From b320cc10871217d51e3458bf85a22e7d50ee4aec Mon Sep 17 00:00:00 2001 From: Jonas Suhr Christensen Date: Fri, 30 Mar 2012 16:04:03 +0200 Subject: Added a bit of debug and implemented messagehandler. --- src/task_proto.cc | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) (limited to 'src/task_proto.cc') 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 clients = connection_handler.observerlist(omi->nodes); - + printf("Writing message to %d clients\n", clients.size()); + std::set::iterator ci = clients.begin(); while(ci != clients.end()) { msgqueue[*ci].push(msg); -- cgit v1.2.3