__func__, key.name.c_str(), key.instance.c_str());
continue;
}
-
+
// filter out noncurrent versions, delete markers, and initial marker
if (!op.list_versions &&
(!entry.is_visible() || op.start_obj.name == key.name)) {
cls_rgw_gc_list_ret op_ret;
#define GC_LIST_ENTRIES_DEFAULT 128
- int ret = gc_list_entries(hctx, op.marker, (op.max ? op.max : GC_LIST_ENTRIES_DEFAULT), op.expired_only,
+ int ret = gc_list_entries(hctx, op.marker, (op.max ? op.max : GC_LIST_ENTRIES_DEFAULT), op.expired_only,
op_ret.entries, &op_ret.truncated, op_ret.next_marker);
if (ret < 0)
return ret;
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
-#ifndef CEPH_CLS_RGW_CLIENT_H
-#define CEPH_CLS_RGW_CLIENT_H
+#pragma once
#include "include/str_list.h"
#include "include/rados/librados.hpp"
int cls_rgw_get_bucket_resharding(librados::IoCtx& io_ctx, const std::string& oid,
cls_rgw_bucket_instance_entry *entry);
#endif
-
-#endif
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
-#ifndef CEPH_CLS_RGW_CONST_H
-#define CEPH_CLS_RGW_CONST_H
+#pragma once
#define RGW_CLASS "rgw"
#define RGW_CLEAR_BUCKET_RESHARDING "clear_bucket_resharding"
#define RGW_GUARD_BUCKET_RESHARDING "guard_bucket_resharding"
#define RGW_GET_BUCKET_RESHARDING "get_bucket_resharding"
-
-#endif
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
-#ifndef CEPH_CLS_RGW_OPS_H
-#define CEPH_CLS_RGW_OPS_H
+#pragma once
#include "cls/rgw/cls_rgw_types.h"
void dump(ceph::Formatter *f) const;
};
WRITE_CLASS_ENCODER(cls_rgw_get_bucket_resharding_ret)
-
-#endif /* CEPH_CLS_RGW_OPS_H */
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
-#ifndef CEPH_CLS_RGW_TYPES_H
-#define CEPH_CLS_RGW_TYPES_H
+#pragma once
#include <boost/container/flat_map.hpp>
#include "common/ceph_time.h"
void get_key(std::string *key) const;
};
WRITE_CLASS_ENCODER(cls_rgw_reshard_entry)
-
-#endif
#include "common/ceph_context.h"
#include "global/global_context.h"
-#define dout_context g_ceph_context
-#define dout_subsys ceph_subsys_rgw
#define GC_LIST_DEFAULT_MAX 128
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
-#ifndef CEPH_CLS_RGW_GC_CLIENT_H
-#define CEPH_CLS_RGW_GC_CLIENT_H
+#pragma once
#include "include/rados/librados.hpp"
std::list<cls_rgw_gc_obj_info>& entries, bool *truncated, std::string& next_marker);
void cls_rgw_gc_queue_remove_entries(librados::ObjectWriteOperation& op, uint32_t num_entries);
void cls_rgw_gc_queue_defer_entry(librados::ObjectWriteOperation& op, uint32_t expiration_secs, const cls_rgw_gc_obj_info& info);
-
-#endif
-#ifndef CEPH_CLS_RGW_GC_CONSTS_H
-#define CEPH_CLS_RGW_GC_CONSTS_H
+// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
+// vim: ts=8 sw=2 smarttab
+
+#pragma once
#define RGW_GC_CLASS "rgw_gc"
#define RGW_GC_QUEUE_LIST_ENTRIES "rgw_gc_queue_list_entries"
#define RGW_GC_QUEUE_REMOVE_ENTRIES "rgw_gc_queue_remove_entries"
#define RGW_GC_QUEUE_UPDATE_ENTRY "rgw_gc_queue_update_entry"
-
-#endif
\ No newline at end of file
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
-#ifndef CEPH_CLS_RGW_GC_OPS_H
-#define CEPH_CLS_RGW_GC_OPS_H
+#pragma once
#include "cls/rgw/cls_rgw_types.h"
}
};
WRITE_CLASS_ENCODER(cls_rgw_gc_queue_defer_entry_op)
-#endif /* CEPH_CLS_RGW_GC_OPS_H */
// -*- mode:C++; tab-width:8; c-basic-offset:2; indent-tabs-mode:t -*-
// vim: ts=8 sw=2 smarttab
-#ifndef CEPH_CLS_RGW_GC_TYPES_H
-#define CEPH_CLS_RGW_GC_TYPES_H
+#pragma once
#include "include/types.h"
#include <unordered_map>
}
};
WRITE_CLASS_ENCODER(cls_rgw_gc_urgent_data)
-
-#endif
static RGWObjCategory main_category = RGWObjCategory::Main;
#define RGW_USAGE_OBJ_PREFIX "usage."
-#define dout_subsys ceph_subsys_rgw
-
static bool rgw_get_obj_data_pool(const RGWZoneGroup& zonegroup, const RGWZoneParams& zone_params,
const rgw_placement_rule& head_placement_rule,