mirror of
https://github.com/ceph/ceph
synced 2025-01-19 01:21:49 +00:00
osd: fix Connection leaks
Messenger::get_connection() returns a reference. Put it. Signed-off-by: Sage Weil <sage@inktank.com>
This commit is contained in:
parent
e18f9ee844
commit
a87361ef30
@ -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();
|
||||
}
|
||||
|
Loading…
Reference in New Issue
Block a user