benchmark silo added

[c11concurrency-benchmarks.git] / silo / new-benchmarks / abstract_db.h

diff --git a/silo/new-benchmarks/abstract_db.h b/silo/new-benchmarks/abstract_db.h
new file mode 100644 (file)
index 0000000..e343602
--- /dev/null
+++ b/silo/new-benchmarks/abstract_db.h
@@ -0,0 +1,111 @@
+#ifndef _ABSTRACT_DB_H_
+#define _ABSTRACT_DB_H_
+
+#include <stddef.h>
+#include <stdint.h>
+#include <sys/types.h>
+
+#include <map>
+#include <string>
+
+#include "abstract_ordered_index.h"
+
+class abstract_db {
+public:
+
+  // dtor should close db
+  virtual ~abstract_db() {}
+
+  /**
+   * an approximate max batch size for updates in a transaction.
+   *
+   * A return value of -1 indicates no maximum
+   */
+  virtual ssize_t txn_max_batch_size() const { return -1; }
+
+  /**
+   * XXX(stephentu): hack
+   */
+  virtual void do_txn_epoch_sync() const {}
+
+  /**
+   * XXX(stephentu): hack
+   */
+  virtual void do_txn_finish() const {}
+
+  /** loader should be used as a performance hint, not for correctness */
+  virtual void thread_init(bool loader) {}
+
+  virtual void thread_end() {}
+
+  // [ntxns_persisted, ntxns_committed, avg latency]
+  virtual std::tuple<uint64_t, uint64_t, double>
+    get_ntxn_persisted() const { return std::make_tuple(0, 0, 0.0); }
+
+  virtual void reset_ntxn_persisted() { }
+
+  enum TxnProfileHint {
+    HINT_DEFAULT,
+
+    // ycsb profiles
+    HINT_KV_GET_PUT, // KV workloads over a single key
+    HINT_KV_RMW, // get/put over a single key
+    HINT_KV_SCAN, // KV scan workloads (~100 keys)
+
+    // tpcc profiles
+    HINT_TPCC_NEW_ORDER,
+    HINT_TPCC_PAYMENT,
+    HINT_TPCC_DELIVERY,
+    HINT_TPCC_ORDER_STATUS,
+    HINT_TPCC_ORDER_STATUS_READ_ONLY,
+    HINT_TPCC_STOCK_LEVEL,
+    HINT_TPCC_STOCK_LEVEL_READ_ONLY,
+  };
+
+  ///**
+  // * Initializes a new txn object the space pointed to by buf
+  // *
+  // * Flags is only for the ndb protocol for now
+  // *
+  // * [buf, buf + sizeof_txn_object(txn_flags)) is a valid ptr
+  // */
+  //virtual void *new_txn(uint64_t txn_flags, void *buf,
+  //    TxnProfileHint hint = HINT_DEFAULT) = 0;
+
+  typedef std::map<std::string, uint64_t> counter_map;
+  typedef std::map<std::string, counter_map> txn_counter_map;
+
+  /**
+   * Reports things like read/write set sizes
+   */
+  virtual counter_map
+  get_txn_counters(void *txn) const
+  {
+    return counter_map();
+  }
+
+  ///**
+  // * Returns true on successful commit.
+  // *
+  // * On failure, can either throw abstract_abort_exception, or
+  // * return false- caller should be prepared to deal with both cases
+  // */
+  //virtual bool commit_txn(void *txn) = 0;
+
+  ///**
+  // * XXX
+  // */
+  //virtual void abort_txn(void *txn) = 0;
+
+  //virtual void print_txn_debug(void *txn) const {}
+
+  //virtual abstract_ordered_index *
+  //open_index(const std::string &name,
+  //           size_t value_size_hint,
+  //           bool mostly_append = false) = 0;
+
+  //virtual void
+  //close_index(abstract_ordered_index *idx) = 0;
+};
+
+#endif /* _ABSTRACT_DB_H_ */