aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--fs/ceph/mds_client.c6
1 files changed, 1 insertions, 5 deletions
diff --git a/fs/ceph/mds_client.c b/fs/ceph/mds_client.c
index bec8a7aeb300..a2600101ec22 100644
--- a/fs/ceph/mds_client.c
+++ b/fs/ceph/mds_client.c
@@ -1899,7 +1899,6 @@ static void handle_forward(struct ceph_mds_client *mdsc,
1899 u64 tid = le64_to_cpu(msg->hdr.tid); 1899 u64 tid = le64_to_cpu(msg->hdr.tid);
1900 u32 next_mds; 1900 u32 next_mds;
1901 u32 fwd_seq; 1901 u32 fwd_seq;
1902 u8 must_resend;
1903 int err = -EINVAL; 1902 int err = -EINVAL;
1904 void *p = msg->front.iov_base; 1903 void *p = msg->front.iov_base;
1905 void *end = p + msg->front.iov_len; 1904 void *end = p + msg->front.iov_len;
@@ -1907,14 +1906,11 @@ static void handle_forward(struct ceph_mds_client *mdsc,
1907 ceph_decode_need(&p, end, 2*sizeof(u32), bad); 1906 ceph_decode_need(&p, end, 2*sizeof(u32), bad);
1908 next_mds = ceph_decode_32(&p); 1907 next_mds = ceph_decode_32(&p);
1909 fwd_seq = ceph_decode_32(&p); 1908 fwd_seq = ceph_decode_32(&p);
1910 must_resend = ceph_decode_8(&p);
1911
1912 WARN_ON(must_resend); /* shouldn't happen. */
1913 1909
1914 mutex_lock(&mdsc->mutex); 1910 mutex_lock(&mdsc->mutex);
1915 req = __lookup_request(mdsc, tid); 1911 req = __lookup_request(mdsc, tid);
1916 if (!req) { 1912 if (!req) {
1917 dout("forward %llu dne\n", tid); 1913 dout("forward %llu to mds%d - req dne\n", tid, next_mds);
1918 goto out; /* dup reply? */ 1914 goto out; /* dup reply? */
1919 } 1915 }
1920 1916