diff options
Diffstat (limited to 'src/task_proto.cc')
-rw-r--r-- | src/task_proto.cc | 10 |
1 files changed, 8 insertions, 2 deletions
diff --git a/src/task_proto.cc b/src/task_proto.cc index 304080d..24be3b0 100644 --- a/src/task_proto.cc +++ b/src/task_proto.cc @@ -133,17 +133,23 @@ int callback_lws_task(struct libwebsocket_context * context, data.append((char*)in, len); MessageList mlst = parse_msg(data); + printf("Handling %d incoming message\n", mlst.size()); MessageList omsgs = handle_msg(mlst); + printf("Handling %d outgoing messages\n", omsgs.size()); + MessageList::iterator omi = omsgs.begin(); while(omi != omsgs.end()) { std::string msg; msg.append((size_t)LWS_SEND_BUFFER_PRE_PADDING, ' '); msg.append(msg_tostring(*omi)); msg.append((size_t)LWS_SEND_BUFFER_POST_PADDING, ' '); - + + printf("%d nodes affected by command\n", omi->nodes.size()); + std::set<clientid_t> clients = connection_handler.observerlist(omi->nodes); - + printf("Writing message to %d clients\n", clients.size()); + std::set<clientid_t>::iterator ci = clients.begin(); while(ci != clients.end()) { msgqueue[*ci].push(msg); |