}
}
+bool MDLog::is_trim_slow() const {
+ return (segments.size() > (size_t)(max_segments * log_warn_factor));
+}
+
void MDLog::log_trim_upkeep(void) {
+ ceph_pthread_setname("mds-log-trim");
+
dout(10) << dendl;
std::unique_lock mds_lock(mds->mds_lock);
#include "rgw_perf_counters.h"
#include "services/svc_zone.h"
#include "common/dout.h"
+#include "rgw_url.h"
#include <chrono>
+ #include <fmt/format.h>
-#define dout_subsys ceph_subsys_rgw
+#define dout_subsys ceph_subsys_rgw_notification
namespace rgw::notify {
+
+static inline std::ostream& operator<<(std::ostream& out,
+ const event_entry_t& e) {
+ std::string host;
+ std::string user;
+ std::string password;
+ parse_url_authority(e.push_endpoint, host, user, password);
+ return out << "notification id: '" << e.event.configurationId
+ << "', topic: '" << e.arn_topic
+ << "', endpoint: '" << host
+ << "', endpoint_user: '" << user
+ << "', bucket_owner: '" << e.event.bucket_ownerIdentity
+ << "', bucket: '" << e.event.bucket_name
+ << "', object: '" << e.event.object_key
+ << "', event type: '" << e.event.eventName << "'";
+}
struct persistency_tracker {
ceph::coarse_real_time last_retry_time {ceph::coarse_real_clock::zero()};