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 unref()
Decrement reference count and conditionally delete this instance.
virtual void write(const void *buf, size_t count)
Write to the socket.
void unlock() const
Unlock list.
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.
const FUSE_message_t & fmsg() const
Get plain message.
FUSE_header_t header
header
size_t payload_size() const
Get payload size.