24 #include <netcomm/fawkes/message.h>
25 #include <netcomm/fawkes/message_queue.h>
26 #include <netcomm/fawkes/transceiver.h>
27 #include <netcomm/socket/stream.h>
28 #include <netcomm/utils/exceptions.h>
29 #include <netinet/in.h>
55 while (!msgq->empty()) {
61 s->write(f.
payload, payload_size);
65 }
catch (SocketException &e) {
67 throw ConnectionDiedException(
"Write failed");
86 FawkesNetworkMessageQueue *msgq,
87 unsigned int max_num_msgs)
92 unsigned int num_msgs = 0;
93 while (s->available() && (num_msgs++ < max_num_msgs)) {
99 if (payload_size > 0) {
100 msg.
payload = malloc(payload_size);
101 s->read(msg.
payload, payload_size);