summaryrefslogtreecommitdiffstats
path: root/fs/ceph/caps.c
diff options
context:
space:
mode:
authorYan, Zheng <zyan@redhat.com>2019-01-01 03:28:33 -0500
committerIlya Dryomov <idryomov@gmail.com>2019-03-05 12:55:16 -0500
commit81c5a1487e52a316e5e7d79e9911376648a79e85 (patch)
treeb716d8a8ec3d7b012197776fafd4c3f68c31c33c /fs/ceph/caps.c
parent84bf39509bea5b9f936281c4c660e75099fcd15f (diff)
ceph: split large reconnect into multiple messages
Signed-off-by: "Yan, Zheng" <zyan@redhat.com> Signed-off-by: Ilya Dryomov <idryomov@gmail.com>
Diffstat (limited to 'fs/ceph/caps.c')
-rw-r--r--fs/ceph/caps.c6
1 files changed, 6 insertions, 0 deletions
diff --git a/fs/ceph/caps.c b/fs/ceph/caps.c
index bba28a5034ba..0eaf1b48c431 100644
--- a/fs/ceph/caps.c
+++ b/fs/ceph/caps.c
@@ -2393,6 +2393,12 @@ void ceph_early_kick_flushing_caps(struct ceph_mds_client *mdsc,
2393 if ((cap->issued & ci->i_flushing_caps) != 2393 if ((cap->issued & ci->i_flushing_caps) !=
2394 ci->i_flushing_caps) { 2394 ci->i_flushing_caps) {
2395 ci->i_ceph_flags &= ~CEPH_I_KICK_FLUSH; 2395 ci->i_ceph_flags &= ~CEPH_I_KICK_FLUSH;
2396 /* encode_caps_cb() also will reset these sequence
2397 * numbers. make sure sequence numbers in cap flush
2398 * message match later reconnect message */
2399 cap->seq = 0;
2400 cap->issue_seq = 0;
2401 cap->mseq = 0;
2396 __kick_flushing_caps(mdsc, session, ci, 2402 __kick_flushing_caps(mdsc, session, ci,
2397 oldest_flush_tid); 2403 oldest_flush_tid);
2398 } else { 2404 } else {