operator new and delete

3e7c413f · Nickolai Zeldovich · 0b9edac9 · 3e7c413f · 3e7c413f · 3e7c413f
--- a/Makefile
+++ b/Makefile
@@ -26,7 +26,7 @@ COMFLAGS := -fno-pic -static -fno-builtin -fno-strict-aliasing -O2 -Wall \
 	    -DHW_$(HW) -include param.h -include compiler.h
 COMFLAGS += $(shell $(CC) -fno-stack-protector -E -x c /dev/null >/dev/null 2>&1 && echo -fno-stack-protector)
 CFLAGS   := $(COMFLAGS) -std=c99
-CXXFLAGS := $(COMFLAGS) -std=c++0x -Wno-sign-compare
+CXXFLAGS := $(COMFLAGS) -std=c++0x -Wno-sign-compare -fno-exceptions
 ASFLAGS = -m64 -gdwarf-2 -MD
 LDFLAGS += -m elf_x86_64
@@ -36,6 +36,7 @@ OBJS = \
 	cilk.o \
 	condvar.o \
 	console.o \
+	cpprt.o \
 	crange.o \
 	e1000.o \
 	exec.o \

--- a/cpprt.cc
+++ b/cpprt.cc
+extern "C" {
+#include "types.h"
+#include "kernel.h"
+}
+void *
+operator new(unsigned long nbytes)
+{
+  return kmalloc(nbytes);
+}
+void
+operator delete(void *p)
+{
+  kmfree(p);
+}
--- a/kernel.h
+++ b/kernel.h
@@ -216,7 +216,6 @@ struct nskey {
 						   .u.iis.b=y, \
 						   .u.iis.s=z}
-void            nsinit(void);
 struct ns*      nsalloc(int allowdup);
 void		nsfree(struct ns*);
 u64             ns_allockey(struct ns*);

--- a/ns.cc
+++ b/ns.cc
@@ -45,10 +45,6 @@ struct ns {
  struct bucket table[NHASH];
 };
-void
-nsinit(void)
-{
-}
 // XXX should be using our missing scalable allocator module
 struct ns*

--- a/ns.hh
+++ b/ns.hh
+#pragma once
+// name spaces
+// XXX maybe use open hash table, no chain, better cache locality
+#if SPINLOCK_DEBUG
+#define NHASH 10
+#else
+#define NHASH 100
+#endif
+class scoped_gc_epoch {
+ public:
+  scoped_gc_epoch() { gc_begin_epoch(); }
+  ~scoped_gc_epoch() { gc_end_epoch(); }
+};
+template<class K, class V>
+class xelem {
+ public:
+  V val;
+  int next_lock;
+  xelem<K, V> * volatile next;
+  K key;
+  xelem(const K &k, const V &v) : val(v), key(k) {}
+};
+template<class K, class V>
+struct xbucket {
+  xelem<K, V> * volatile chain;
+} __attribute__((aligned (CACHELINE)));
+template<class K, class V>
+class xns {
+ private:
+  bool allowdup;
+  u64 nextkey;
+  xbucket<K, V> table[NHASH];
+ public:
+  xns(bool dup) {
+    allowdup = dup;
+    nextkey = 1;
+    for (int i = 0; i < NHASH; i++)
+      table[i].chain = 0;
+  }
+  ~xns() {
+    for (int i = 0; i < NHASH; i++)
+      if (table[i].chain)
+        panic("~xns: not empty");
+  }
+  u64 allockey() {
+    return __sync_fetch_and_add(&nextkey, 1);
+  }
+  u64 h(const K &key) {
+    return key % NHASH;
+  }
+  int insert(const K &key, const V &val) {
+    auto e = new xelem<K, V>(key, val);
+    if (!e)
+      return -1;
+    u64 i = h(key);
+    scoped_gc_epoch gc;
+    for (;;) {
+      auto root = table[i].chain;
+      if (!allowdup) {
+        for (auto x = root; x; x = x->next) {
+          if (x->key == key) {
+            // XXX delete e;
+            return -1;
+          }
+        }
+      }
+      e->next = root;
+      if (__sync_bool_compare_and_swap(&table[i].chain, root, e))
+        return 0;
+    }
+  }
+  V lookup(const K &key) {
+    u64 i = h(key);
+    scoped_gc_epoch gc;
+    auto e = table[i].chain;
+    while (e) {
+      if (e->key == key)
+        return e->val;
+      e = e->next;
+    }
+    return 0;
+  }
+  bool remove(const K &key, const V *vp = 0) {
+    u64 i = h(key);
+    scoped_gc_epoch gc;
+    for (;;) {
+      int fakelock = 0;
+      int *pelock = &fakelock;
+      auto pe = &table[i].chain;
+      for (;;) {
+        auto e = *pe;
+        if (!e)
+          return false;
+        if (e->key == key && (!vp || e->val == *vp)) {
+          if (!__sync_bool_compare_and_swap(&e->next_lock, 0, 1))
+            break;
+          if (!__sync_bool_compare_and_swap(pelock, 0, 1)) {
+            e->next_lock = 0;
+            break;
+          }
+          if (!__sync_bool_compare_and_swap(pe, e, e->next)) {
+            *pelock = 0;
+            e->next_lock = 0;
+            break;
+          }
+          *pelock = 0;
+          // XXX delete e;
+          return true;
+        }
+        pe = &e->next;
+        pelock = &e->next_lock;
+      }
+    }
+  }
+  template<class CB>
+  void enumerate(CB cb) {
+    scoped_gc_epoch gc;
+    for (int i = 0; i < NHASH; i++) {
+      auto e = table[i].chain;
+      while (e) {
+        if (cb(e->key, e->val))
+          return;
+        e = e->next;
+      }
+    }
+  }
+  template<class CB>
+  void enumerate_key(const K &key, CB cb) {
+    scoped_gc_epoch gc;
+    u64 i = h(key);
+    auto e = table[i].chain;
+    while (e) {
+      if (e->key == key && cb(e->key, e->val))
+        return;
+      e = e->next;
+    }
+  }
+};