|
Jpp
18.3.0-rc.1
the software that should make you happy
|
ControlHost client manager. More...
Public Member Functions | |
| JClient () | |
| Default constructor. More... | |
| JClient (const JTCPSocket &socket) | |
| Constructor. More... | |
| const std::string & | getNickname () const |
| Get nick name. More... | |
| void | setNickname (const std::string &nick_name) |
| Set nick name. More... | |
| bool | checkRequest () const |
| Check request. More... | |
| void | incrementRequest () |
| Increment request by one. More... | |
| void | decrementRequest () |
| Decrement request by one. More... | |
| void | setRequestAll () |
| Set no request. More... | |
| const std::set< JTag > & | getSubscriptionAll () const |
| Get subscription. More... | |
| const std::set< JTag > & | getSubscriptionAny () const |
| Get subscription. More... | |
| bool | setSubscription (const std::string &subscription) |
| Set subcription. More... | |
| bool | checkSubscriptionAll (const JPrefix_t &prefix) const |
| Check subscription for given prefix. More... | |
| bool | checkSubscriptionAny (const JPrefix_t &prefix) const |
| Check subscription for given prefix. More... | |
| bool | checkSubscription (const JPrefix_t &prefix) const |
| Check subscription for given prefix. More... | |
| void | add (const JDispatch &message) |
| Add message to client queues depending on subscription of each client. More... | |
| void | drop () |
| Drop all messages for which the client has not the 'all' subscription. More... | |
| void | setNonBlocking (const bool on) |
| Set non-blocking of I/O. More... | |
| bool | getNonBlocking () const |
| Get non-blocking of I/O. More... | |
| void | setKeepIdle (const int t_s) |
| Set the TCP idle time. More... | |
| void | setKeepCnt (const int count) |
| Set the TCP idle count. More... | |
| void | setKeepIntvl (const int t_s) |
| Set the TCP interval time. More... | |
| void | setTcpNoDelay (const bool on) |
| Set TCP no-delay. More... | |
| bool | getTcpNoDelay () const |
| Get TCP no-delay. More... | |
| void | accept (const int server) |
| Accept connection from a server. More... | |
| void | connect (const int port) |
| Connect to port on local host. More... | |
| void | connect (const JHostname &hostname) |
| Connect to port on specified host. More... | |
| void | connect (const std::string &hostname, const int port) |
| Connect to port on specified host. More... | |
| void | connect (const int ip_number, const int port) |
| Connect to port on specified host. More... | |
| int | shutdown () |
| Shut down socket. More... | |
| void | setKeepAlive (const bool on) |
| Set keep alive of socket. More... | |
| bool | getKeepAlive () const |
| Get keep alive of socket. More... | |
| void | setReuseAddress (const bool on) |
| Set reuse address. More... | |
| bool | getReuseAddress () const |
| Get reuse address. More... | |
| void | setReceiveBufferSize (const int size) |
| Set receive buffer size. More... | |
| int | getReceiveBufferSize () const |
| Set receive buffer size. More... | |
| void | setSendBufferSize (const int size) |
| Set send buffer size. More... | |
| int | getSendBufferSize () const |
| Get send buffer size. More... | |
| virtual int | read (char *buffer, const int length) override |
| Read data from socket. More... | |
| virtual int | write (const char *buffer, const int length) override |
| Write data to socket. More... | |
| int | close () |
| Close file. More... | |
| bool | in_avail (JTimeval timeout=JTimeval::min()) const |
| Check availability of input. More... | |
| bool | out_avail (JTimeval timeout=JTimeval::min()) const |
| Check availability of output. More... | |
| virtual bool | good () const |
| Check status. More... | |
| virtual bool | fail () const |
| Check status. More... | |
| virtual bool | bad () const |
| Check status. More... | |
| virtual bool | eof () const |
| Check end of file. More... | |
| bool | less (const JAbstractFile &file) const |
| Less than operation. More... | |
| int | getFileDescriptor () const |
| Get file descriptor. More... | |
| void | setFileDescriptor (const int file) |
| Set file descriptor. More... | |
| bool | is_open () const |
| Get open status. More... | |
| const sockaddr * | getSockaddr () const |
| Get sockaddr. More... | |
| sockaddr * | getSockaddr () |
| Get sockaddr. More... | |
| int | getFamily () const |
| Get family. More... | |
| void | setFamily (const int family) |
| Set family. More... | |
| std::string | getHostname () const |
| Get host name. More... | |
| int | getIPnumber () const |
| Get IP number. More... | |
| void | setIPnumber (const int ip_number) |
| Set IP number. More... | |
| void | setIPnumber () |
| Set any IP number. More... | |
| int | getPort () const |
| Get port number. More... | |
| void | setPort (const int port) |
| Set port number. More... | |
Static Public Member Functions | |
| static int | sizeOf () |
| Get size of object. More... | |
Public Attributes | |
| JSocketInputChannel_t | in |
| reader for incoming messages More... | |
| JSocketNonblockingWriter | out |
| writer for outgoing messages More... | |
| std::deque< JDispatch > | queue |
| queue for outgoing messages More... | |
Static Public Attributes | |
| static unsigned int | QUEUE_LIMIT |
| Maximum number of messages in queue. More... | |
| static const int | FILE_CLOSED = -1 |
Protected Member Functions | |
| template<class T > | |
| void | setOption (const int level, const int option, const T value) |
| Set socket option. More... | |
| template<class T > | |
| T | getOption (const int level, const int option) const |
| Get socket option. More... | |
Protected Attributes | |
| std::set< JTag > | subscriptionAll |
| std::set< JTag > | subscriptionAny |
| std::string | nick_name |
| bool | requestAll |
| int | requestCounter |
| int | fileDescriptor |
ControlHost client manager.
Definition at line 243 of file JLigier.cc.
|
inline |
Default constructor.
Definition at line 255 of file JLigier.cc.
|
inline |
Constructor.
| socket | socket |
Definition at line 269 of file JLigier.cc.
|
inline |
|
inline |
|
inline |
Check request.
Definition at line 305 of file JLigier.cc.
|
inline |
|
inline |
|
inline |
|
inline |
Set subcription.
| subscription | subscription |
Definition at line 366 of file JLigier.cc.
|
inline |
Check subscription for given prefix.
| prefix | prefix |
Definition at line 398 of file JLigier.cc.
|
inline |
Check subscription for given prefix.
| prefix | prefix |
Definition at line 410 of file JLigier.cc.
|
inline |
Check subscription for given prefix.
| prefix | prefix |
Definition at line 422 of file JLigier.cc.
|
inline |
Add message to client queues depending on subscription of each client.
Note that adding a message may result in dropping (other) messages.
| message | message |
Definition at line 434 of file JLigier.cc.
|
inline |
Drop all messages for which the client has not the 'all' subscription.
Definition at line 450 of file JLigier.cc.
|
inlineinherited |
Set non-blocking of I/O.
| on | true to enable non-blocking; false to disable |
Definition at line 53 of file JTCPSocket.hh.
|
inlineinherited |
Get non-blocking of I/O.
Definition at line 77 of file JTCPSocket.hh.
|
inlineinherited |
Set the TCP idle time.
| t_s | time [s] |
Definition at line 95 of file JTCPSocket.hh.
|
inlineinherited |
Set the TCP idle count.
| count | count |
Definition at line 106 of file JTCPSocket.hh.
|
inlineinherited |
Set the TCP interval time.
| t_s | time [s] |
Definition at line 117 of file JTCPSocket.hh.
|
inlineinherited |
Set TCP no-delay.
| on | true to set TCP no-delay; false to disable |
Definition at line 128 of file JTCPSocket.hh.
|
inlineinherited |
Get TCP no-delay.
Definition at line 139 of file JTCPSocket.hh.
|
inlineinherited |
Accept connection from a server.
| server | file descriptor of TCP server socket |
Definition at line 150 of file JTCPSocket.hh.
|
inlineinherited |
Connect to port on local host.
| port | port number |
Definition at line 163 of file JTCPSocket.hh.
|
inlineinherited |
Connect to port on specified host.
| hostname | host name |
Definition at line 174 of file JTCPSocket.hh.
|
inlineinherited |
Connect to port on specified host.
| hostname | host name |
| port | port number |
Definition at line 186 of file JTCPSocket.hh.
|
inlineinherited |
Connect to port on specified host.
| ip_number | IP number |
| port | port number |
Definition at line 198 of file JTCPSocket.hh.
|
inlineinherited |
Shut down socket.
Definition at line 74 of file JSocket.hh.
|
inlineinherited |
Set keep alive of socket.
| on | true to enable keep alive; false to disable |
Definition at line 89 of file JSocket.hh.
|
inlineinherited |
Get keep alive of socket.
Definition at line 100 of file JSocket.hh.
|
inlineinherited |
Set reuse address.
| on | true to enable reuse address; false to disable |
Definition at line 111 of file JSocket.hh.
|
inlineinherited |
Get reuse address.
Definition at line 122 of file JSocket.hh.
|
inlineinherited |
Set receive buffer size.
| size | number of bytes |
Definition at line 133 of file JSocket.hh.
|
inlineinherited |
|
inlineinherited |
Set send buffer size.
| size | number of bytes |
Definition at line 155 of file JSocket.hh.
|
inlineinherited |
|
inlineoverridevirtualinherited |
Read data from socket.
This method handles I/O errors in such a way that:
| buffer | buffer |
| length | number of bytes to read |
Reimplemented from JLANG::JFile.
Reimplemented in JNET::JUDPSocket, and JNET::JSocketBlocking.
Definition at line 183 of file JSocket.hh.
|
inlineoverridevirtualinherited |
Write data to socket.
This method handles I/O errors in such a way that:
| buffer | buffer |
| length | number of bytes to write |
Reimplemented from JLANG::JFile.
Reimplemented in JNET::JUDPSocket, and JNET::JSocketBlocking.
Definition at line 222 of file JSocket.hh.
|
inlineprotectedinherited |
Set socket option.
| level | level |
| option | option |
| value | value |
Definition at line 259 of file JSocket.hh.
|
inlineprotectedinherited |
Get socket option.
| level | level |
| option | option |
Definition at line 277 of file JSocket.hh.
|
inlineinherited |
|
inlineinherited |
Check availability of input.
This method returns true if at least one byte can be read without blocking.
| timeout | timeout |
Definition at line 106 of file JFile.hh.
|
inlineinherited |
Check availability of output.
This method returns true if at least one byte can be written without blocking.
| timeout | timeout |
Definition at line 119 of file JFile.hh.
|
inlinevirtualinherited |
|
inlinevirtualinherited |
Check status.
|
inlinevirtualinherited |
|
inlinevirtualinherited |
Check end of file.
|
inlineinherited |
Less than operation.
| file | JAbstractFile to be compared |
Definition at line 64 of file JAbstractFile.hh.
|
inlineinherited |
|
inlineinherited |
Set file descriptor.
| file | file descriptor |
Definition at line 86 of file JAbstractFile.hh.
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
Get host name.
Definition at line 88 of file JSocketAddress.hh.
|
inlineinherited |
|
inlineinherited |
|
inlineinherited |
Set any IP number.
Definition at line 119 of file JSocketAddress.hh.
|
inlineinherited |
|
inlineinherited |
Set port number.
| port | port number |
Definition at line 141 of file JSocketAddress.hh.
|
inlinestaticinherited |
|
static |
| JSocketInputChannel_t JNET::JClient::in |
reader for incoming messages
Definition at line 461 of file JLigier.cc.
| JSocketNonblockingWriter JNET::JClient::out |
writer for outgoing messages
Definition at line 462 of file JLigier.cc.
| std::deque<JDispatch> JNET::JClient::queue |
queue for outgoing messages
Definition at line 463 of file JLigier.cc.
Definition at line 466 of file JLigier.cc.
Definition at line 467 of file JLigier.cc.
|
protected |
Definition at line 468 of file JLigier.cc.
|
protected |
Definition at line 469 of file JLigier.cc.
|
protected |
Definition at line 470 of file JLigier.cc.
|
staticinherited |
Definition at line 27 of file JAbstractFile.hh.
|
protectedinherited |
Definition at line 102 of file JAbstractFile.hh.
1.8.5