From 9dfc4fb240095a55725e7bb4faaf34c3136b5947 Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Wed, 24 Mar 2010 14:04:49 -0700 Subject: [PATCH] msgr: set m->connection for messages sent to self --- src/msg/SimpleMessenger.h | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/src/msg/SimpleMessenger.h b/src/msg/SimpleMessenger.h index cd03a1c997693..c751630d3760b 100644 --- a/src/msg/SimpleMessenger.h +++ b/src/msg/SimpleMessenger.h @@ -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); } -- 2.39.5