24 #include <gui_utils/connection_dispatcher.h>
25 #include <netcomm/fawkes/client.h>
44 client_ =
new FawkesNetworkClient();
58 unsigned short int port,
76 ConnectionDispatcher::connect_signals()
78 dispatcher_connected_.connect(
81 dispatcher_message_received_.connect(
116 client_owned_ =
false;
125 FawkesNetworkClient *
135 ConnectionDispatcher::operator bool()
137 return (client_ && client_->connected());
146 signal_connected_.emit();
155 signal_disconnected_.emit();
164 queue_message_received_.
lock();
165 while (!queue_message_received_.empty()) {
167 signal_message_received_.emit(msg);
169 queue_message_received_.pop();
171 queue_message_received_.
unlock();
184 queue_message_received_.push_locked(m);
185 dispatcher_message_received_();
191 dispatcher_disconnected_();
197 dispatcher_connected_();
205 sigc::signal<void, FawkesNetworkMessage *>
208 return signal_message_received_;
218 return signal_connected_;
229 return signal_disconnected_;