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