Tests: Add CmiInitMsgHeader calls for non-CmiAlloc message allocations 94/5094/3
authorNitin Bhat <nbhat4@illinois.edu>
Mon, 15 Apr 2019 21:28:56 +0000 (16:28 -0500)
committerNitin Bhat <nbhat4@illinois.edu>
Tue, 16 Apr 2019 14:01:15 +0000 (09:01 -0500)
Change-Id: If269b7c43738c5ff05bb26c88187f47c5f4bf9a8

17 files changed:
tests/ampi/speed/hello.C
tests/converse/commbench/broadcast.c
tests/converse/commbench/commbench.c
tests/converse/commbench/flood.c
tests/converse/commbench/memoryAccess.c
tests/converse/commbench/overhead.c
tests/converse/commbench/pingpong-cachemiss.c
tests/converse/commbench/pingpong.c
tests/converse/commbench/proc.c
tests/converse/commbench/reduction.c
tests/converse/commbench/smputil.c
tests/converse/commbench/timer.c
tests/converse/megacon/broadc.c
tests/converse/megacon/deadlock.c
tests/converse/megacon/multicast.c
tests/converse/megacon/multisend.c
tests/converse/megacon/ringsimple.c

index 614cd203f3aae5732f11f1a281f1d3e4789014a4..f938e3c8324ff46272fc62913fb331b26871d077 100644 (file)
@@ -136,6 +136,7 @@ struct conv_start_msg {
 /** Called on processor 0 to initiate the test */
 void convCommTest(int isLocal) {
        conv_start_msg m;
+       CmiInitMsgHeader(m.hdr, sizeof(struct conv_start_msg));
        CmiSetHandler(&m,CpvAccess(conv_kicker_idx));
        m.isLocal=isLocal;
        CmiSyncBroadcastAllFn(sizeof(m),(char *)&m);
index 45842eba38a459fbda4e3b25f12ee37b96f3b8be..1b3ddc9a9f0bbacc182f558e9754f1530193b495 100644 (file)
@@ -105,6 +105,7 @@ static void reduction_handler(void* msg) {
   int i = 0;
   int idx = CpvAccess(nextidx);
   EmptyMsg emsg;
+  CmiInitMsgHeader(emsg.core, sizeof(EmptyMsg));
 
   sizes[idx].time = CmiWallTimer() - CpvAccess(starttime);
   CmiFree(msg);
@@ -134,6 +135,7 @@ static void reduction_handler(void* msg) {
 /* on PE 0 */
 static void sync_starter(void* msg) {
   EmptyMsg emsg;
+  CmiInitMsgHeader(emsg.core, sizeof(EmptyMsg));
   ptimemsg tmsg = (ptimemsg)msg;
 
   double midTime = (CmiWallTimer() + CpvAccess(lasttime)) / 2;
@@ -173,6 +175,7 @@ static void bcast_reply(void* msg) {
 
 static void bcast_central(void* msg) {
   EmptyMsg emsg;
+  CmiInitMsgHeader(emsg.core, sizeof(EmptyMsg));
   ptimemsg tmsg = (ptimemsg)msg;
   CmiAssert(CmiMyPe() == 0);
   if (CpvAccess(currentPe) == 0) {
index 01b1ce92db0d5f3deb44503ae7f357cb7a611767..88f0c0549b0183fe2288e5975f5ba6b5b9f20655 100644 (file)
@@ -99,6 +99,7 @@ int commbench_skip(const char* test) {
 void commbench_next() {
   int idx, bank;
   EmptyMsg msg;
+  CmiInitMsgHeader(msg.core, sizeof(EmptyMsg));
 
   bank = CpvAccess(test_bank_size);
 nextidx:
index bda7744b09826b2e8d712b28db0e7d366e379fe1..66403d92da92c868660b1fdbd2ce980d1999a601 100644 (file)
@@ -90,6 +90,7 @@ static void recvTime(TimeMessage* msg) {
   int i, j;
   double time;
 
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   pva(numRecv)++;
   for (i = 0; i < CmiNumPes(); i++) {
     if (i == msg->srcNode) continue;
@@ -136,6 +137,7 @@ static void recvTime(TimeMessage* msg) {
 
 static void startNextNode(EmptyMsg* msg) {
   EmptyMsg m;
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   CmiFree(msg);
   if ((CmiMyPe() + 1) != CmiNumPes()) {
     CmiSetHandler(&m, pva(nbrHandler));
@@ -148,6 +150,7 @@ static void startNextNbr(EmptyMsg* msg) {
   TimeMessage* tm;
   int i, size;
 
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   CmiFree(msg);
   pva(nextNbr)++;
   if (pva(nextNbr) == CmiMyPe()) {
@@ -177,6 +180,8 @@ static void startNextSize(EmptyMsg* msg) {
   EmptyMsg m;
   Message* mm;
   int num;
+
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   pva(nextSize)++;
   if (pva(nextSize) == pva(numSizes)) {
     pva(nextSize) = -1;
@@ -200,6 +205,7 @@ static void startNextSize(EmptyMsg* msg) {
 
 static void startNextIter(Message* msg) {
   EmptyMsg m;
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
 
   msg->iter += 1;
 
@@ -231,6 +237,7 @@ static void bounceMessage(Message* msg) {
 
 void flood_init(void) {
   EmptyMsg m;
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
 
   if (CmiNumPes() == 1) {
     CmiPrintf("[flood] This benchmark requires > 1 nodes.\n");
index 6e0f6a7925e8074854f9a77e4d74fdf313309d01..a985ed7327d93d8fae32fbfcae371d0d69bbd235 100644 (file)
@@ -192,6 +192,7 @@ static void memoryHandler(EmptyMsg* msg) {
 
 void memoryAccess_init(void) {
   EmptyMsg msg;
+  CmiInitMsgHeader(msg.core, sizeof(EmptyMsg));
 
   CmiPrintf("Single core malloc/free/traversal performance numbers\n");
   memoryTest();
index 5b9c348a98ed4ab1a632b92e9931bfa603aed741..00b9677eb1add188335a9b466e9022215ff2a17a 100644 (file)
@@ -127,6 +127,7 @@ static void enqueue_handler(void* msg) {
   int idx = CpvAccess(nextidx);
   EmptyMsg emsg;
 
+  CmiInitMsgHeader(emsg.core, sizeof(EmptyMsg));
   CpvAccess(numiter)++;
   if (CpvAccess(numiter) < sizes[idx].numiter) {
     CsdEnqueue(msg);
index 8946b99aa41d88513481e5569da57ee195fdce6a..481ef6c8ed878f1914de23fdc34232f56124e412 100644 (file)
@@ -91,6 +91,7 @@ static void recvTime(TimeMessage* msg) {
   int i, j;
   double time;
 
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   pva(numRecv)++;
   for (i = 0; i < CmiNumNodes(); i++) {
     if (i == msg->srcNode) continue;
@@ -133,6 +134,7 @@ static void recvTime(TimeMessage* msg) {
 
 static void startNextNode(EmptyMsg* msg) {
   EmptyMsg m;
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   CmiFree(msg);
   if ((CmiMyNode() + 1) != CmiNumNodes()) {
     CmiSetHandler(&m, pva(nbrHandler));
@@ -147,6 +149,7 @@ static void startNextNbr(EmptyMsg* msg) {
 
   /* CmiAssert(CmiMyPe()==0); */
 
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   CmiFree(msg);
   pva(nextNbr)++;
   if (pva(nextNbr) == CmiMyNode()) {
@@ -179,6 +182,7 @@ static void startNextSize(EmptyMsg* msg) {
 
   /* CmiAssert(CmiMyPe()==0); */
 
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   pva(nextSize)++;
   if (pva(nextSize) == pva(numSizes)) {
     pva(nextSize) = -1;
@@ -210,6 +214,8 @@ static void startNextIter(Message* msg) {
   EmptyMsg m;
   Message* mm;
   pva(nextIter)++;
+
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   if (pva(nextIter) >= sizes[pva(nextSize)].numiter) {
     pva(endtime) = CmiWallTimer();
     /* checkMessage(msg); */
@@ -299,6 +305,7 @@ static void startMessage(Message* msg) {
 
 void pingpong_cachemiss_init(void) {
   EmptyMsg m;
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
 
   if (CmiNumNodes() == 1) {
     CmiPrintf("[pingpong] This benchmark requires > 1 nodes.\n");
index 8d1f9799cb2fbc91cc3d584898fa33cbd5ec23cf..d59bd9b9c3d368c734aaa057300afc176414c9ca 100644 (file)
@@ -83,6 +83,7 @@ static void recvTime(TimeMessage* msg) {
   int i, j;
   double time;
 
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   pva(numRecv)++;
   for (i = 0; i < CmiNumPes(); i++) {
     if (i == msg->srcNode) continue;
@@ -121,6 +122,7 @@ static void recvTime(TimeMessage* msg) {
 
 static void startNextNode(EmptyMsg* msg) {
   EmptyMsg m;
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   CmiFree(msg);
   if ((CmiMyPe() + 1) != CmiNumPes()) {
     CmiSetHandler(&m, pva(nbrHandler));
@@ -133,6 +135,7 @@ static void startNextNbr(EmptyMsg* msg) {
   TimeMessage* tm;
   int i, size;
 
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   CmiFree(msg);
   pva(nextNbr)++;
   if (pva(nextNbr) == CmiMyPe()) {
@@ -162,6 +165,7 @@ static void startNextSize(EmptyMsg* msg) {
   EmptyMsg m;
   Message* mm;
 
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   pva(nextSize)++;
   if (pva(nextSize) == pva(numSizes)) {
     pva(nextSize) = -1;
@@ -183,6 +187,7 @@ static void startNextSize(EmptyMsg* msg) {
 static void startNextIter(Message* msg) {
   EmptyMsg m;
 
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   pva(nextIter)++;
   if (pva(nextIter) > sizes[pva(nextSize)].numiter) {
     pva(endtime) = CmiWallTimer();
@@ -208,6 +213,7 @@ static void bounceMessage(Message* msg) {
 void pingpong_init(void) {
   EmptyMsg m;
 
+  CmiInitMsgHeader(m.core, sizeof(EmptyMsg));
   if (CmiNumPes() == 1) {
     CmiPrintf("[pingpong] This benchmark requires > 1 nodes.\n");
     CmiSetHandler(&m, pva(ack_handler));
index c95eaf40e0caffe4642365ae058d575b3763beba..9c9d664ba03cf8c30f066f9274208412d54ce209 100644 (file)
@@ -42,6 +42,7 @@ static int iround(double x) { return (int)(ceil(2.0 * x) / 2.0); }
 static void collectNumbers(ProcMsg* msg) {
   int npes;
   EmptyMsg emsg;
+  CmiInitMsgHeader(emsg.core, sizeof(EmptyMsg));
 
   if (CpvAccess(isSingle)) {
     CpvAccess(Time1) = CmiWallTimer() - CpvAccess(Time1);
@@ -77,6 +78,7 @@ static void collectNumbers(ProcMsg* msg) {
 
 void proc_init(void) {
   ProcMsg msg;
+  CmiInitMsgHeader(msg.core, sizeof(EmptyMsg));
 
   CpvAccess(isSingle) = 1;
   msg.success = NTRIALS;
index de488ff33e3f7c1ab6395a7ff8441c4081cb4ec0..ec7548eccbf64a5bb73c0719833cdf75135c7f09 100644 (file)
@@ -118,6 +118,8 @@ static void reduction_starter(void* msg) {
 
 static void reduction_handler(void* msg) {
   EmptyMsg emsg;
+  CmiInitMsgHeader(emsg.core, sizeof(EmptyMsg));
+
   CpvAccess(endtime) = CmiWallTimer();
 
   CmiFree(msg);
@@ -128,6 +130,8 @@ static void reduction_handler(void* msg) {
 static void reduction_central(void* msg) {
   EmptyMsg emsg;
   ptimemsg tmsg = (ptimemsg)msg;
+
+  CmiInitMsgHeader(emsg.core, sizeof(EmptyMsg));
   if (CpvAccess(currentPe) == 0) {
     CpvAccess(lasttime) =
       CpvAccess(endtime) - tmsg->time - CpvAccess(timediff)[tmsg->srcpe];
@@ -166,6 +170,7 @@ static void sync_starter(void* msg) {
   EmptyMsg emsg;
   ptimemsg tmsg = (ptimemsg)msg;
 
+  CmiInitMsgHeader(emsg.core, sizeof(EmptyMsg));
   double midTime = (CmiWallTimer() + CpvAccess(lasttime)) / 2;
   CpvAccess(timediff)[CpvAccess(currentPe)] = midTime - tmsg->time;
   CmiFree(msg);
@@ -193,6 +198,7 @@ static void sync_reply(void* msg) {
 
 void reduction_init(void) {
   EmptyMsg emsg;
+  CmiInitMsgHeader(emsg.core, sizeof(EmptyMsg));
 
   CmiSetHandler(&emsg, CpvAccess(sync_reply));
   CpvAccess(lasttime) = CmiWallTimer();
index ff2633e09bfc8be7c0541b866f726f7da75ac9c3..a894959c13d4aabea037c0e0e6be7b352cdd676b 100644 (file)
@@ -86,6 +86,7 @@ void smputil_init(void) {
   int i;
   CmiNodeLock lock;
 
+  CmiInitMsgHeader(msg.core, sizeof(EmptyMsg));
   starttime = CmiWallTimer();
   for (i = 0; i < NVARITER; i++)
     ;
index a14a4cf7dbe3904ee5308f1c65c54b345357763f..2fd19706eb1cd2cda96689d9e6ef142ce9120726 100644 (file)
@@ -7,6 +7,7 @@ void timer_init(void) {
   volatile double starttime, endtime;
   int i;
   EmptyMsg msg;
+  CmiInitMsgHeader(msg.core, sizeof(EmptyMsg));
 
   starttime = CmiWallTimer();
   for (i = 0; i < NITER; i++) CmiCpuTimer();
index a5966fe647f2c3efec516374d2c0ca272bf1b14d..3d16eabc818e54e3af27d95a2eb0fb4d63db1688 100644 (file)
@@ -35,6 +35,8 @@ void broadc_recv(mesg m)
 void broadc_start_cycle(bchare c)
 {
   struct mesg_s m={{0},CmiMyPe(),c,0x12345678}; struct mesg_s *mp; CmiCommHandle h;
+
+  CmiInitMsgHeader(m.head, sizeof(struct mesg_s));
   switch (c->totalsent) {
     case 0:
       CmiSetHandler(&m, CpvAccess(broadc_recv_idx));
index c5c611cfe1df93e18fdddf426829dcb785bc4655..5a15e562153d4b531d3465f3204c7b259af9210a 100644 (file)
@@ -40,6 +40,7 @@ void deadlock_cram(char *msg)
 void deadlock_init()
 {
   char msg[CmiMsgHeaderSizeBytes]={0};
+  CmiInitMsgHeader(msg, sizeof(struct incmsg_s));
   if (CmiNumPes()<2) {
     CmiPrintf("warning: need 2 processors for deadlock-test, skipping.\n");
     Cpm_megacon_ack(CpmSend(0));
index b905c278f0bd2dcc8c97475268f028c5cddbe41d..e09722efbf03ef595135f5c2ec7e77561df57317 100644 (file)
@@ -36,6 +36,8 @@ void multicast_recv(mesg m)
 void multicast_start_cycle(bchare c)
 {
   struct mesg_s m={{0},CmiMyPe(),c,0x12345678}; struct mesg_s *mp;
+
+  CmiInitMsgHeader(m.head, sizeof(struct mesg_s));
   switch (c->totalsent) {
     case 0:
       CmiSetHandler(&m, CpvAccess(multicast_recv_idx));
index 940cf4134e18eaec2e74470ca5d828c9a9e8f2b9..7aaf9216d2bed5aec989e67f678895d17edbc05a 100644 (file)
@@ -67,6 +67,7 @@ void multisend_init(void)
     int sizes[nMulti];
     char *msgs[nMulti];
     multisendmsg first; /* Allocate one message on the stack (because you can!) */
+    CmiInitMsgHeader(first.core, sizeof(multisendmsg));
     for (m=0;m<nMulti;m++) {
       multisendmsg *msg;
       if (m==0) msg=&first;
index cd9d9cfef4de75666dc3b8900c612ca6ce020233..b5c92299a5d406290e9091c966646149f72552d6 100644 (file)
@@ -38,6 +38,8 @@ void ringsimple_hop(ringmsg *msg)
 void ringsimple_init(void)
 {
   int i; ringmsg msg={{0},1000,0,{0}};
+
+  CmiInitMsgHeader(msg.core, sizeof(ringmsg));
   for (i=0; i<10; i++) msg.data[i] = i;
   CmiSetHandler(&msg, CpvAccess(ringsimple_hop_index));
   for (i=0; i<entries; i++) {