1 files changed, 144 insertions, 0 deletions
diff --git a/src/key_value_store/kvs_arg_types.h b/src/key_value_store/kvs_arg_types.h
new file mode 100644
index 000000000..5bcc4b131
--- /dev/null
+++ b/src/key_value_store/kvs_arg_types.h
@@ -0,0 +1,144 @@
+/*
+ * Argument types used by cls_kvs.cc
+ *
+ *  Created on: Aug 10, 2012
+ *      Author: eleanor
+ */
+
+#ifndef CLS_KVS_H_
+#define CLS_KVS_H_
+
+#define EBALANCE 137
+
+#include "include/encoding.h"
+#include "key_value_store/kv_flat_btree_async.h"
+
+using ceph::bufferlist;
+
+struct assert_size_args {
+  uint64_t bound; //the size to compare to - should be k or 2k
+  uint64_t comparator; //should be CEPH_OSD_CMPXATTR_OP_EQ,
+		  //CEPH_OSD_CMPXATTR_OP_LT, or
+		  //CEPH_OSD_CMPXATTR_OP_GT
+
+  void encode(bufferlist &bl) const {
+    ENCODE_START(1,1,bl);
+    encode(bound, bl);
+    encode(comparator, bl);
+    ENCODE_FINISH(bl);
+  }
+  void decode(bufferlist::const_iterator &p) {
+    DECODE_START(1, p);
+    decode(bound, p);
+    decode(comparator, p);
+    DECODE_FINISH(p);
+  }
+};
+WRITE_CLASS_ENCODER(assert_size_args)
+
+struct idata_from_key_args {
+  std::string key;
+  index_data idata;
+  index_data next_idata;
+
+  void encode(bufferlist &bl) const {
+    ENCODE_START(1,1,bl);
+    encode(key, bl);
+    encode(idata, bl);
+    encode(next_idata, bl);
+    ENCODE_FINISH(bl);
+  }
+  void decode(bufferlist::const_iterator &p) {
+    DECODE_START(1, p);
+    decode(key, p);
+    decode(idata, p);
+    decode(next_idata, p);
+    DECODE_FINISH(p);
+  }
+};
+WRITE_CLASS_ENCODER(idata_from_key_args)
+
+struct idata_from_idata_args {
+  index_data idata;
+  index_data next_idata;
+
+  void encode(bufferlist &bl) const {
+    ENCODE_START(1,1,bl);
+    encode(idata, bl);
+    encode(next_idata, bl);
+    ENCODE_FINISH(bl);
+  }
+  void decode(bufferlist::const_iterator &p) {
+    DECODE_START(1, p);
+    decode(idata, p);
+    decode(next_idata, p);
+    DECODE_FINISH(p);
+  }
+};
+WRITE_CLASS_ENCODER(idata_from_idata_args)
+
+struct omap_set_args {
+  std::map<std::string, bufferlist> omap;
+  uint64_t bound;
+  bool exclusive;
+
+  void encode(bufferlist &bl) const {
+    ENCODE_START(1,1,bl);
+    encode(omap, bl);
+    encode(bound, bl);
+    encode(exclusive, bl);
+    ENCODE_FINISH(bl);
+  }
+  void decode(bufferlist::const_iterator &p) {
+    DECODE_START(1, p);
+    decode(omap, p);
+    decode(bound, p);
+    decode(exclusive, p);
+    DECODE_FINISH(p);
+  }
+};
+WRITE_CLASS_ENCODER(omap_set_args)
+
+struct omap_rm_args {
+  std::set<std::string> omap;
+  uint64_t bound;
+
+  void encode(bufferlist &bl) const {
+    ENCODE_START(1,1,bl);
+    encode(omap, bl);
+    encode(bound, bl);
+    ENCODE_FINISH(bl);
+  }
+  void decode(bufferlist::const_iterator &p) {
+    DECODE_START(1, p);
+    decode(omap, p);
+    decode(bound, p);
+    DECODE_FINISH(p);
+  }
+};
+WRITE_CLASS_ENCODER(omap_rm_args)
+
+struct rebalance_args {
+  object_data odata;
+  uint64_t bound;
+  uint64_t comparator;
+
+  void encode(bufferlist &bl) const {
+    ENCODE_START(1,1,bl);
+    encode(odata, bl);
+    encode(bound, bl);
+    encode(comparator, bl);
+    ENCODE_FINISH(bl);
+  }
+  void decode(bufferlist::const_iterator &p) {
+    DECODE_START(1, p);
+    decode(odata,p);
+    decode(bound, p);
+    decode(comparator, p);
+    DECODE_FINISH(p);
+  }
+};
+WRITE_CLASS_ENCODER(rebalance_args)
+
+
+#endif /* CLS_KVS_H_ */