verbs: cleanup, remove unnecessary checks
authorBilge Acun <acun2@illinois.edu>
Mon, 28 Oct 2013 19:34:31 +0000 (14:34 -0500)
committerBilge Acun <acun2@illinois.edu>
Mon, 28 Oct 2013 19:34:31 +0000 (14:34 -0500)
src/arch/verbs/machine-ibverbs.c

index 2e6b060a9bdd54fe74ebbcd8f67974e25ea4a926..830ff1cf649cbb853b6b17dd791140df1d1abef6 100644 (file)
@@ -1944,25 +1944,10 @@ static inline void processBufferedBcast(){
                        }
                        start->bcastList[i].valid=0;
                        MACHSTATE3(3,"Buffered broadcast msg %p of size %d being processed at %d",start->bcastList[i].msg,start->bcastList[i].size,i);
-#if CMK_BROADCAST_SPANNING_TREE
-        if (start->bcastList[i].asm_rank == DGRAM_BROADCAST
-#if CMK_NODE_QUEUE_AVAILABLE
-          || start->bcastList[i].asm_rank == DGRAM_NODEBROADCAST
-#endif
-         ){
-               handleOneRecvedMsg(start->bcastList[i].size, start->bcastList[i].msg);
-               CmiFree(start->bcastList[i].msg);           // gzheng 
-                                       }
-#elif CMK_BROADCAST_HYPERCUBE
-        if (start->bcastList[i].asm_rank == DGRAM_BROADCAST
-#if CMK_NODE_QUEUE_AVAILABLE
-          || start->bcastList[i].asm_rank == DGRAM_NODEBROADCAST
-#endif
-         ){
-               handleOneRecvedMsg(start->bcastList[i].size, start->bcastList[i].msg);
-               CmiFree(start->bcastList[i].msg);           // gzheng 
-                                       }
-#endif
+               
+                       handleOneRecvedMsg(start->bcastList[i].size, start->bcastList[i].msg);
+                       CmiFree(start->bcastList[i].msg);           // gzheng 
+               
                }
                if(start->count != 0){
                        MACHSTATE2(3,"]]] start %p start->count %d",start,start->count);