Changeset 2029


Ignore:
Timestamp:
02/04/21 20:35:15 (6 months ago)
Author:
aclsce
Message:

Commented mpi_comm_free as it was done on branch 2.5 to avoid potential deadlocks.

Location:
XIOS/trunk/src
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • XIOS/trunk/src/client.cpp

    r1866 r2029  
    278278 
    279279 
    280       MPI_Comm_free(&interComm); 
     280      /* MPI_Comm_free(&interComm); */ // WARNING remove freeing communicator !! --> deadlock raised, to be checked 
    281281      for (std::list<MPI_Comm>::iterator it = contextInterComms.begin(); it != contextInterComms.end(); it++) 
    282         MPI_Comm_free(&(*it)); 
     282        /* MPI_Comm_free(&(*it)) */ ; // WARNING remove freeing communicator !! --> deadlock raised, to be checked 
    283283      MPI_Comm_free(&intraComm); 
    284284 
  • XIOS/trunk/src/node/context.cpp

    r1927 r2029  
    503503         //! Free internally allocated communicators 
    504504         for (std::list<MPI_Comm>::iterator it = comms.begin(); it != comms.end(); ++it) 
    505            MPI_Comm_free(&(*it)); 
     505           /* MPI_Comm_free(&(*it)) */ ; // WARNING remove freeing communicator !! --> deadlock raised, to be checked 
    506506         comms.clear(); 
    507507 
     
    545545         //! Free internally allocated communicators 
    546546         for (std::list<MPI_Comm>::iterator it = comms.begin(); it != comms.end(); ++it) 
    547            MPI_Comm_free(&(*it)); 
     547           /* MPI_Comm_free(&(*it)) */;  // WARNING remove freeing communicator !! --> deadlock raised, to be checked 
    548548         comms.clear(); 
    549549 
     
    561561   { 
    562562     for (std::list<MPI_Comm>::iterator it = comms.begin(); it != comms.end(); ++it) 
    563        MPI_Comm_free(&(*it)); 
     563       /* MPI_Comm_free(&(*it)) */ ; // WARNING remove freeing communicator !! --> deadlock raised, to be checked 
    564564     comms.clear(); 
    565565   } 
  • XIOS/trunk/src/server.cpp

    r1639 r2029  
    407407 
    408408      for (std::list<MPI_Comm>::iterator it = contextInterComms.begin(); it != contextInterComms.end(); it++) 
    409         MPI_Comm_free(&(*it)); 
     409        /* MPI_Comm_free(&(*it)) */; // WARNING remove freeing communicator !! --> deadlock raised, to be checked 
    410410 
    411411      for (std::list<MPI_Comm>::iterator it = contextIntraComms.begin(); it != contextIntraComms.end(); it++) 
     
    419419 
    420420        for (std::list<MPI_Comm>::iterator it = interCommRight.begin(); it != interCommRight.end(); it++) 
    421           MPI_Comm_free(&(*it)); 
     421          /* MPI_Comm_free(&(*it)) */ ; // WARNING remove freeing communicator !! --> deadlock raised, to be checked 
    422422 
    423423      MPI_Comm_free(&intraComm); 
     
    484484                MPI_Send(&msg,1,MPI_INT,0,0,*itr) ; 
    485485              } 
    486               MPI_Comm_free(&(*it)); 
     486              /* MPI_Comm_free(&(*it)); */ // WARNING remove freeing communicator !! --> deadlock raised, to be checked 
    487487              interCommLeft.erase(it) ; 
    488488              break ; 
Note: See TracChangeset for help on using the changeset viewer.