fix minor things for VC++
authorGengbin Zheng <gzheng@illinois.edu>
Fri, 13 Jan 2012 15:04:58 +0000 (09:04 -0600)
committerGengbin Zheng <gzheng@illinois.edu>
Fri, 13 Jan 2012 15:04:58 +0000 (09:04 -0600)
tests/converse/commbench/broadcast.c

index 204cfdea893397b07761e127fa3d78273ed64b15..3baf82874815a9e841f27fbf77cf485aa60db446 100644 (file)
@@ -134,12 +134,12 @@ static void reduction_handler(void *msg)
   }
 }
    
+/* on PE 0 */
 static void sync_starter(void *msg) 
 {
   EmptyMsg emsg;    
   ptimemsg tmsg = (ptimemsg)msg;
 
-  CmiAssert(CmiMyPe() == 0);
   double midTime = (CmiWallTimer() + CpvAccess(lasttime))/2;
   CpvAccess(timediff)[CpvAccess(currentPe)] = midTime - tmsg->time;
   CmiFree(msg);
@@ -160,21 +160,21 @@ static void sync_starter(void *msg)
 
 static void sync_reply(void *msg) 
 {
-  CmiFree(msg);
   ptimemsg tmsg = (ptimemsg)CmiAlloc(sizeof(timemsg));
   tmsg->time = CmiWallTimer();
   CmiSetHandler(tmsg, CpvAccess(sync_starter));
   CmiSyncSendAndFree(0, sizeof(timemsg), tmsg);
+  CmiFree(msg);
 }
  
 static void bcast_reply(void *msg)
 {
-  CmiFree(msg);
   ptimemsg tmsg = (ptimemsg)CmiAlloc(sizeof(timemsg));
   tmsg->time = CmiWallTimer();
   tmsg->srcpe = CmiMyPe();
   CmiSetHandler(tmsg, CpvAccess(bcast_central));
   CmiSyncSendAndFree(0, sizeof(timemsg), tmsg);
+  CmiFree(msg);
 }
 
 static void bcast_central(void *msg)