From 5f579f4978fb453032a6dd633fe1d745679fc50f Mon Sep 17 00:00:00 2001
From: bdemsky <bdemsky>
Date: Sat, 19 Dec 2009 07:46:00 +0000
Subject: [PATCH] add files

---
 Robust/src/Runtime/STM/monitor.c | 46 +++++++++++++++++++++++++++
 Robust/src/Runtime/STM/monitor.h | 54 ++++++++++++++++++++++++++++++++
 2 files changed, 100 insertions(+)
 create mode 100644 Robust/src/Runtime/STM/monitor.c
 create mode 100644 Robust/src/Runtime/STM/monitor.h

diff --git a/Robust/src/Runtime/STM/monitor.c b/Robust/src/Runtime/STM/monitor.c
new file mode 100644
index 00000000..84f10e43
--- /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
index 00000000..90eeb875
--- /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
-- 
2.34.1