From 837d9650ff312c1107a63cb4a1337e8d4e4a39eb Mon Sep 17 00:00:00 2001
From: adash <adash>
Date: Sun, 8 Feb 2009 08:43:44 +0000
Subject: [PATCH] new benchmark for lookup service

---
 .../LookUpService/LookUpService.java          | 89 +++++++++++++++++++
 .../Distributed/LookUpService/makefile        | 12 +++
 2 files changed, 101 insertions(+)
 create mode 100644 Robust/src/Benchmarks/Distributed/LookUpService/LookUpService.java
 create mode 100644 Robust/src/Benchmarks/Distributed/LookUpService/makefile

diff --git a/Robust/src/Benchmarks/Distributed/LookUpService/LookUpService.java b/Robust/src/Benchmarks/Distributed/LookUpService/LookUpService.java
new file mode 100644
index 00000000..1680c5d6
--- /dev/null
+++ b/Robust/src/Benchmarks/Distributed/LookUpService/LookUpService.java
@@ -0,0 +1,89 @@
+public class LookUpService extends Thread {
+  DistributedHashMap mydhmap;
+  int threadid;
+  int numthreads;
+
+  public LookUpService(DistributedHashMap dmap, int threadid, int numthreads) {
+    mydhmap = dmap;
+    this.threadid = threadid;
+    this.numthreads = numthreads;
+  }
+
+  public void run() {
+    //Add to the hash map
+    int nobjs = 10;
+    // Do read/writes
+    int numtrans = 1000;
+    // read probability % between 0-99
+    int rdprob = 90;
+    atomic {
+      for(int i = 0; i < nobjs; i++) {
+        Integer key = global new Integer(threadid*nobjs+i);
+        Integer val = global new Integer(i);
+        Object o1 = key;
+        Object o2 = val;
+        mydhmap.put(o1, o2);
+      }
+    }
+    for (int i = 0; i < numtrans; i++) {
+      Random rand = new Random(i);
+      int rdwr = rand.nextInt(100);
+      int rwkey = rand.nextInt(nobjs*numthreads);
+      Integer k = new Integer(rwkey);
+      if (rdwr < rdprob) {
+        Integer tmp = mydhmap.get(k);
+      } else {
+        Integer val = global new Integer(i);
+        mydhmap.put(k, val);
+      }
+    }
+  }
+
+  public static void main(String[] args) {
+    int nthreads;
+    if(args.length>0)
+      nthreads = Integer.parseInt(args[0]);
+
+    int[] mid = new int[8];
+    mid[0] = (128<<24)|(195<<16)|(175<<8)|79;//dc-1
+    mid[1] = (128<<24)|(195<<16)|(136<<8)|163;//dc-2
+    mid[2] = (128<<24)|(195<<16)|(136<<8)|164;//dc-3
+    mid[3] = (128<<24)|(195<<16)|(136<<8)|165;//dc-4
+    mid[4] = (128<<24)|(195<<16)|(136<<8)|166;//dc-5
+    mid[5] = (128<<24)|(195<<16)|(136<<8)|167;//dc-6
+    mid[6] = (128<<24)|(195<<16)|(136<<8)|168;//dc-7
+    mid[7] = (128<<24)|(195<<16)|(136<<8)|169;//dc-8
+
+    LookUpService[] lus;
+    DistributedHashMap dhmap;
+    //DistributedHashEntry dhe;
+
+    
+    atomic {
+      dhmap = global new DistributedHashMap(100, 100, 0.75f);
+      lus = global new LookUpService[nthreads];
+      for(int i = 0; i<nthreads; i++) {
+        lus[i] = global new LookUpService(dhmap, i, nthreads);
+      }
+    }
+
+    LookUpService tmp;
+    /* Start threads */
+    for(int i = 0; i<nthreads; i++) {
+      atomic {
+        tmp = lus[i];
+      }
+      tmp.start(mid[i]);
+    }
+
+    /* Join threads */
+    for(int i = 0; i<nthreads; i++) {
+      atomic {
+        tmp = lus[i];
+      }
+      tmp.join();
+    }
+
+    System.printString("Finished\n");
+  }
+}
diff --git a/Robust/src/Benchmarks/Distributed/LookUpService/makefile b/Robust/src/Benchmarks/Distributed/LookUpService/makefile
new file mode 100644
index 00000000..b31cf2b4
--- /dev/null
+++ b/Robust/src/Benchmarks/Distributed/LookUpService/makefile
@@ -0,0 +1,12 @@
+MAINCLASS=LookUpService
+SRC1=${MAINCLASS}.java \
+     ../../../ClassLibrary/DistributedHashMap.java
+FLAGS1=-dsm -dsmcaching -rangeprefetch -optimize -mainclass ${MAINCLASS} -trueprob 0.90
+FLAGS2=-dsm -optimize -mainclass ${MAINCLASS}
+default:
+#	../../../buildscript ${FLAGS2} -o ${MAINCLASS}NPNC ${SRC1}
+	../../../buildscript ${FLAGS1} -o ${MAINCLASS}RangePN ${SRC1}
+
+clean:
+	rm -rf tmpbuilddirectory
+	rm *.bin
-- 
2.34.1