aboutsummaryrefslogtreecommitdiff
path: root/fs/ceph/mds_client.c
diff options
context:
space:
mode:
authorSage Weil <sage@newdream.net>2009-11-10 16:02:23 -0800
committerSage Weil <sage@newdream.net>2009-11-10 16:03:53 -0800
commitcdac830313fa6bf2831693af80fefe4aaac11b7d (patch)
treecf5004237a084779ca84130c3303e42e9ea9fa35 /fs/ceph/mds_client.c
parenteed0ef2caf928327332da54d23579debe629d5bc (diff)
ceph: remove recon_gen logic
We don't get an explicit affirmative confirmation that our caps reconnect, nor do we necessarily want to pay that cost. So, take all this code out for now. Signed-off-by: Sage Weil <sage@newdream.net>
Diffstat (limited to 'fs/ceph/mds_client.c')
-rw-r--r--fs/ceph/mds_client.c15
1 files changed, 1 insertions, 14 deletions
diff --git a/fs/ceph/mds_client.c b/fs/ceph/mds_client.c
index 828417ae16f..aad10d90fee 100644
--- a/fs/ceph/mds_client.c
+++ b/fs/ceph/mds_client.c
@@ -329,7 +329,6 @@ static struct ceph_mds_session *register_session(struct ceph_mds_client *mdsc,
ceph_con_open(&s->s_con, ceph_mdsmap_get_addr(mdsc->mdsmap, mds));
spin_lock_init(&s->s_cap_lock);
- s->s_recon_gen = 0;
s->s_cap_gen = 0;
s->s_cap_ttl = 0;
s->s_renew_requested = 0;
@@ -736,25 +735,14 @@ static void remove_session_caps(struct ceph_mds_session *session)
static int wake_up_session_cb(struct inode *inode, struct ceph_cap *cap,
void *arg)
{
- struct ceph_mds_session *session = arg;
-
- spin_lock(&inode->i_lock);
- if (cap->recon_gen != session->s_recon_gen) {
- pr_err("failed reconnect %p %llx.%llx cap %p "
- "(recon_gen %d < session %d)\n", inode,
- ceph_vinop(inode), cap,
- cap->recon_gen, session->s_recon_gen);
- __ceph_remove_cap(cap, NULL);
- }
wake_up(&ceph_inode(inode)->i_cap_wq);
- spin_unlock(&inode->i_lock);
return 0;
}
static void wake_up_session_caps(struct ceph_mds_session *session)
{
dout("wake_up_session_caps %p mds%d\n", session, session->s_mds);
- iterate_session_caps(session, wake_up_session_cb, session);
+ iterate_session_caps(session, wake_up_session_cb, NULL);
}
/*
@@ -2052,7 +2040,6 @@ static void send_mds_reconnect(struct ceph_mds_client *mdsc, int mds)
session->s_state = CEPH_MDS_SESSION_RECONNECTING;
session->s_seq = 0;
- session->s_recon_gen++;
ceph_con_open(&session->s_con,
ceph_mdsmap_get_addr(mdsc->mdsmap, mds));