#include <netcomm/fawkes/transceiver.h>
Static Public Member Functions | |
static void | send (StreamSocket *s, FawkesNetworkMessageQueue *msgq) |
Send messages. | |
static void | recv (StreamSocket *s, FawkesNetworkMessageQueue *msgq, unsigned int max_num_msgs=8) |
Receive data. |
Utility class that provides methods to send and receive messages via the network. Operates on message queues and a given socket.
Definition at line 34 of file transceiver.h.
void fawkes::FawkesNetworkTransceiver::recv | ( | StreamSocket * | s, | |
FawkesNetworkMessageQueue * | msgq, | |||
unsigned int | max_num_msgs = 8 | |||
) | [static] |
Receive data.
This method receives all messages currently available from the network, or a limited number depending on max_num_msgs. If max_num_msgs is 0 then all messages are read. Note that on a busy connection this may cause recv() to never return! The default is to return after 8 messages. The messages are stored in the supplied message queue.
s | socket to gather messages from | |
msgq | message queue to store received messages in | |
max_num_msgs | maximum number of messages to read from stream in one go. |
ConnectionDiedException | Thrown if any error occurs during the operation since for any error the conncetion is considered dead. |
Definition at line 86 of file transceiver.cpp.
References fawkes::Socket::available(), fawkes::fawkes_message_t::header, fawkes::LockQueue< Type >::lock(), fawkes::fawkes_message_t::payload, fawkes::fawkes_message_header_t::payload_size, fawkes::Socket::read(), and fawkes::LockQueue< Type >::unlock().
Referenced by fawkes::FawkesNetworkClientRecvThread::recv().
void fawkes::FawkesNetworkTransceiver::send | ( | StreamSocket * | s, | |
FawkesNetworkMessageQueue * | msgq | |||
) | [static] |
Send messages.
s | socket over which the data shall be transmitted. | |
msgq | message queue that contains the messages that have to be sent |
ConnectionDiedException | Thrown if any error occurs during the operation since for any error the conncetion is considered dead. |
Definition at line 51 of file transceiver.cpp.
References fawkes::fawkes_message_t::header, fawkes::LockQueue< Type >::lock(), fawkes::fawkes_message_t::payload, fawkes::LockQueue< Type >::unlock(), and fawkes::Socket::write().
Referenced by fawkes::FawkesNetworkServerClientSendThread::loop(), and fawkes::FawkesNetworkClientSendThread::loop().