complete hashtable implementation with separate socket pools for read and

[IRC.git] / Robust / src / Runtime / DSTM / interface / dstm.h

diff --git a/Robust/src/Runtime/DSTM/interface/dstm.h b/Robust/src/Runtime/DSTM/interface/dstm.h
index f7478881487e7feea66a4704faa909049cf9e669..8a86ea2fb9b61101e22c0b0f64a6e52ab8a60847 100644 (file)
--- a/Robust/src/Runtime/DSTM/interface/dstm.h
+++ b/Robust/src/Runtime/DSTM/interface/dstm.h
@@ -48,9 +48,11 @@
 #define MAX_OBJECTS  20
 //Max remote-machine connections
 #define NUM_MACHINES 2
+#define LOADFACTOR 0.5
 #define DEFAULT_OBJ_STORE_SIZE 1048510 //1MB
 //Transaction id per machine
 #define TID_LEN 20
+#define LISTEN_PORT 2156
 
 
 #include <stdlib.h>
@@ -61,7 +63,15 @@
 #include "queue.h"
 #include "mcpileq.h"
 #include "threadnotify.h"
-
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <netdb.h>
+#include <netinet/in.h>
+#include <sys/types.h>
+#include <unistd.h>
+#include <errno.h>
+#include <time.h>
+#include "sockpool.h"
 
 //bit designations for status field of objheader
 #define DIRTY 0x01
@@ -124,6 +134,11 @@ typedef struct objstr {
        struct objstr *next;
 } objstr_t;
 
+typedef struct oidmidpair {
+    unsigned int oid;
+    unsigned int mid;
+} oidmidpair_t;
+
 typedef struct transrecord {
   objstr_t *cache;
   chashtable_t *lookupTable;