#include "common/ConfUtils.h"
#include "common/ceph_argparse.h"
#include "common/config_proxy.h"
+#include "common/strtol.h"
#include "global/global_context.h"
#include "global/global_init.h"
#include "common/ceph_argparse.h"
#include "global/global_init.h"
+#include "log/Log.h"
#include "mon/AuthMonitor.h"
#include "common/Formatter.h"
#include "common.h"
+#include "log/Log.h"
+
+#include <shared_mutex> // for std::shared_lock
#undef dout_prefix
#define dout_prefix *_dout << "ceph_dedup_daemon: " \
*/
#include "common.h"
+#include "log/Log.h"
+
+#include <boost/optional.hpp>
struct EstimateResult {
std::unique_ptr<CDC> cdc;
#include "common/errno.h"
#include "common/strtol.h"
#include "common/url_escape.h"
+#include "include/types.h" // for struct byte_u_t
#include "global/global_context.h"
#include "global/global_init.h"
#include <boost/algorithm/string.hpp>
#include <boost/scoped_ptr.hpp>
#include <boost/optional.hpp>
+#include <iomanip>
#include <fstream>
#include <stdlib.h>
#include "common/Formatter.h"
#include "common/errno.h"
#include "common/ceph_argparse.h"
+#include "common/perf_counters_collection.h"
#include "common/url_escape.h"
#include "global/global_init.h"
*
*/
+#include "DataScan.h"
+
#include "include/compat.h"
+#include "common/debug.h"
#include "common/errno.h"
#include "common/ceph_argparse.h"
#include <fstream>
#include "cls/cephfs/cls_cephfs_client.h"
#include "PgFiles.h"
-#include "DataScan.h"
#include "include/compat.h"
#define dout_context g_ceph_context
#include "MDSUtility.h"
#include "include/rados/librados.hpp"
+struct inode_backtrace_t;
class InodeStore;
class MDSTable;
*
*/
+#include "Dumper.h"
+
#include "include/compat.h"
#include "include/fs_types.h"
+#include "common/debug.h"
#include "common/entity_name.h"
#include "common/errno.h"
#include "common/safe_io.h"
#include "osdc/Journaler.h"
#include "mon/MonClient.h"
-#include "Dumper.h"
-
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#include "JournalFilter.h"
#include "common/ceph_argparse.h"
+#include "common/debug.h"
+#include "common/strtol.h" // for strict_strtoll()
#include "mds/events/ESession.h"
#include "mds/events/EUpdate.h"
* foundation. see file copying.
*/
+#include "JournalScanner.h"
+#include "common/debug.h"
#include "include/rados/librados.hpp"
#include "mds/JournalPointer.h"
#include "mds/events/ESubtreeMap.h"
#include "mds/PurgeQueue.h"
-#include "JournalScanner.h"
-
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#include <sstream>
#include "common/ceph_argparse.h"
+#include "common/debug.h"
#include "common/errno.h"
#include "osdc/Journaler.h"
#include "mds/mdstypes.h"
#include "MDSUtility.h"
#include "mon/MonClient.h"
+#include "common/debug.h"
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#include "include/types.h"
#include "common/Formatter.h"
#include "common/ceph_argparse.h"
+#include "common/debug.h"
#include "common/errno.h"
#include "osdc/Journaler.h"
#include "mds/mdstypes.h"
*
*/
+#include "common/debug.h"
#include "common/errno.h"
#include "osdc/Striper.h"
* Foundation. See file COPYING.
*
*/
+
+#include "Resetter.h"
+
#include <memory>
+#include "common/debug.h"
#include "common/errno.h"
#include "osdc/Journaler.h"
#include "mds/JournalPointer.h"
#include "mon/MonClient.h"
#include "mds/events/EResetJournal.h"
-#include "Resetter.h"
-
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_mds
#include "RoleSelector.h"
+#include "common/strtol.h"
int MDSRoleSelector::parse_rank(
const FSMap &fsmap,
#include "common/ceph_argparse.h"
+#include "common/debug.h"
#include "common/errno.h"
#include "mds/SessionMap.h"
#include "common/errno.h"
#include "common/WorkQueue.h"
#include "common/perf_counters.h"
+#include "common/perf_counters_collection.h"
#include "common/perf_counters_key.h"
#include "include/stringify.h"
#include "msg/Messenger.h"
#include "common/Timer.h"
#include "common/WorkQueue.h"
#include "common/perf_counters.h"
+#include "common/perf_counters_collection.h"
#include "common/perf_counters_key.h"
#include "include/types.h"
#include "mon/MonClient.h"
#include "common/debug.h"
#include "common/errno.h"
#include "common/perf_counters.h"
+#include "common/perf_counters_collection.h"
#include "common/perf_counters_key.h"
+#include "include/stringify.h"
#include "FSMirror.h"
#include "PeerReplayer.h"
#include "Utils.h"
#include "ServiceDaemon.h"
#include "Types.h"
+#include <boost/optional.hpp>
+
namespace cephfs {
namespace mirror {
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
+#include "ServiceDaemon.h"
#include "common/debug.h"
#include "common/errno.h"
#include "common/Timer.h"
+#include "include/Context.h"
#include "include/stringify.h"
-#include "ServiceDaemon.h"
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_cephfs_mirror
#include "include/cephfs/libcephfs.h"
#include "mds/mdstypes.h"
+#include <boost/variant/variant.hpp>
+
namespace cephfs {
namespace mirror {
#include "common/Preforker.h"
#include "global/global_init.h"
#include "global/signal_handler.h"
+#include "log/Log.h"
#include "mon/MonClient.h"
#include "msg/Messenger.h"
#include "Mirror.h"
#include "common/errno.h"
#include "common/config.h"
#include "common/Formatter.h"
+#include "common/strtol.h" // for strict_strtol()
#include "common/ceph_argparse.h"
#include "include/stringify.h"
#include "common/debug.h"
#include "SimplePolicy.h"
+#include <shared_mutex> // for std::shared_lock
+
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_immutable_obj_cache
#undef dout_prefix
#include <iostream>
+#include "common/config_proxy.h" // for class ConfigProxy
#include "common/errno.h"
#include "common/url_escape.h"
#include "common/pretty_binary.h"
+#include "global/global_context.h" // for g_conf()
#include "include/buffer.h"
-#include "kv/KeyValueDB.h"
+#include "include/types.h" // for struct byte_u_t
#include "kv/KeyValueHistogram.h"
+#ifdef WITH_BLUESTORE
+#include "os/bluestore/BlueStore.h"
+#endif
+
using namespace std;
StoreTool::StoreTool(const string& type,
#include "acconfig.h"
#include "include/buffer_fwd.h"
+#include "kv/KeyValueDB.h"
#ifdef WITH_BLUESTORE
#include "os/bluestore/BlueStore.h"
#endif
#include <string>
#include "common/ceph_argparse.h"
+#include "common/Clock.h" // for ceph_clock_now()
#include "common/errno.h"
+#include "common/strtol.h"
+#include "global/global_context.h"
#include "global/global_init.h"
#include "include/str_list.h"
#include "mon/MonMap.h"
#include "common/ceph_argparse.h"
#include "common/errno.h"
#include "common/safe_io.h"
+#include "common/strtol.h" // for strict_strtoll()
+#include "crush/CrushWrapper.h"
+#include "include/unordered_map.h"
#include "include/random.h"
#include "mon/health_check.h"
#include <time.h>
*/
#include "include/rados/librados.hpp"
+#include "common/debug.h"
#include "common/errno.h"
#include "PoolDump.h"
*
*/
-
-#include "common/errno.h"
-
-#include "osd/PGLog.h"
#include "RadosImport.h"
+#include "osd/PGLog.h"
+#include "common/debug.h"
+#include "common/errno.h"
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rados
#include "common/errno.h"
#include "common/Formatter.h"
#include "common/obj_bencher.h"
+#include "common/strtol.h" // for strict_strtoll()
#include "common/TextTable.h"
#include "include/stringify.h"
#include "mds/inode_backtrace.h"
#include "objclass/objclass.h"
#include "cls/refcount/cls_refcount_ops.h"
+#include <boost/optional.hpp>
+
+#include <iomanip>
+
using namespace std::chrono_literals;
using namespace librados;
using ceph::util::generate_random_number;
#include "common/config.h"
#include "common/errno.h"
#include "common/escape.h"
+#include "common/Formatter.h"
#include "common/safe_io.h"
#include "global/global_context.h"
#include <fstream>
#include "common/debug.h"
#include "common/errno.h"
#include "common/Formatter.h"
+#include "common/safe_io.h" // for safe_read()
#include "common/TextTable.h"
#include "common/Throttle.h"
#include "global/global_context.h"
#include <unistd.h>
#include <sys/time.h>
#include <sys/types.h>
+#include <iomanip>
#include <iostream>
#include <vector>
#include <boost/algorithm/string.hpp>
#include "tools/rbd/Shell.h"
#include "tools/rbd/Utils.h"
#include "include/stringify.h"
+#include "include/types.h" // for struct byte_u_t
#include "common/errno.h"
#include "common/Formatter.h"
#include <iostream>
#include <vector>
#include "common/ceph_mutex.h"
+#include "common/Clock.h" // for ceph_clock_now()
#include "include/Context.h"
#include "common/AsyncOpTracker.h"
#include "cls/rbd/cls_rbd_types.h"
#include "tools/rbd_mirror/image_replayer/journal/Replayer.h"
#include "tools/rbd_mirror/image_replayer/journal/StateBuilder.h"
#include <map>
+#include <shared_mutex> // for std::shared_lock
+
+#include <boost/optional/optional_io.hpp>
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#include "tools/rbd_mirror/image_sync/SyncPointPruneRequest.h"
#include "tools/rbd_mirror/image_sync/Types.h"
+#include <shared_mutex> // for std::shared_lock
+
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#include "librbd/journal/Policy.h"
#include "tools/rbd_mirror/image_deleter/Types.h"
+#include <shared_mutex> // for std::shared_lock
+
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
+#include "Policy.h"
+
#include "common/debug.h"
+#include "common/Clock.h" // for ceph_clock_now()
#include "common/errno.h"
#include "librbd/Utils.h"
-#include "Policy.h"
+
+#include <shared_mutex> // for std::shared_lock
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#define CEPH_RBD_MIRROR_IMAGE_MAP_POLICY_H
#include <map>
+#include <set>
+#include <string>
#include <tuple>
#include <boost/optional.hpp>
#include "cls/rbd/cls_rbd_types.h"
+#include "common/ceph_mutex.h"
#include "include/rados/librados.hpp"
#include "tools/rbd_mirror/image_map/StateTransition.h"
#include "tools/rbd_mirror/image_map/Types.h"
#include "tools/rbd_mirror/image_sync/Utils.h"
#include <boost/algorithm/string/predicate.hpp>
+#include <shared_mutex> // for std::shared_lock
+
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#include "librbd/exclusive_lock/Policy.h"
#include "librbd/journal/Policy.h"
#include "librbd/mirror/GetInfoRequest.h"
+
+#include <shared_mutex> // for std::shared_lock
#include <type_traits>
#define dout_context g_ceph_context
#include "librbd/journal/Types.h"
#include <boost/variant.hpp>
+#include <shared_mutex> // for std::shared_lock
+
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#include "tools/rbd_mirror/ProgressContext.h"
#include "tools/rbd_mirror/image_replayer/journal/StateBuilder.h"
+#include <shared_mutex> // for std::shared_lock
+
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#include "common/debug.h"
#include "common/errno.h"
#include "common/perf_counters.h"
+#include "common/perf_counters_collection.h"
#include "common/perf_counters_key.h"
#include "common/Timer.h"
#include "librbd/Journal.h"
#include "tools/rbd_mirror/image_replayer/journal/ReplayStatusFormatter.h"
#include "tools/rbd_mirror/image_replayer/journal/StateBuilder.h"
+#include <shared_mutex> // for std::shared_lock
+
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
#include "tools/rbd_mirror/image_replayer/snapshot/Utils.h"
#include <boost/algorithm/string/predicate.hpp>
+#include <shared_mutex> // for std::shared_lock
+
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#undef dout_prefix
// vim: ts=8 sw=2 smarttab
#include "Replayer.h"
+#include "common/Clock.h" // for ceph_clock_now()
#include "common/debug.h"
#include "common/errno.h"
#include "common/perf_counters.h"
+#include "common/perf_counters_collection.h"
#include "common/perf_counters_key.h"
#include "include/stringify.h"
#include "common/Timer.h"
#include "tools/rbd_mirror/image_replayer/snapshot/ApplyImageStateRequest.h"
#include "tools/rbd_mirror/image_replayer/snapshot/StateBuilder.h"
#include "tools/rbd_mirror/image_replayer/snapshot/Utils.h"
+
#include <set>
+#include <shared_mutex> // for std::shared_lock
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#include "librbd/ImageState.h"
#include "librbd/Operations.h"
#include "librbd/Utils.h"
+
#include <set>
+#include <shared_mutex> // for std::shared_lock
#define dout_context g_ceph_context
#define dout_subsys ceph_subsys_rbd_mirror
#include "common/debug.h"
#include "common/errno.h"
#include "common/perf_counters.h"
+#include "common/perf_counters_collection.h"
#include "global/global_init.h"
#include "global/signal_handler.h"
#include "Mirror.h"
#include "common/TextTable.h"
#include "common/ceph_argparse.h"
#include "common/config.h"
-#include "common/dout.h"
+#include "common/debug.h"
#include "common/errno.h"
#include "common/event_socket.h"
#include "common/module.h"