more changes to support range prefetching :

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

diff --git a/Robust/src/Runtime/DSTM/interface/prefetch.h b/Robust/src/Runtime/DSTM/interface/prefetch.h
index 0920bce6c65bcec44aa721f35d140071d4900abe..79e0a49c76e746a9a973871492b543724cca8b35 100644 (file)
--- a/Robust/src/Runtime/DSTM/interface/prefetch.h
+++ b/Robust/src/Runtime/DSTM/interface/prefetch.h
@@ -4,11 +4,42 @@
 #define GET_STRIDE(x) ((x & 0x7000) >> 12)
 #define GET_RANGE(x) (x & 0x0fff)
 #define GET_STRIDEINC(x) ((x & 0x8000) >> 15)
+
+/****** Global structure **********/
+typedef struct objOffsetPile {
+  unsigned int oid;
+  short numoffset;
+  short *offsets;
+  struct objOffsetPile *next;
+} objOffsetPile_t;
+
+typedef struct perMcPrefetchList {
+  unsigned int mid;
+  objOffsetPile_t *list;
+  struct perMcPrefetchList *next;
+} perMcPrefetchList_t;
+
+typedef struct proPrefetchQ {
+  perMcPrefetchList_t *front, *rear;
+  pthread_mutex_t qlock;
+  pthread_mutexattr_t qlockattr;
+  pthread_cond_t qcond;
+} proPrefetchQ_t;
+
+// Global Prefetch Processing Queue
+proPrefetchQ_t prefetchQ;
+
+/**** Prefetch Queue to be processed functions ******/
+void proPrefetchQDealloc(perMcPrefetchList_t *);
+
+/******** Process Queue Element functions ***********/
 void rangePrefetch(int, int, unsigned int *, unsigned short *, short *offset);
 void *transPrefetchNew();
-void checkIfLocal(char *ptr);
+perMcPrefetchList_t* checkIfLocal(char *ptr);
 int isOidAvail(unsigned int oid);
 int lookForObjs(int*, short *, int *, int *, int *);
+void insertPrefetch(int, unsigned int, short, short*, perMcPrefetchList_t **); 
+void sendRangePrefetchReq(perMcPrefetchList_t *, int sd);
 
 /************* Internal functions *******************/
 int getsize(short *ptr, int n);