+++ /dev/null
-#include <errno.h>
-
-#include "cls/log/cls_log_ops.h"
-#include "include/rados/librados.hpp"
-#include "include/compat.h"
-
-
-using namespace librados;
-
-
-
-void cls_log_add(librados::ObjectWriteOperation& op, list<cls_log_entry>& entries, bool monotonic_inc)
-{
- bufferlist in;
- cls_log_add_op call;
- call.entries = entries;
- ::encode(call, in);
- op.exec("log", "add", in);
-}
-
-void cls_log_add(librados::ObjectWriteOperation& op, cls_log_entry& entry)
-{
- bufferlist in;
- cls_log_add_op call;
- call.entries.push_back(entry);
- ::encode(call, in);
- op.exec("log", "add", in);
-}
-
-void cls_log_add_prepare_entry(cls_log_entry& entry, const utime_t& timestamp,
- const string& section, const string& name, bufferlist& bl)
-{
- entry.timestamp = timestamp;
- entry.section = section;
- entry.name = name;
- entry.data = bl;
-}
-
-void cls_log_add(librados::ObjectWriteOperation& op, const utime_t& timestamp,
- const string& section, const string& name, bufferlist& bl)
-{
- cls_log_entry entry;
-
- cls_log_add_prepare_entry(entry, timestamp, section, name, bl);
- cls_log_add(op, entry);
-}
-
-void cls_log_trim(librados::ObjectWriteOperation& op, const utime_t& from_time, const utime_t& to_time,
- const string& from_marker, const string& to_marker)
-{
- bufferlist in;
- cls_log_trim_op call;
- call.from_time = from_time;
- call.to_time = to_time;
- call.from_marker = from_marker;
- call.to_marker = to_marker;
- ::encode(call, in);
- op.exec("log", "trim", in);
-}
-
-int cls_log_trim(librados::IoCtx& io_ctx, const string& oid, const utime_t& from_time, const utime_t& to_time,
- const string& from_marker, const string& to_marker)
-{
- bool done = false;
-
- do {
- ObjectWriteOperation op;
-
- cls_log_trim(op, from_time, to_time, from_marker, to_marker);
-
- int r = io_ctx.operate(oid, &op);
- if (r == -ENODATA)
- done = true;
- else if (r < 0)
- return r;
-
- } while (!done);
-
-
- return 0;
-}
-
-class LogListCtx : public ObjectOperationCompletion {
- list<cls_log_entry> *entries;
- string *marker;
- bool *truncated;
-public:
- LogListCtx(list<cls_log_entry> *_entries, string *_marker, bool *_truncated) :
- entries(_entries), marker(_marker), truncated(_truncated) {}
- void handle_completion(int r, bufferlist& outbl) override {
- if (r >= 0) {
- cls_log_list_ret ret;
- try {
- bufferlist::iterator iter = outbl.begin();
- ::decode(ret, iter);
- if (entries)
- *entries = std::move(ret.entries);
- if (truncated)
- *truncated = ret.truncated;
- if (marker)
- *marker = std::move(ret.marker);
- } catch (buffer::error& err) {
- // nothing we can do about it atm
- }
- }
- }
-};
-
-void cls_log_list(librados::ObjectReadOperation& op, utime_t& from, utime_t& to,
- const string& in_marker, int max_entries,
- list<cls_log_entry>& entries,
- string *out_marker, bool *truncated)
-{
- bufferlist inbl;
- cls_log_list_op call;
- call.from_time = from;
- call.to_time = to;
- call.marker = in_marker;
- call.max_entries = max_entries;
-
- ::encode(call, inbl);
-
- op.exec("log", "list", inbl, new LogListCtx(&entries, out_marker, truncated));
-}
-
-class LogInfoCtx : public ObjectOperationCompletion {
- cls_log_header *header;
-public:
- explicit LogInfoCtx(cls_log_header *_header) : header(_header) {}
- void handle_completion(int r, bufferlist& outbl) override {
- if (r >= 0) {
- cls_log_info_ret ret;
- try {
- bufferlist::iterator iter = outbl.begin();
- ::decode(ret, iter);
- if (header)
- *header = ret.header;
- } catch (buffer::error& err) {
- // nothing we can do about it atm
- }
- }
- }
-};
-
-void cls_log_info(librados::ObjectReadOperation& op, cls_log_header *header)
-{
- bufferlist inbl;
- cls_log_info_op call;
-
- ::encode(call, inbl);
-
- op.exec("log", "info", inbl, new LogInfoCtx(header));
-}
-