--- /dev/null
+#include <errno.h>
+
+#include "cls/statelog/cls_statelog_client.h"
+#include "include/rados/librados.hpp"
+
+
+using namespace librados;
+
+
+void cls_statelog_add(librados::ObjectWriteOperation& op, list<cls_statelog_entry>& entries)
+{
+ bufferlist in;
+ cls_statelog_add_op call;
+ call.entries = entries;
+ ::encode(call, in);
+ op.exec("statelog", "add", in);
+}
+
+void cls_statelog_add(librados::ObjectWriteOperation& op, cls_statelog_entry& entry)
+{
+ bufferlist in;
+ cls_statelog_add_op call;
+ call.entries.push_back(entry);
+ ::encode(call, in);
+ op.exec("statelog", "add", in);
+}
+
+void cls_statelog_add_prepare_entry(cls_statelog_entry& entry, const string& client_id, const string& op_id,
+ const string& object, const utime_t& timestamp, uint32_t state, bufferlist& bl)
+{
+ entry.client_id = client_id;
+ entry.op_id = op_id;
+ entry.object = object;
+ entry.timestamp = timestamp;
+ entry.state = state;
+ entry.data = bl;
+}
+
+void cls_statelog_add(librados::ObjectWriteOperation& op, const string& client_id, const string& op_id,
+ const string& object, const utime_t& timestamp, uint32_t state, bufferlist& bl)
+
+{
+ cls_statelog_entry entry;
+
+ cls_statelog_add_prepare_entry(entry, client_id, op_id, object, timestamp, state, bl);
+ cls_statelog_add(op, entry);
+}
+
+void cls_statelog_remove_by_client(librados::ObjectWriteOperation& op, const string& client_id, const string& op_id)
+{
+ bufferlist in;
+ cls_statelog_remove_op call;
+ call.client_id = client_id;
+ call.op_id = op_id;
+ ::encode(call, in);
+ op.exec("statelog", "remove", in);
+}
+
+void cls_statelog_remove_by_object(librados::ObjectWriteOperation& op, const string& object, const string& op_id)
+{
+ bufferlist in;
+ cls_statelog_remove_op call;
+ call.object = object;
+ call.op_id = op_id;
+ ::encode(call, in);
+ op.exec("statelog", "remove", in);
+}
+
+class StateLogListCtx : public ObjectOperationCompletion {
+ list<cls_statelog_entry> *entries;
+ string *marker;
+ bool *truncated;
+public:
+ StateLogListCtx(list<cls_statelog_entry> *_entries, string *_marker, bool *_truncated) :
+ entries(_entries), marker(_marker), truncated(_truncated) {}
+ void handle_completion(int r, bufferlist& outbl) override {
+ if (r >= 0) {
+ cls_statelog_list_ret ret;
+ try {
+ bufferlist::iterator iter = outbl.begin();
+ ::decode(ret, iter);
+ if (entries)
+ *entries = ret.entries;
+ if (truncated)
+ *truncated = ret.truncated;
+ if (marker)
+ *marker = ret.marker;
+ } catch (buffer::error& err) {
+ // nothing we can do about it atm
+ }
+ }
+ }
+};
+
+void cls_statelog_list(librados::ObjectReadOperation& op,
+ const string& client_id, const string& op_id, const string& object, /* op_id may be empty, also one of client_id, object*/
+ const string& in_marker, int max_entries, list<cls_statelog_entry>& entries,
+ string *out_marker, bool *truncated)
+{
+ bufferlist inbl;
+ cls_statelog_list_op call;
+ call.client_id = client_id;
+ call.op_id = op_id;
+ call.object = object;
+ call.marker = in_marker;
+ call.max_entries = max_entries;
+
+ ::encode(call, inbl);
+
+ op.exec("statelog", "list", inbl, new StateLogListCtx(&entries, out_marker, truncated));
+}
+
+void cls_statelog_check_state(librados::ObjectOperation& op, const string& client_id, const string& op_id, const string& object, uint32_t state)
+{
+ bufferlist inbl;
+ cls_statelog_check_state_op call;
+ call.client_id = client_id;
+ call.op_id = op_id;
+ call.object = object;
+ call.state = state;
+
+ ::encode(call, inbl);
+
+ op.exec("statelog", "check_state", inbl, NULL);
+}
+