diff options
author | Yan, Zheng <zyan@redhat.com> | 2019-01-01 03:28:33 -0500 |
---|---|---|
committer | Ilya Dryomov <idryomov@gmail.com> | 2019-03-05 12:55:16 -0500 |
commit | 81c5a1487e52a316e5e7d79e9911376648a79e85 (patch) | |
tree | b716d8a8ec3d7b012197776fafd4c3f68c31c33c /fs/ceph/caps.c | |
parent | 84bf39509bea5b9f936281c4c660e75099fcd15f (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.c | 6 |
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 { |