doc: Add serial to list of ci file reserved words
[charm.git] / src / ck-com / OneTimeMulticastStrategy.C
index 19c57f26a4755d949438cf491ccab7c3a91cfbb3..d7a0882e5948f357f37c707c38d5296de1dca59e 100644 (file)
@@ -86,8 +86,9 @@ void OneTimeMulticastStrategy::insertMessage(CharmMessageHolder *cmsg){
 void OneTimeMulticastStrategy::localMulticast(CharmMessageHolder *cmsg) {
   double start = CmiWallTimer();
   CkSectionID *sec_id = cmsg->sec_id;
-  CkVec< CkArrayIndexMax > localIndices;
-  sinfo.getLocalIndices(sec_id->_nElems, sec_id->_elems, sec_id->_cookie.aid, localIndices);
+  CkVec< CkArrayIndex > localIndices;
+  CkArrayID aid(sec_id->_cookie.get_aid());
+  sinfo.getLocalIndices(sec_id->_nElems, sec_id->_elems, aid, localIndices);
   deliverToIndices(cmsg->getCharmMessage(), localIndices );
   traceUserBracketEvent(10000, start, CmiWallTimer());
 }
@@ -113,7 +114,7 @@ void OneTimeMulticastStrategy::remoteMulticast(ComlibMulticastMsg * multMsg, boo
   
   // Find my index in the list of all destination PEs
   if(rootPE){
-    CkAssert(CkMyPe() == multMsg->_cookie.pe);
+    CkAssert(CkMyPe() == multMsg->_cookie.get_pe());
     myIndex = -1;
   } else {
     for (int i=0; i<totalDestPEs; ++i) {
@@ -132,7 +133,7 @@ void OneTimeMulticastStrategy::remoteMulticast(ComlibMulticastMsg * multMsg, boo
 
   if(totalDestPEs > 0) {
     //CkPrintf("totalDestPEs = %d\n", totalDestPEs);
-    determineNextHopPEs(totalDestPEs, multMsg->indicesCount, myIndex, multMsg->_cookie.pe, pelist, npes );
+    determineNextHopPEs(totalDestPEs, multMsg->indicesCount, myIndex, multMsg->_cookie.get_pe(), pelist, npes );
   } else {
     npes = 0;
   }
@@ -151,7 +152,7 @@ void OneTimeMulticastStrategy::remoteMulticast(ComlibMulticastMsg * multMsg, boo
   
 
   CmiSetHandler(env, CkpvAccess(comlib_handler));
-  ((CmiMsgHeaderBasic *) env)->stratid = getInstance();  
+  ((CmiMsgHeaderExt *) env)->stratid = getInstance();  
   CkPackMessage(&env);
 
   double middle = CmiWallTimer();
@@ -196,7 +197,7 @@ void OneTimeMulticastStrategy::handleMessage(void *msg){
   // Deliver to objects marked as local in the message
   int localElems;
   envelope *newenv;
-  CkArrayIndexMax *local_idx_list;  
+  CkArrayIndex *local_idx_list;  
   sinfo.unpack(env, localElems, local_idx_list, newenv);
   ComlibMulticastMsg *newmsg = (ComlibMulticastMsg *)EnvToUsr(newenv);  
 
@@ -307,7 +308,7 @@ void OneTimeTreeMulticastStrategy::determineNextHopPEs(const int totalDestPEs, c
 int getFirstPeOnPhysicalNodeFromList(int pe, const int totalDestPEs, const ComlibMulticastIndexCount* destPEs){
   int num;
   int *nodePeList;
-  CmiGetPesOnPhysicalNode(pe, &nodePeList, &num);
+  CmiGetPesOnPhysicalNode(CmiPhysicalNodeID(pe), &nodePeList, &num);
   
   for(int i=0;i<num;i++){
     // Scan destPEs for the pe
@@ -330,7 +331,7 @@ int getFirstPeOnPhysicalNodeFromList(int pe, const int totalDestPEs, const Comli
 int getNthPeOnPhysicalNodeFromList(int n, int pe, const int totalDestPEs, const ComlibMulticastIndexCount* destPEs){
   int num;
   int *nodePeList;
-  CmiGetPesOnPhysicalNode(pe, &nodePeList, &num);
+  CmiGetPesOnPhysicalNode(CmiPhysicalNodeID(pe), &nodePeList, &num);
   
   int count = 0;
   int lastFound = -1;
@@ -365,7 +366,7 @@ vector<int> getPesOnPhysicalNodeFromList(int pe, const int totalDestPEs, const C
  
   int num; 
   int *nodePeList; 
-  CmiGetPesOnPhysicalNode(pe, &nodePeList, &num); 
+  CmiGetPesOnPhysicalNode(CmiPhysicalNodeID(pe), &nodePeList, &num); 
   
   for(int i=0;i<num;i++){ 
     // Scan destPEs for the pe 
@@ -392,7 +393,7 @@ vector<int> getOtherPesOnPhysicalNodeFromList(int pe, const int totalDestPEs, co
 
   int num;
   int *nodePeList;
-  CmiGetPesOnPhysicalNode(pe, &nodePeList, &num);
+  CmiGetPesOnPhysicalNode(CmiPhysicalNodeID(pe), &nodePeList, &num);
   
   for(int i=0;i<num;i++){
     // Scan destPEs for the pe
@@ -936,7 +937,7 @@ void OneTimeTopoTreeMulticastStrategy::determineNextHopPEs(const int totalDestPE
         tree.push_back( topo::SpanningTreeVertex(destPEs[i].pe) );
 
     /// Build the complete spanning tree
-    topo::buildSpanningTree(tree.begin(),tree.end(),degree,topo::getSpanningTreeStrategy<std::vector<topo::SpanningTreeVertex>::iterator>());
+    topo::buildSpanningTree(tree.begin(),tree.end(),degree);
 
     /// Identify this PE in the tree and find immediate children
     int peIdx = -1;