msgr: Remove noisy debug output.

diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc
index 558807b0dc20fc822d8588bcfa0a5f7d9946e653..227a24b74ae1c063e0f708c4334a3b6951fb52ce 100644 (file)
--- a/src/msg/SimpleMessenger.cc
+++ b/src/msg/SimpleMessenger.cc
@@ -259,12 +259,9 @@ void SimpleMessenger::Accepter::stop()
 
 void SimpleMessenger::Endpoint::dispatch_entry()
 {
-  dout(0) << "entered SimpleMessenger::Endpoint::dispatch_entry" << dendl;
   endpoint_lock.Lock();
   while (!stop) {
-    dout(0) << "in outer !stop loop of SimpleMessenger::Endpoint::dispatch_entry" << dendl;
     while (!queued_pipes.empty()) {
-      dout(0) << "SimpleMessenger::Endpoint::dispatch_entry delivering a message qlen " << qlen << dendl;
       //get highest-priority pipe
       map<int, xlist<Pipe *> >::reverse_iterator high_iter =
        queued_pipes.rbegin();
@@ -272,14 +269,12 @@ void SimpleMessenger::Endpoint::dispatch_entry()
       xlist<Pipe *>& pipe_list = high_iter->second;
 
       Pipe *pipe = pipe_list.front();
-      dout(0) << "high priority: " << priority << " taking pipe " << pipe << dendl;
       //move pipe to back of line -- or just take off if no more messages
       pipe->pipe_lock.Lock();
       list<Message *>& m_queue = pipe->in_q[priority];
       pipe_list.pop_front();
       if (m_queue.size() > 1) {
        pipe_list.push_back(pipe->queue_items[priority]);
-       dout(0) << "requeuing pipe because there are more messages" << dendl;
       }
       if (pipe_list.empty())
        queued_pipes.erase(priority);

diff --git a/src/msg/SimpleMessenger.h b/src/msg/SimpleMessenger.h
index 154b45260d335af2090d3a021c9a6b0eda227e53..8fd31715d6725a2fba39553ad58dfaa8c9c69610 100644 (file)
--- a/src/msg/SimpleMessenger.h
+++ b/src/msg/SimpleMessenger.h
@@ -218,7 +218,6 @@ private:
     //we have two queue_received's to allow local signal delivery
     // via Message * (that doesn't actually point to a Message)
     void queue_received(Message *m, int priority) {
-      dout(0) << "queuing received message " << m << "in msgr " << rank << dendl;
       list<Message *>& queue = in_q[priority];
 
       pipe_lock.Lock();
@@ -237,7 +236,6 @@ private:
       ++rank->local_endpoint->qlen;
       rank->local_endpoint->qlen_lock.unlock();
       rank->local_endpoint->cond.Signal();
-      dout(0) << "finished queuing received message " << m << "in msgr " << rank << dendl;
     }
     
     void queue_received(Message *m) {