benchmark silo added

[c11concurrency-benchmarks.git] / silo / tuple.cc

diff --git a/silo/tuple.cc b/silo/tuple.cc
new file mode 100644 (file)
index 0000000..3731d9c
--- /dev/null
+++ b/silo/tuple.cc
@@ -0,0 +1,105 @@
+#include "tuple.h"
+#include "txn.h"
+
+using namespace std;
+using namespace util;
+
+event_avg_counter dbtuple::g_evt_avg_dbtuple_stable_version_spins
+  ("avg_dbtuple_stable_version_spins");
+event_avg_counter dbtuple::g_evt_avg_dbtuple_lock_acquire_spins
+  ("avg_dbtuple_lock_acquire_spins");
+event_avg_counter dbtuple::g_evt_avg_dbtuple_read_retries
+  ("avg_dbtuple_read_retries");
+
+event_counter dbtuple::g_evt_dbtuple_creates("dbtuple_creates");
+event_counter dbtuple::g_evt_dbtuple_logical_deletes("dbtuple_logical_deletes");
+event_counter dbtuple::g_evt_dbtuple_physical_deletes("dbtuple_physical_deletes");
+event_counter dbtuple::g_evt_dbtuple_bytes_allocated("dbtuple_bytes_allocated");
+event_counter dbtuple::g_evt_dbtuple_bytes_freed("dbtuple_bytes_freed");
+event_counter dbtuple::g_evt_dbtuple_spills("dbtuple_spills");
+event_counter dbtuple::g_evt_dbtuple_inplace_buf_insufficient("dbtuple_inplace_buf_insufficient");
+event_counter dbtuple::g_evt_dbtuple_inplace_buf_insufficient_on_spill("dbtuple_inplace_buf_insufficient_on_spill");
+
+event_avg_counter dbtuple::g_evt_avg_record_spill_len("avg_record_spill_len");
+static event_avg_counter evt_avg_dbtuple_chain_length("avg_dbtuple_chain_len");
+
+dbtuple::~dbtuple()
+{
+  CheckMagic();
+  INVARIANT(!is_locked());
+  INVARIANT(!is_latest());
+  INVARIANT(!is_write_intent());
+  INVARIANT(!is_modifying());
+
+  VERBOSE(cerr << "dbtuple: " << hexify(intptr_t(this)) << " is being deleted" << endl);
+
+  // only free this instance
+
+  // stats-keeping
+  ++g_evt_dbtuple_physical_deletes;
+  g_evt_dbtuple_bytes_freed += (alloc_size + sizeof(dbtuple));
+
+}
+
+void
+dbtuple::gc_this()
+{
+  INVARIANT(rcu::s_instance.in_rcu_region());
+  INVARIANT(!is_latest());
+  release(this);
+}
+
+string
+dbtuple::VersionInfoStr(version_t v)
+{
+  ostringstream buf;
+  buf << "[";
+  buf << (IsLocked(v) ? "LOCKED" : "-") << " | ";
+  buf << (IsDeleting(v) ? "DEL" : "-") << " | ";
+  buf << (IsWriteIntent(v) ? "WR" : "-") << " | ";
+  buf << (IsModifying(v) ? "MOD" : "-") << " | ";
+  buf << (IsLatest(v) ? "LATEST" : "-") << " | ";
+  buf << Version(v);
+  buf << "]";
+  return buf.str();
+}
+
+static ostream &
+format_tuple(ostream &o, const dbtuple &t)
+{
+  string truncated_contents(
+      (const char *) &t.value_start[0], min(static_cast<size_t>(t.size), 16UL));
+  o << &t << " [tid=" << g_proto_version_str(t.version)
+    << ", size=" << t.size
+    << ", contents=0x" << hexify(truncated_contents) << (t.size > 16 ? "..." : "")
+    << ", next=" << t.next << "]";
+  return o;
+}
+
+void
+dbtuple::print(ostream &o, unsigned len) const
+{
+  o << "dbtuple:" << endl
+    << "  hdr=" << VersionInfoStr(unstable_version())
+#ifdef TUPLE_CHECK_KEY
+    << endl << "  key=" << hexify(key)
+    << endl << "  tree=" << tree
+#endif
+    << endl;
+
+  size_t n = 0;
+  for (const dbtuple *p = this;
+       p && n < len;
+       p = p->get_next(), ++n) {
+    o << "  ";
+    format_tuple(o, *p);
+    o << endl;
+  }
+}
+
+ostream &
+operator<<(ostream &o, const dbtuple &t)
+{
+  t.print(o, 1);
+  return o;
+}