omegalib
13.1
|
#include <MissionControl.h>
Public Member Functions | |
MissionControlConnection (ConnectionInfo ci, IMissionControlMessageHandler *msgHandler, MissionControlServer *server) | |
virtual | ~MissionControlConnection () |
virtual void | handleData () |
virtual void | handleClosed () |
virtual void | handleConnected () |
Connection events. More... | |
virtual void | handleError (const ConnectionError &err) |
void | sendMessage (const char *header, void *data, size_t size) |
void | goodbyeServer () |
Client side: tells the server we are done talking and waits for graceful close. More... | |
String | getName () |
virtual void | setName (const String &name) |
bool | isLogForwardingEnabled () |
void | setLogForwardingEnabled (bool value) |
Public Member Functions inherited from omicron::TcpConnection | |
TcpConnection (const ConnectionInfo &ci) | |
virtual | ~TcpConnection () |
void | handle_connect (const asio::error_code &error) |
tcp::socket & | getSocket () |
Connection properties. More... | |
ConnectionState | getState () |
Gets the connection state. More... | |
const ConnectionInfo & | getConnectionInfo () |
Gets the connection info object. More... | |
bool | poll () |
Connection management. More... | |
void | close () |
Forces a connection close. More... | |
void | waitClose () |
Waits for the other end to close the connection. More... | |
void | open (const String &host, int port) |
Opens a connection to a server. More... | |
void | write (const String &data) |
Data IO Note: all the write methods are blocking: they return only when the data has been fully written to the internal buffers. More... | |
void | write (void *data, size_t size) |
Writes a buffer to the connection stream. More... | |
size_t | readUntil (void *buffer, size_t size, char delimiter= '\0') |
Synchronously read byte data until the specified delimiter is found or the buffer fills up. More... | |
size_t | read (void *buffer, size_t size) |
Synchronously read thre specified number of bytes from the stream. More... | |
size_t | availableBytes () |
Returns the number of bytes available to be read. More... | |
Public Member Functions inherited from omicron::ReferenceType | |
ReferenceType () | |
virtual | ~ReferenceType () |
void | ref () |
void | unref () |
long | refCount () |
Additional Inherited Members | |
Public Types inherited from omicron::TcpConnection | |
enum | ConnectionState { ConnectionListening, ConnectionOpen, ConnectionClosed } |
Static Public Member Functions inherited from omicron::ReferenceType | |
static void | printObjCounts () |
Protected Member Functions inherited from omicron::TcpConnection | |
void | doHandleConnected () |
Protected Attributes inherited from omicron::TcpConnection | |
String | myHost |
int | myPort |
ConnectionInfo | myConnectionInfo |
ConnectionState | myState |
tcp::socket | mySocket |
asio::streambuf | myInputBuffer |
Static Protected Attributes inherited from omicron::ReferenceType | |
static List< ReferenceType * > | mysObjList |
omega::MissionControlConnection::MissionControlConnection | ( | ConnectionInfo | ci, |
IMissionControlMessageHandler * | msgHandler, | ||
MissionControlServer * | server | ||
) |
|
virtual |
|
inline |
void omega::MissionControlConnection::goodbyeServer | ( | ) |
Client side: tells the server we are done talking and waits for graceful close.
|
virtual |
Reimplemented from omicron::TcpConnection.
|
virtual |
Connection events.
Reimplemented from omicron::TcpConnection.
|
virtual |
Reimplemented from omicron::TcpConnection.
|
virtual |
Reimplemented from omicron::TcpConnection.
|
inline |
void omega::MissionControlConnection::sendMessage | ( | const char * | header, |
void * | data, | ||
size_t | size | ||
) |
void omega::MissionControlConnection::setLogForwardingEnabled | ( | bool | value | ) |
|
virtual |