diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-05-23 16:45:17 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-05-23 16:45:44 +0000 |
commit | 17d6a993fc17d533460c5f40f3908c708e057c18 (patch) | |
tree | 1a3bd93e0ecd74fa02f93a528fe2f87e5314c4b5 /src/mds/Server.h | |
parent | Releasing progress-linux version 18.2.2-0progress7.99u1. (diff) | |
download | ceph-17d6a993fc17d533460c5f40f3908c708e057c18.tar.xz ceph-17d6a993fc17d533460c5f40f3908c708e057c18.zip |
Merging upstream version 18.2.3.
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/mds/Server.h')
-rw-r--r-- | src/mds/Server.h | 15 |
1 files changed, 15 insertions, 0 deletions
diff --git a/src/mds/Server.h b/src/mds/Server.h index 81a5933ba..47f86518b 100644 --- a/src/mds/Server.h +++ b/src/mds/Server.h @@ -158,7 +158,9 @@ public: void force_clients_readonly(); // -- requests -- + void trim_completed_request_list(ceph_tid_t tid, Session *session); void handle_client_request(const cref_t<MClientRequest> &m); + void handle_client_reply(const cref_t<MClientReply> &m); void journal_and_reply(MDRequestRef& mdr, CInode *tracei, CDentry *tracedn, LogEvent *le, MDSLogContextBase *fin); @@ -235,6 +237,9 @@ public: void handle_client_removexattr(MDRequestRef& mdr); void handle_client_fsync(MDRequestRef& mdr); + + // check layout + bool is_valid_layout(file_layout_t *layout); // open void handle_client_open(MDRequestRef& mdr); @@ -328,6 +333,13 @@ public: std::set<client_t> client_reclaim_gather; + std::set<client_t> get_laggy_clients() const { + return laggy_clients; + } + void clear_laggy_clients() { + laggy_clients.clear(); + } + const bufferlist& get_snap_trace(Session *session, SnapRealm *realm) const; const bufferlist& get_snap_trace(client_t client, SnapRealm *realm) const; @@ -553,6 +565,9 @@ private: size_t alternate_name_max = g_conf().get_val<Option::size_t>("mds_alternate_name_max"); size_t fscrypt_last_block_max_size = g_conf().get_val<Option::size_t>("mds_fscrypt_last_block_max_size"); + + // record laggy clients due to laggy OSDs + std::set<client_t> laggy_clients; }; static inline constexpr auto operator|(Server::RecallFlags a, Server::RecallFlags b) { |