RepoMirrors/ceph
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2025-02-07 10:53:30 +00:00
Code Issues Packages Projects Releases Wiki Activity

objecter: ping connections with lingering ops every tick()

Browse Source 
Also, make sure that we initialize linger_op.session once
we have it.

Signed-off-by: Yehuda Sadeh <yehuda@hq.newdream.net>
This commit is contained in:
Yehuda Sadeh 2012-05-02 17:33:43 -07:00 committed by Sage Weil
parent 2629474f52
commit ac85b9e867
1 changed files with 20 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/osdc/Objecter.cc
View File

@ -265,6 +265,13 @@ void Objecter::send_linger(LingerOp *info)
}
}
op_submit(o, info->session);
OSDSession *s = o->session;
if (info->session != s) {
info->session_item.remove_myself();
info->session = s;
if (info->session)
s->linger_ops.push_back(&info->session_item);
}
info->registering = true;
logger->inc(l_osdc_linger_send);
@ -780,6 +787,17 @@ void Objecter::tick()
++laggy_ops;
}
}
for (map<uint64_t,LingerOp*>::iterator p = linger_ops.begin();
p != linger_ops.end();
p++) {
LingerOp *op = p->second;
if (op->session) {
ldout(cct, 0) << " pinging osd that serves lingering tid " << p->first << " (osd." << op->session->osd << ")" << dendl;
toping.insert(op->session);
} else {
ldout(cct, 0) << " lingering tid " << p->first << " does not have session" << dendl;
}
}
logger->set(l_osdc_op_laggy, laggy_ops);
logger->set(l_osdc_osd_laggy, toping.size());
@ -791,8 +809,9 @@ void Objecter::tick()
// (osd reply message policy is lossy)
for (set<OSDSession*>::iterator i = toping.begin();
i != toping.end();
i++)
i++) {
messenger->send_message(new MPing, (*i)->con);
}
}
// reschedule