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));