From: Sage Weil <sage@inktank.com>
Date: Thu, 29 Nov 2012 19:11:17 +0000 (-0800)
Subject: osd: fix Connection leaks
X-Git-Tag: v0.56~131^2~8
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=a87361ef3090d5bda6a6b3bb15e4fcf5dd9645f0;p=ceph.git

osd: fix Connection leaks

Messenger::get_connection() returns a reference.  Put it.

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

diff --git a/src/osd/OSD.cc b/src/osd/OSD.cc
index afdc92f2f558..541c5d00e024 100644
--- a/src/osd/OSD.cc
+++ b/src/osd/OSD.cc
@@ -4703,6 +4703,7 @@ void OSD::do_notifies(
 	service.send_message_osd_cluster(it->first, m, curmap->get_epoch());
       }
     }
+    con->put();
   }
 }
 
@@ -4740,6 +4741,7 @@ void OSD::do_queries(map< int, map<pg_t,pg_query_t> >& query_map,
 	service.send_message_osd_cluster(who, m, curmap->get_epoch());
       }
     }
+    con->put();
   }
 }
 
@@ -4776,6 +4778,7 @@ void OSD::do_infos(map<int,vector<pair<pg_notify_t, pg_interval_map_t> > >& info
 	service.send_message_osd_cluster(p->first, m, curmap->get_epoch());
       }
     }
+    con->put();
   }
   info_map.clear();
 }