kclient: rename lookup_mds_session get_mds_session

Since it bumps the ref count.

diff --git a/src/kernel/caps.c b/src/kernel/caps.c
index 29ae6653aad549878e91b5fa2175e469a456e08b..747600670f2037a45291f606f485091c7adae42a 100644 (file)
--- a/src/kernel/caps.c
+++ b/src/kernel/caps.c
@@ -648,7 +648,7 @@ retry:
                if (!session) {
                        spin_unlock(&inode->i_lock);
                        mutex_lock(&mdsc->mutex);
-                       session = __ceph_lookup_mds_session(mdsc, mds);
+                       session = __ceph_get_mds_session(mdsc, mds);
                        mutex_unlock(&mdsc->mutex);
                        if (session) {
                                dout(10, "inverting session/ino locks on %p\n",
@@ -1610,7 +1610,7 @@ void ceph_handle_caps(struct ceph_mds_client *mdsc,
 
        /* find session */
        mutex_lock(&mdsc->mutex);
-       session = __ceph_lookup_mds_session(mdsc, mds);
+       session = __ceph_get_mds_session(mdsc, mds);
        if (session)
                down_write(&mdsc->snap_rwsem);
        mutex_unlock(&mdsc->mutex);

diff --git a/src/kernel/mds_client.c b/src/kernel/mds_client.c
index cc39d30fa384d09a7cc545f3811987966c5b64a2..24b65821b9a8e63caa8a71da326c27885cdfb753 100644 (file)
--- a/src/kernel/mds_client.c
+++ b/src/kernel/mds_client.c
@@ -281,7 +281,7 @@ static const char *session_state_name(int s)
 /*
  * called under mdsc->mutex
  */
-struct ceph_mds_session *__ceph_lookup_mds_session(struct ceph_mds_client *mdsc,
+struct ceph_mds_session *__ceph_get_mds_session(struct ceph_mds_client *mdsc,
                                                int mds)
 {
        struct ceph_mds_session *session;
@@ -289,7 +289,7 @@ struct ceph_mds_session *__ceph_lookup_mds_session(struct ceph_mds_client *mdsc,
        if (mds >= mdsc->max_sessions || mdsc->sessions[mds] == NULL)
                return NULL;
        session = mdsc->sessions[mds];
-       dout(30, "lookup_mds_session %p %d -> %d\n", session,
+       dout(30, "get_mds_session %p %d -> %d\n", session,
             atomic_read(&session->s_ref), atomic_read(&session->s_ref)+1);
        atomic_inc(&session->s_ref);
        return session;
@@ -951,7 +951,7 @@ void ceph_mdsc_handle_session(struct ceph_mds_client *mdsc,
        seq = le64_to_cpu(h->seq);
 
        mutex_lock(&mdsc->mutex);
-       session = __ceph_lookup_mds_session(mdsc, mds);
+       session = __ceph_get_mds_session(mdsc, mds);
        if (session && mdsc->mdsmap)
                /* FIXME: this ttl calculation is generous */
                session->s_ttl = jiffies + HZ*mdsc->mdsmap->m_session_autoclose;
@@ -1173,7 +1173,7 @@ retry:
        }
 
        /* get session */
-       session = __ceph_lookup_mds_session(mdsc, mds);
+       session = __ceph_get_mds_session(mdsc, mds);
        if (!session)
                session = register_session(mdsc, mds);
        dout(30, "do_request mds%d session %p state %s\n", mds, session,
@@ -1314,7 +1314,7 @@ void ceph_mdsc_handle_reply(struct ceph_mds_client *mdsc, struct ceph_msg *msg)
 
        if (req->r_session && req->r_session->s_mds != mds) {
                ceph_put_mds_session(req->r_session);
-               req->r_session = __ceph_lookup_mds_session(mdsc, mds);
+               req->r_session = __ceph_get_mds_session(mdsc, mds);
        }
        if (req->r_session == NULL) {
                derr(1, "got reply on %llu, but no session for mds%d\n",
@@ -1433,8 +1433,8 @@ void ceph_mdsc_handle_forward(struct ceph_mds_client *mdsc,
                     from_mds);
                req->r_num_fwd = fwd_seq;
                put_request_sessions(req);
-               req->r_session = __ceph_lookup_mds_session(mdsc, next_mds);
-               req->r_fwd_session = __ceph_lookup_mds_session(mdsc, from_mds);
+               req->r_session = __ceph_get_mds_session(mdsc, next_mds);
+               req->r_fwd_session = __ceph_get_mds_session(mdsc, from_mds);
        } else {
                /* no, resend. */
                /* forward race not possible; mds would drop */
@@ -1507,7 +1507,7 @@ static void send_mds_reconnect(struct ceph_mds_client *mdsc, int mds)
        dout(1, "reconnect to recovering mds%d\n", mds);
 
        /* find session */
-       session = __ceph_lookup_mds_session(mdsc, mds);
+       session = __ceph_get_mds_session(mdsc, mds);
        down_read(&mdsc->snap_rwsem);
        mutex_unlock(&mdsc->mutex);    /* drop lock for duration */
 
@@ -1791,7 +1791,7 @@ void ceph_mdsc_handle_lease(struct ceph_mds_client *mdsc, struct ceph_msg *msg)
 
        /* find session */
        mutex_lock(&mdsc->mutex);
-       session = __ceph_lookup_mds_session(mdsc, mds);
+       session = __ceph_get_mds_session(mdsc, mds);
        mutex_unlock(&mdsc->mutex);
        if (!session) {
                derr(0, "WTF, got lease but no session for mds%d\n", mds);
@@ -1945,7 +1945,7 @@ static void delayed_work(struct work_struct *work)
                mdsc->last_renew_caps = jiffies;
 
        for (i = 0; i < mdsc->max_sessions; i++) {
-               struct ceph_mds_session *s = __ceph_lookup_mds_session(mdsc, i);
+               struct ceph_mds_session *s = __ceph_get_mds_session(mdsc, i);
                if (s == NULL)
                        continue;
                if (s->s_state == CEPH_MDS_SESSION_CLOSING) {
@@ -2016,7 +2016,7 @@ static void drop_leases(struct ceph_mds_client *mdsc)
        dout(10, "drop_leases\n");
        mutex_lock(&mdsc->mutex);
        for (i = 0; i < mdsc->max_sessions; i++) {
-               struct ceph_mds_session *s = __ceph_lookup_mds_session(mdsc, i);
+               struct ceph_mds_session *s = __ceph_get_mds_session(mdsc, i);
                if (!s)
                        continue;
                mutex_unlock(&mdsc->mutex);
@@ -2082,7 +2082,7 @@ void ceph_mdsc_close_sessions(struct ceph_mds_client *mdsc)
                dout(10, "closing sessions\n");
                n = 0;
                for (i = 0; i < mdsc->max_sessions; i++) {
-                       session = __ceph_lookup_mds_session(mdsc, i);
+                       session = __ceph_get_mds_session(mdsc, i);
                        if (!session)
                                continue;
                        mutex_unlock(&mdsc->mutex);

diff --git a/src/kernel/mds_client.h b/src/kernel/mds_client.h
index 0f0a6445521071f723225f52ff48b31a350214ff..02f0710e09fcbcdee1d5b2226d58bc76ba6ffb0d 100644 (file)
--- a/src/kernel/mds_client.h
+++ b/src/kernel/mds_client.h
@@ -212,8 +212,7 @@ struct ceph_mds_client {
 
 extern const char *ceph_mds_op_name(int op);
 
-extern struct ceph_mds_session *
-__ceph_lookup_mds_session(struct ceph_mds_client *, int mds);
+extern struct ceph_mds_session *__ceph_get_mds_session(struct ceph_mds_client *, int mds);
 
 inline static struct ceph_mds_session *
 ceph_get_mds_session(struct ceph_mds_session *s)

diff --git a/src/kernel/snap.c b/src/kernel/snap.c
index 7f22edd78961e95e0eac321b6ebc415d4ad9c2e2..13cf1b8b91ef0d9f7378f6f92c0ca514dc986453 100644 (file)
--- a/src/kernel/snap.c
+++ b/src/kernel/snap.c
@@ -643,7 +643,7 @@ void ceph_handle_snap(struct ceph_mds_client *mdsc,
 
        /* find session */
        mutex_lock(&mdsc->mutex);
-       session = __ceph_lookup_mds_session(mdsc, mds);
+       session = __ceph_get_mds_session(mdsc, mds);
        if (session)
                down_write(&mdsc->snap_rwsem);
        mutex_unlock(&mdsc->mutex);