Simplifying...
authorTerry L. Wilmarth <wilmarth@uiuc.edu>
Thu, 16 Dec 2004 16:56:47 +0000 (16:56 +0000)
committerTerry L. Wilmarth <wilmarth@uiuc.edu>
Thu, 16 Dec 2004 16:56:47 +0000 (16:56 +0000)
examples/pose/SimBenchmark/Worker.C
examples/pose/SimBenchmark/pgm.C

index 8e13035b9da1c7d7a1f317d511704bf1d7e79737..1879bd773e00de378ca580cebc77d031e341fcbb 100644 (file)
@@ -104,21 +104,14 @@ void worker::doWork()
   MediumWorkMsg *mm;
   LargeWorkMsg *lm;
 
-  if ((POSE_endtime > -1) && (OVT() > POSE_endtime))  return;
-
-  // do some computation based on gsIdx
-  if (granularity > 0.0) POSE_busy_wait(granularity);
-  else if (grainSize == FINE) POSE_busy_wait(FINE_GRAIN);
-  else if (grainSize == MEDIUM_GS) POSE_busy_wait(MEDIUM_GRAIN);
-  else if (grainSize == COARSE) POSE_busy_wait(COARSE_GRAIN);
-  else if (grainSize == MIX_GS) POSE_busy_wait(MEDIUM_GRAIN);
-
   // generate some events
   int actualMsgSize = msgSize;
   int local = (int)(((double)locality)/100.0 * (double)msgsPerWork);
-  int localNbr = (myHandle+1) % numObjs;
+  //CkPrintf("%d out of %d messages will be sent to local objects\n", local, msgsPerWork);
+  int localNbr;
   for (int i=0; i<msgsPerWork; i++) {
     if (sent >= numMsgs) return;
+    localNbr = (myHandle+1) % numObjs;
     elapse(elapseTime);
     if (msgSize == MIX_MS) actualMsgSize = (actualMsgSize + 1) % 3;
     if (actualMsgSize == SMALL) {
@@ -127,7 +120,7 @@ void worker::doWork()
       if (local > 0) local--;
       else localNbr = neighbor;
       POSE_invoke(workSmall(sm), worker, localNbr, 0);
-      //CkPrintf("%d sending small work to %d at %d. Sent=%d\n",myHandle,localNbr,ovt,sent);
+      CkPrintf("%d sending small work to %d at %d. Sent=%d\n",myHandle,localNbr,ovt,sent);
     }
     else if (actualMsgSize == MEDIUM) {
       mm = new MediumWorkMsg;
index 304b5c7c5d705babd7a7299303b5455d7be1755f..ca31f5b044abee591197465b806198f69c26006d 100644 (file)
@@ -71,7 +71,7 @@ main::main(CkArgMsg *m)
     wd->grainSize = grainSize;
     wd->granularity = granularity;
     wd->density = density;
-    wd->msgsPerWork = (lrand48() % 4) + 2;
+    wd->msgsPerWork = 10; //(lrand48() % 4) + 2;
 
     dest = map[i];
     wd->Timestamp(0);