ops, forgot a for loop
authorFilippo Gioachin <gioachin@illinois.edu>
Thu, 16 Sep 2004 03:07:54 +0000 (03:07 +0000)
committerFilippo Gioachin <gioachin@illinois.edu>
Thu, 16 Sep 2004 03:07:54 +0000 (03:07 +0000)
src/conv-com/pipebroadcastconverse.C

index 1932794538d5ffb25b6baf012352a6c5f3bf7827..2ac05aa25022e211e2be6d66aa6f605b81a42af0 100644 (file)
@@ -78,7 +78,10 @@ void PipeBroadcastConverse::propagate(char *env, int isFragmented, int srcPeNumb
     */
 
     //CmiSyncListSend(num_pes, dest_pes, env->getTotalsize(), (char *)env);
-    CmiSyncSend(dest_pes[k], totalSendingSize, env);
+    for (k=0; k<num_pes; ++k) {
+      ComlibPrintf("[%d] PipeBroadcast sending to %d\n",CkMyPe(), dest_pes[k]);
+      CmiSyncSend(dest_pes[k], totalSendingSize, env);
+    }
     //sizeToSend = pipeSize<totalSendingSize ? pipeSize : totalSendingSize;
     //for (k=0; k<num_pes; ++k) CmiSyncSend(dest_pes[k], sizeToSend, env);
     free(dest_pes);