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>
33 using namespace fawkes;
35 namespace firevision {
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) );