From 35f592a435c08c425e84196af876b9168f1c573a Mon Sep 17 00:00:00 2001 From: Sage Weil Date: Thu, 10 Jun 2010 12:55:52 -0700 Subject: [PATCH] --- yaml --- r: 208829 b: refs/heads/master c: ee6b272b9c3447a78fa831e37b925aefd5587ec9 h: refs/heads/master i: 208827: 996814b57d23c867a83b77911a27dfbbc450b90a v: v3 --- [refs] | 2 +- trunk/fs/ceph/caps.c | 2 +- trunk/fs/ceph/mds_client.c | 10 ++++------ trunk/fs/ceph/mds_client.h | 3 +-- 4 files changed, 7 insertions(+), 10 deletions(-) diff --git a/[refs] b/[refs] index ded433b449b3..fbda83d9bbd2 100644 --- a/[refs] +++ b/[refs] @@ -1,2 +1,2 @@ --- -refs/heads/master: 2962507ca204f886967e1a089d9bec206d427c22 +refs/heads/master: ee6b272b9c3447a78fa831e37b925aefd5587ec9 diff --git a/trunk/fs/ceph/caps.c b/trunk/fs/ceph/caps.c index b28915d5f404..a5b5725931bf 100644 --- a/trunk/fs/ceph/caps.c +++ b/trunk/fs/ceph/caps.c @@ -2717,7 +2717,7 @@ void ceph_handle_caps(struct ceph_mds_session *session, * along for the mds (who clearly thinks we still have this * cap). */ - ceph_add_cap_releases(mdsc, session, -1); + ceph_add_cap_releases(mdsc, session); ceph_send_cap_releases(mdsc, session); goto done; } diff --git a/trunk/fs/ceph/mds_client.c b/trunk/fs/ceph/mds_client.c index dd440bd438a9..26a5368e91f2 100644 --- a/trunk/fs/ceph/mds_client.c +++ b/trunk/fs/ceph/mds_client.c @@ -1067,15 +1067,13 @@ static int trim_caps(struct ceph_mds_client *mdsc, * Called under s_mutex. */ int ceph_add_cap_releases(struct ceph_mds_client *mdsc, - struct ceph_mds_session *session, - int extra) + struct ceph_mds_session *session) { struct ceph_msg *msg; struct ceph_mds_cap_release *head; int err = -ENOMEM; + int extra = mdsc->client->mount_args->cap_release_safety; - if (extra < 0) - extra = mdsc->client->mount_args->cap_release_safety; spin_lock(&session->s_cap_lock); @@ -2005,7 +2003,7 @@ static void handle_reply(struct ceph_mds_session *session, struct ceph_msg *msg) } mutex_unlock(&mdsc->mutex); - ceph_add_cap_releases(mdsc, req->r_session, -1); + ceph_add_cap_releases(mdsc, req->r_session); mutex_unlock(&session->s_mutex); /* kick calling process */ @@ -2715,7 +2713,7 @@ static void delayed_work(struct work_struct *work) send_renew_caps(mdsc, s); else ceph_con_keepalive(&s->s_con); - ceph_add_cap_releases(mdsc, s, -1); + ceph_add_cap_releases(mdsc, s); if (s->s_state == CEPH_MDS_SESSION_OPEN || s->s_state == CEPH_MDS_SESSION_HUNG) ceph_send_cap_releases(mdsc, s); diff --git a/trunk/fs/ceph/mds_client.h b/trunk/fs/ceph/mds_client.h index 952410c60d09..e389902db131 100644 --- a/trunk/fs/ceph/mds_client.h +++ b/trunk/fs/ceph/mds_client.h @@ -324,8 +324,7 @@ static inline void ceph_mdsc_put_request(struct ceph_mds_request *req) } extern int ceph_add_cap_releases(struct ceph_mds_client *mdsc, - struct ceph_mds_session *session, - int extra); + struct ceph_mds_session *session); extern void ceph_send_cap_releases(struct ceph_mds_client *mdsc, struct ceph_mds_session *session);