RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-01-01 08:32:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

mgrc: mark down connections with dead sessions

Browse Source 
Signed-off-by: John Spray <john.spray@redhat.com>
This commit is contained in:
John Spray 2016-08-04 15:03:51 +01:00
parent e6de53aa60
commit c38d4915a9
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/mgr/MgrClient.cc
View File

@ -95,6 +95,7 @@ bool MgrClient::handle_mgr_map(MMgrMap *m)
if (session) {
ldout(cct, 4) << "Terminating session with "
<< session->con->get_peer_addr() << dendl;
session->con->mark_down();
delete session;
session = nullptr;
stats_period = 0;
@ -286,7 +287,7 @@ int MgrClient::start_command(const vector<string>& cmd, const bufferlist& inbl,
ldout(cct, 20) << "cmd: " << cmd << dendl;
if (session == nullptr) {
derr << "no session, waiting" << dendl;
lderr(cct) << "no session, waiting" << dendl;
wait_on_list(waiting_for_session);
}
@ -301,6 +302,8 @@ int MgrClient::start_command(const vector<string>& cmd, const bufferlist& inbl,
// Leaving fsid argument null because it isn't used.
MCommand *m = op->get_message({});
assert(session);
assert(session->con);
session->con->send_message(m);
return 0;