From 19fcec84d8d7d21e796c7624e521b60d28ee21ed Mon Sep 17 00:00:00 2001 From: Daniel Baumann Date: Sun, 7 Apr 2024 20:45:59 +0200 Subject: Adding upstream version 16.2.11+ds. Signed-off-by: Daniel Baumann --- src/mds/RecoveryQueue.h | 56 +++++++++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 56 insertions(+) create mode 100644 src/mds/RecoveryQueue.h (limited to 'src/mds/RecoveryQueue.h') diff --git a/src/mds/RecoveryQueue.h b/src/mds/RecoveryQueue.h new file mode 100644 index 000000000..699be08c3 --- /dev/null +++ b/src/mds/RecoveryQueue.h @@ -0,0 +1,56 @@ +// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*- +// vim: ts=8 sw=2 smarttab +/* + * Ceph - scalable distributed file system + * + * Copyright (C) 2004-2006 Sage Weil + * + * This is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License version 2.1, as published by the Free Software + * Foundation. See file COPYING. + * + */ + +//class C_MDC_Recover; +// +#ifndef RECOVERY_QUEUE_H +#define RECOVERY_QUEUE_H + +#include + +#include "include/common_fwd.h" +#include "osdc/Filer.h" + +class CInode; +class MDSRank; + +class RecoveryQueue { +public: + explicit RecoveryQueue(MDSRank *mds_); + + void enqueue(CInode *in); + void advance(); + void prioritize(CInode *in); ///< do this inode now/soon + + void set_logger(PerfCounters *p) {logger=p;} + +private: + friend class C_MDC_Recover; + + void _start(CInode *in); ///< start recovering this file + void _recovered(CInode *in, int r, uint64_t size, utime_t mtime); + + size_t file_recover_queue_size = 0; + size_t file_recover_queue_front_size = 0; + + elist file_recover_queue; ///< the queue + elist file_recover_queue_front; ///< elevated priority items + std::map file_recovering; // inode -> need_restart + + MDSRank *mds; + PerfCounters *logger = nullptr; + Filer filer; +}; + +#endif // RECOVERY_QUEUE_H -- cgit v1.2.3