Jpp
18.0.0-rc.2
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... | |
void | 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 42 of file JTCPSocket.hh.
|
inlineinherited |
Get non-blocking of I/O.
Definition at line 66 of file JTCPSocket.hh.
|
inlineinherited |
Set the TCP idle time.
t_s | time [s] |
Definition at line 84 of file JTCPSocket.hh.
|
inlineinherited |
Set the TCP idle count.
count | count |
Definition at line 95 of file JTCPSocket.hh.
|
inlineinherited |
Set the TCP interval time.
t_s | time [s] |
Definition at line 106 of file JTCPSocket.hh.
|
inlineinherited |
Set TCP no-delay.
on | true to set TCP no-delay; false to disable |
Definition at line 117 of file JTCPSocket.hh.
|
inlineinherited |
Get TCP no-delay.
Definition at line 128 of file JTCPSocket.hh.
|
inlineinherited |
Accept connection from a server.
server | file descriptor of server socket |
Definition at line 139 of file JTCPSocket.hh.
|
inlineinherited |
Connect to port on local host.
port | port number |
Definition at line 152 of file JTCPSocket.hh.
|
inlineinherited |
Connect to port on specified host.
hostname | host name |
Definition at line 163 of file JTCPSocket.hh.
|
inlineinherited |
Connect to port on specified host.
hostname | host name |
port | port number |
Definition at line 175 of file JTCPSocket.hh.
|
inlineinherited |
Connect to port on specified host.
ip_number | IP number |
port | port number |
Definition at line 187 of file JTCPSocket.hh.
|
inlineinherited |
Shut down socket.
Definition at line 72 of file JSocket.hh.
|
inlineinherited |
Set keep alive of socket.
on | true to enable keep alive; false to disable |
Definition at line 87 of file JSocket.hh.
|
inlineinherited |
Get keep alive of socket.
Definition at line 98 of file JSocket.hh.
|
inlineinherited |
Set reuse address.
on | true to enable reuse address; false to disable |
Definition at line 109 of file JSocket.hh.
|
inlineinherited |
Get reuse address.
Definition at line 120 of file JSocket.hh.
|
inlineinherited |
Set receive buffer size.
size | number of bytes |
Definition at line 131 of file JSocket.hh.
|
inlineinherited |
|
inlineinherited |
Set send buffer size.
size | number of bytes |
Definition at line 153 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 181 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 220 of file JSocket.hh.
|
inlineprotectedinherited |
Set socket option.
level | level |
option | option |
value | value |
Definition at line 257 of file JSocket.hh.
|
inlineprotectedinherited |
Get socket option.
level | level |
option | option |
Definition at line 275 of file JSocket.hh.
|
inlineinherited |
Check availability of input.
This method returns true if at least one byte can be read without blocking.
timeout | timeout |
Definition at line 100 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 113 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.