]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
msgr: set m->connection for messages sent to self
authorSage Weil <sage@newdream.net>
Wed, 24 Mar 2010 21:04:49 +0000 (14:04 -0700)
committerSage Weil <sage@newdream.net>
Wed, 24 Mar 2010 21:25:46 +0000 (14:25 -0700)
src/msg/SimpleMessenger.h

index cd03a1c9976933677f41fa34ca3dec4410ff38a7..c751630d3760b31e71252b22f76a8e5adc7a3e0c 100644 (file)
@@ -354,6 +354,8 @@ private:
 
     Pipe *local_pipe;
     void local_delivery(Message *m, int priority) {
+      if ((unsigned long)m > 10)
+       m->set_connection(local_pipe->connection_state->get());
       local_pipe->queue_received(m, priority);
     }
 
@@ -365,6 +367,8 @@ private:
     }
     
     void local_delivery(Message *m) {
+      if ((unsigned long)m > 10)
+       m->set_connection(local_pipe->connection_state->get());
       local_pipe->queue_received(m);
     }