Revised and working ring.
authorTerry L. Wilmarth <wilmarth@uiuc.edu>
Thu, 10 Feb 2005 18:03:29 +0000 (18:03 +0000)
committerTerry L. Wilmarth <wilmarth@uiuc.edu>
Thu, 10 Feb 2005 18:03:29 +0000 (18:03 +0000)
examples/pose/Ring/Worker.C

index 0c85ab7329fa0e6e74cd2292f54f8aaecae8a963..606f12d5ac1bd08a7e7edfc1008f2428f5c6661a 100644 (file)
@@ -24,16 +24,15 @@ worker::worker(WorkerData *m)
   totalObjs = numObjs * CkNumPes();
   localDensity = ((double)density)/((double)totalObjs);
   delete m;
-  CkPrintf("Worker %d created on PE %d.\n", myHandle, CkMyPe());
 
   SmallWorkMsg *sm = new SmallWorkMsg;
   memset(sm->data, 0, SM_MSG_SZ*sizeof(int));
   sm->fromPE = -1;
-  CkPrintf("Worker %d created on PE %d.\n", myHandle, CkMyPe());
+  //CkPrintf("Worker %d created on PE %d.\n", myHandle, CkMyPe());
   //if (myHandle%numObjs == 0) { //local ring; multiple global rings
   //if (myHandle%(numObjs/2) == 0) { //multiple offset global rings
   //if (myHandle == 0) { 
-  CkPrintf("Worker %d starting ring, sending to self.\n", myHandle);
+  //CkPrintf("Worker %d starting ring, sending to self.\n", myHandle);
   POSE_invoke(workSmall(sm), worker, parent->thisIndex, 0);
   //}
 }
@@ -66,7 +65,7 @@ void worker::terminus()
 
 void worker::workSmall(SmallWorkMsg *m)
 {
-  CkPrintf("%d receiving small work at %d from obj %d\n", parent->thisIndex, ovt, m->fromPE);
+  //CkPrintf("%d receiving small work at %d from obj %d\n", parent->thisIndex, ovt, m->fromPE);
   doWork();
 }
 
@@ -129,7 +128,7 @@ void worker::doWork()
     // local ring
     POSE_invoke(workSmall(sm), worker, ((myHandle%numObjs)+1)%numObjs + (numObjs*CkMyPe()), 0);
     //POSE_invoke(workSmall(sm), worker, (myHandle+1)%totalObjs, 0);
-    CkPrintf("%d sending small work to %d at %d. Sent=%d\n",myHandle,((myHandle%numObjs)+1)%numObjs + (numObjs*CkMyPe()),ovt,sent);
+    //CkPrintf("%d sending small work to %d at %d. Sent=%d\n",myHandle,((myHandle%numObjs)+1)%numObjs + (numObjs*CkMyPe()),ovt,sent);
   }
   else if (actualMsgSize == MEDIUM) {
     mm = new MediumWorkMsg;
@@ -145,6 +144,6 @@ void worker::doWork()
   }
   int elapseCheck = sent * (1.0/localDensity);
   if (OVT() < elapseCheck) elapse(elapseCheck-OVT());
-  CkPrintf("%d sent %d messages out of %d!\n", myHandle, sent, numMsgs);
+  //CkPrintf("%d sent %d messages out of %d!\n", myHandle, sent, numMsgs);
 }