24 #include <fvutils/net/fuse_transceiver.h> 25 #include <fvutils/net/fuse_message_queue.h> 26 #include <fvutils/net/fuse_message.h> 27 #include <netcomm/socket/stream.h> 28 #include <netcomm/utils/exceptions.h> 30 #include <netinet/in.h> 61 while ( ! msgq->empty() ) {
93 unsigned int max_num_msgs)
98 unsigned int num_msgs = 0;
105 if ( payload_size > 0 ) {
107 msg.
payload = malloc(payload_size);
117 }
while ( s->
available() && (num_msgs < max_num_msgs) );
void unlock() const
Unlock list.
void unref()
Decrement reference count and conditionally delete this instance.
virtual void write(const void *buf, size_t count)
Write to the socket.
Fawkes library namespace.
TCP stream socket over IP.
virtual bool available()
Check if data is available.
void pack()
Pack data for sending.
A LockQueue of FuseNetworkMessage to hold messages in inbound and outbound queues.
virtual size_t read(void *buf, size_t count, bool read_all=true)
Read from socket.
Thrown if the connection died during an operation.
void lock() const
Lock queue.
size_t payload_size() const
Get payload size.
FUSE_header_t header
header
const FUSE_message_t & fmsg() const
Get plain message.