add files

diff --git a/Robust/src/Runtime/STM/monitor.c b/Robust/src/Runtime/STM/monitor.c
new file mode 100644 (file)
index 0000000..84f10e4
--- /dev/null
+++ b/Robust/src/Runtime/STM/monitor.c
@@ -0,0 +1,46 @@
+#include "monitor.h"
+#include <unistd.h>
+#include <fcntl.h>
+#include <stdio.h>
+
+//Need to have global lock before calling this method
+void createmonitor() {
+  struct eventmonitor *event=calloc(1, sizeof(struct eventmonitor));
+  //add new eventmonitor to list
+  event->next=eventlist;
+  eventlist=events;
+  
+  //point thread lock variable to eventmonitor
+  events=event;
+  EVLOGEVENT(EM_THREAD);
+}
+
+void writedata(int fd, char * buffer, int count) {
+  int offset=0;
+  while(count>0) {
+    int size=write(fd, &buffer[offset], count);
+    offset+=size;
+    count-=size;
+  }
+}
+
+void dumpdata() {
+  int fd=open("logdata",O_RDWR|O_CREAT);
+  int count=0;
+  struct eventmonitor * ptr=eventlist;
+  while(ptr!=NULL) {
+    count++;
+    ptr=ptr->next;
+  }
+  writedata(fd, &count, sizeof(int));
+  ptr=eventlist;
+  if (ptr->index>MAXEVENTS) {
+    printf("ERROR: EVENT COUNT EXCEEDED\n")
+  }
+  while(ptr!=NULL) {
+    writedata(fd, &ptr->index, sizeof(int));
+    writedata(fd, ptr->value, sizeof(int)*ptr->index);
+    ptr=ptr->next;
+  }  
+  close(fd);
+}

diff --git a/Robust/src/Runtime/STM/monitor.h b/Robust/src/Runtime/STM/monitor.h
new file mode 100644 (file)
index 0000000..90eeb87
--- /dev/null
+++ b/Robust/src/Runtime/STM/monitor.h
@@ -0,0 +1,54 @@
+#ifndef MONITOR_H
+#define MONITOR_H
+
+#define MAXEVENTS (1024*1024*128)
+
+
+#define EV_THREAD 0
+#define EV_BARRIER 1
+#define EV_READ 2
+#define EV_WRITE 3
+#define EV_START 4
+#define EV_COMMIT 5
+#define EV_ABORT 6
+
+struct eventmonitor {
+  int index;
+  struct eventmonitor * next;
+  unsigned int value[MAXEVENTS];
+};
+
+extern __thread struct eventmonitor * events;
+extern struct eventmonitor * eventlist;
+void createmonitor();
+void dumpdata();
+
+#if defined(__i386__)
+static __inline__ unsigned long long rdtsc(void)
+{
+  unsigned long long int x;
+  __asm__ volatile (".byte 0x0f, 0x31" : "=A" (x));
+  return x;
+}
+#elif defined(__x86_64__)
+static __inline__ unsigned long long rdtsc(void)
+{
+  unsigned hi, lo;
+  __asm__ __volatile__ ("rdtsc" : "=a"(lo), "=d"(hi));
+  return ( (unsigned long long)lo)|( ((unsigned long long)hi)<<32 );
+}
+#endif
+
+#define LOGTIME *((long long *)&events->value[events->index])=rdtsc(); \
+  events->index+=2;
+
+#define EVLOGEVENT(x) { events->value[events->index++]=x;      \
+    LOGTIME                                                    \
+      }
+
+#define EVLOGEVENTOBJ(x,o) { events->value[events->index++]=x; \
+  events->value[events->index++]=o;                            \
+  LOGTIME                                                      \
+    }
+
+#endif