Added a bit of debug and implemented messagehandler.

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);