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/connectionhandler.cc | 6 ++++++ 1 file changed, 6 insertions(+) (limited to 'src/connectionhandler.cc') diff --git a/src/connectionhandler.cc b/src/connectionhandler.cc index 6fdcd51..9362965 100644 --- a/src/connectionhandler.cc +++ b/src/connectionhandler.cc @@ -27,6 +27,8 @@ */ #include "connectionhandler.h" +#include + // Global ConnectionHandler. ConnectionHandler connection_handler; @@ -42,11 +44,13 @@ void ConnectionHandler::init(clientid_t clientid) void ConnectionHandler::close(clientid_t clientid) { connlist.erase(clientid); + printf("Removed connection\n"); } void ConnectionHandler::observe(clientid_t clientid, taskid_t taskid) { connlist[clientid].insert(taskid); + printf("Added observer of %d\n", taskid); } void ConnectionHandler::unobserve(clientid_t clientid, taskid_t taskid) @@ -56,10 +60,12 @@ void ConnectionHandler::unobserve(clientid_t clientid, taskid_t taskid) std::set ConnectionHandler::observerlist(TaskIdList tasks) { + printf("Observerlist request\n"); std::set clients; for(TaskIdList::iterator i = tasks.begin(); i != tasks.end(); i++) { taskid_t tid = *i; + printf("Locating observers of node %d\n", tid); for(ConnectionList::iterator ci = connlist.begin(); ci != connlist.end(); ci++) { std::set::iterator ti = ci->second.find(tid); -- cgit v1.2.3