// vim: ts=8 sw=2 smarttab
#include "dbstore.h"
+#include "log/Log.h"
using namespace std;
#include "common/ceph_context.h"
#include "common/dbstore.h"
+#include "log/Log.h"
#include "sqlite/sqliteDB.h"
using namespace rgw::store;
#include <dbstore.h>
#include <sqliteDB.h>
#include "rgw_common.h"
+#include "common/Clock.h" // for ceph_clock_now()
using namespace std;
using DB = rgw::store::DB;
#include <unistd.h>
#include "rgw_multi.h"
#include "include/scope_guard.h"
+#include "common/Clock.h" // for ceph_clock_now()
#include "common/errno.h"
#define dout_subsys ceph_subsys_rgw
#include "common/async/yield_context.h"
#include "common/random_string.h"
+#include "common/strtol.h" // for ceph::parse()
#include "cls/fifo/cls_fifo_types.h"
#include "cls/fifo/cls_fifo_ops.h"
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab ft=cpp
+#include "rgw_data_sync.h"
+
#include "common/ceph_json.h"
#include "common/RefCountedObj.h"
#include "common/WorkQueue.h"
#include "rgw_common.h"
#include "rgw_zone.h"
#include "rgw_sync.h"
-#include "rgw_data_sync.h"
#include "rgw_rest_conn.h"
#include "rgw_cr_rados.h"
#include "rgw_cr_rest.h"
#include "include/common_fwd.h"
#include "include/random.h"
+#include "include/timegm.h"
#include <boost/asio/yield.hpp>
+#include <shared_mutex> // for std::shared_lock
#include <string_view>
#define dout_subsys ceph_subsys_rgw
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab ft=cpp
+#include <shared_mutex> // for std::shared_lock
#include <vector>
#include "common/async/yield_context.h"
// vim: ts=8 sw=2 smarttab ft=cpp
#include "rgw_pubsub_push.h"
+#include <shared_mutex> // for std::shared_lock
#include <string>
#include <sstream>
#include <algorithm>
#include "rgw_sal_rados.h"
#include "cls/rgw/cls_rgw_client.h"
#include "cls/lock/cls_lock_client.h"
+#include "common/Clock.h" // for ceph_clock_now()
#include "common/errno.h"
#include "common/ceph_json.h"
#include "driver/rados/rgw_bucket.h"
#include "driver/rados/rgw_sal_rados.h"
+#include <iomanip>
+
#define dout_context g_ceph_context
static rgw::sal::Driver* driver = NULL;
#include <thread>
#include <atomic>
#include <mutex>
+#include <shared_mutex> // for std::shared_lock
#include <boost/lockfree/queue.hpp>
#include <boost/functional/hash.hpp>
+#include "common/Clock.h" // for ceph_clock_now()
#include "common/dout.h"
#include <openssl/ssl.h>
#include <atomic>
#include <ctime>
+#include <iomanip>
#include <list>
#include <memory>
#include "common/armor.h"
#include "common/utf8.h"
#include "common/split.h"
+#include "include/timegm.h"
#include "rgw_rest_s3.h"
#include "rgw_auth_s3.h"
#include "rgw_common.h"
#pragma once
+#include <shared_mutex> // for std::shared_lock
#include <string>
#include <map>
#include <unordered_map>
#include "common/convenience.h"
#include "common/strtol.h"
#include "include/str_list.h"
+#include "include/timegm.h"
#include "rgw_crypt_sanitize.h"
#include "rgw_bucket_sync.h"
#include "rgw_sync_policy.h"
#include "include/Context.h"
#include "common/ceph_json.h"
+#include "common/Clock.h" // for ceph_clock_now()
#include "rgw_coroutine.h"
#include "rgw_asio_thread.h"
#include <boost/asio/yield.hpp>
+#include <shared_mutex> // for std::shared_lock
+
#define dout_subsys ceph_subsys_rgw
#define dout_context g_ceph_context
#include "common/config.h"
#include "rgw_dmclock.h"
+#if defined(WITH_SEASTAR) && !defined(WITH_ALIEN)
+#include "crimson/common/perf_counters_collection.h"
+#else
+#include "common/perf_counters_collection.h"
+#endif
+
namespace queue_counters {
enum {
#include "rgw_dmclock_sync_scheduler.h"
#include "rgw_dmclock_scheduler_ctx.h"
+#if defined(WITH_SEASTAR) && !defined(WITH_ALIEN)
+#include "crimson/common/perf_counters_collection.h"
+#else
+#include "common/perf_counters_collection.h"
+#endif
+
namespace rgw::dmclock {
SyncScheduler::~SyncScheduler()
#include <boost/algorithm/string.hpp>
#include "common/ceph_json.h"
+#include "common/strtol.h"
#include "rgw_common.h"
#include "rgw_es_query.h"
#include <unordered_map>
#include <string>
#include <vector>
+#include <shared_mutex> // for std::shared_lock
#include <thread>
#include <atomic>
#include <mutex>
#include <boost/algorithm/string.hpp>
#include <boost/functional/hash.hpp>
#include <boost/lockfree/queue.hpp>
+#include "common/Clock.h" // for ceph_clock_now()
#include "common/dout.h"
+#include "include/utime.h"
#define dout_subsys ceph_subsys_rgw_notification
#include "common/errno.h"
#include "common/ceph_json.h"
+#include "include/timegm.h"
#include "include/types.h"
#include "include/str_list.h"
#include <vector>
#include "common/async/yield_context.h"
+#include "include/types.h" // for epoch_t
#include "rgw_realm_reloader.h"
#include "rgw_sal_fwd.h"
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab ft=cpp
+#include "rgw_policy_s3.h"
+
#include <errno.h>
#include "common/ceph_json.h"
-#include "rgw_policy_s3.h"
+#include "common/Clock.h" // for ceph_clock_now()
+#include "include/timegm.h"
#include "rgw_common.h"
#include "rgw_crypt_sanitize.h"
#include "rgw_cksum.h"
#include "include/function2.hpp"
#include "include/utime.h"
+#include "common/Clock.h" // for ceph_clock_now()
#include "common/lru_map.h"
#include "common/RefCountedObj.h"
#include "common/Thread.h"
#pragma once
#include <chrono>
+#include <shared_mutex> // for std::shared_lock
#include <thread>
#include <condition_variable>
#include "rgw_common.h"
#include <vector>
#include <string>
#include <array>
+#include <iomanip>
#include <string_view>
#include <sstream>
#include <memory>
#include "common/Clock.h"
#include "include/random.h"
+#include "include/timegm.h"
#include "rgw_client_io.h"
#include "rgw_http_client.h"
#include <errno.h>
#include "common/errno.h"
+#include "common/safe_io.h" // for safe_read()
#include "rgw_tools.h"
#include "rgw_zone.h"
+#include <shared_mutex> // for std::shared_lock
+
#define dout_subsys ceph_subsys_rgw
using namespace std;
#include "svc_sys_obj_core.h"
+#include <shared_mutex> // for std::shared_lock
+
class RGWSI_Notify;
class RGWSI_SysObj_Cache_CB;