]> git.apps.os.sepia.ceph.com Git - ceph.git/commitdiff
osd: fix Connection leaks
authorSage Weil <sage@inktank.com>
Thu, 29 Nov 2012 19:11:17 +0000 (11:11 -0800)
committerSage Weil <sage@inktank.com>
Thu, 29 Nov 2012 20:39:44 +0000 (12:39 -0800)
Messenger::get_connection() returns a reference.  Put it.

Signed-off-by: Sage Weil <sage@inktank.com>
src/osd/OSD.cc

index afdc92f2f5581c3242075e7e6c7772df00cf2ab0..541c5d00e02431f1d68eeeef31cbf2f3eaee2f24 100644 (file)
@@ -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();
 }