From: Sage Weil <sage@inktank.com>
Date: Tue, 1 Jul 2014 23:43:46 +0000 (-0700)
Subject: msg: debug Connection refs
X-Git-Tag: v0.84~148^2~4
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=242ee89c96848ee816241e9e7be08ea56fb26f06;p=ceph.git

msg: debug Connection refs

Signed-off-by: Sage Weil <sage@inktank.com>
---

diff --git a/src/mon/Monitor.cc b/src/mon/Monitor.cc
index f983284eb8d2..8e1012447958 100644
--- a/src/mon/Monitor.cc
+++ b/src/mon/Monitor.cc
@@ -2633,7 +2633,7 @@ void Monitor::handle_forward(MForward *m)
     dout(0) << "forward from entity with insufficient caps! " 
 	    << session->caps << dendl;
   } else {
-    Connection *c = new Connection(NULL);  // msgr must be null; see PaxosService::dispatch()
+    Connection *c = new Connection(g_ceph_context, NULL);  // msgr must be null; see PaxosService::dispatch()
     MonSession *s = new MonSession(m->msg->get_source_inst(), c);
     c->set_priv(s);
     c->set_peer_addr(m->client.addr);
diff --git a/src/msg/Message.h b/src/msg/Message.h
index f3c9a4c8dca9..0205eed957e9 100644
--- a/src/msg/Message.h
+++ b/src/msg/Message.h
@@ -190,8 +190,9 @@ public:
   friend class boost::intrusive_ptr<Connection>;
 
 public:
-  Connection(Messenger *m)
-    : lock("Connection::lock"),
+  Connection(CephContext *cct, Messenger *m)
+    : RefCountedObject(cct),
+      lock("Connection::lock"),
       msgr(m),
       priv(NULL),
       peer_type(-1),
diff --git a/src/msg/Pipe.cc b/src/msg/Pipe.cc
index e0c5ef9dc8e4..68825f8c1c84 100644
--- a/src/msg/Pipe.cc
+++ b/src/msg/Pipe.cc
@@ -95,7 +95,7 @@ Pipe::Pipe(SimpleMessenger *r, int st, Connection *con)
     connection_state = con;
     connection_state->reset_pipe(this);
   } else {
-    connection_state = new Connection(msgr);
+    connection_state = new Connection(msgr->cct, msgr);
     connection_state->pipe = get();
   }
 
diff --git a/src/msg/SimpleMessenger.cc b/src/msg/SimpleMessenger.cc
index 4a8711f722da..3962d3bc0921 100644
--- a/src/msg/SimpleMessenger.cc
+++ b/src/msg/SimpleMessenger.cc
@@ -52,7 +52,7 @@ SimpleMessenger::SimpleMessenger(CephContext *cct, entity_name_t name,
     dispatch_throttler(cct, string("msgr_dispatch_throttler-") + mname, cct->_conf->ms_dispatch_throttle_bytes),
     reaper_started(false), reaper_stop(false),
     timeout(0),
-    local_connection(new Connection(this))
+    local_connection(new Connection(cct, this))
 {
   ceph_spin_init(&global_seq_lock);
   init_local_connection();