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

mds: don't renew revoking lease

Browse Source 
MDS may receives lease renew request while lease is being revoked,
just ignore the renew request.

Signed-off-by: Yan, Zheng <zheng.z.yan@intel.com>
This commit is contained in:
Yan, Zheng 2012-12-13 12:20:29 +08:00
parent f1196c7e93
commit 7e23321b72
1 changed files with 14 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/mds/Locker.cc
View File

@ -2914,18 +2914,20 @@ void Locker::handle_client_lease(MClientLease *m)
case CEPH_MDS_LEASE_RENEW:
{
dout(7) << "handle_client_lease client." << client
<< " renew on " << *dn << dendl;
int pool = 1; // fixme.. do something smart!
m->h.duration_ms = (int)(1000 * mdcache->client_lease_durations[pool]);
m->h.seq = ++l->seq;
m->clear_payload();
utime_t now = ceph_clock_now(g_ceph_context);
now += mdcache->client_lease_durations[pool];
mdcache->touch_client_lease(l, pool, now);
mds->send_message_client_counted(m, m->get_connection());
dout(7) << "handle_client_lease client." << client << " renew on " << *dn
<< (!dn->lock.can_lease(client)?", revoking lease":"") << dendl;
if (dn->lock.can_lease(client)) {
int pool = 1; // fixme.. do something smart!
m->h.duration_ms = (int)(1000 * mdcache->client_lease_durations[pool]);
m->h.seq = ++l->seq;
m->clear_payload();
utime_t now = ceph_clock_now(g_ceph_context);
now += mdcache->client_lease_durations[pool];
mdcache->touch_client_lease(l, pool, now);
mds->send_message_client_counted(m, m->get_connection());
}
}
break;