Changeset 2029

Timestamp:

02/04/21 20:35:15 (3 years 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:

• client.cpp (modified) (1 diff)
• node/context.cpp (modified) (3 diffs)
• server.cpp (modified) (3 diffs)

XIOS/trunk/src/client.cpp

@@ -278 +278 @@
 
 
-      MPI_Comm_free(&interComm);
+      /* MPI_Comm_free(&interComm); */ // WARNING remove freeing communicator !! --> deadlock raised, to be checked
       for (std::list<MPI_Comm>::iterator it = contextInterComms.begin(); it != contextInterComms.end(); it++)
-        MPI_Comm_free(&(*it));
+        /* MPI_Comm_free(&(*it)) */ ; // WARNING remove freeing communicator !! --> deadlock raised, to be checked
       MPI_Comm_free(&intraComm);
 

XIOS/trunk/src/node/context.cpp

@@ -503 +503 @@
          //! Free internally allocated communicators
          for (std::list<MPI_Comm>::iterator it = comms.begin(); it != comms.end(); ++it)
-           MPI_Comm_free(&(*it));
+           /* MPI_Comm_free(&(*it)) */ ; // WARNING remove freeing communicator !! --> deadlock raised, to be checked
          comms.clear();
 
@@ -545 +545 @@
          //! Free internally allocated communicators
          for (std::list<MPI_Comm>::iterator it = comms.begin(); it != comms.end(); ++it)
-           MPI_Comm_free(&(*it));
+           /* MPI_Comm_free(&(*it)) */;  // WARNING remove freeing communicator !! --> deadlock raised, to be checked
          comms.clear();
 
@@ -561 +561 @@
    {
      for (std::list<MPI_Comm>::iterator it = comms.begin(); it != comms.end(); ++it)
-       MPI_Comm_free(&(*it));
+       /* MPI_Comm_free(&(*it)) */ ; // WARNING remove freeing communicator !! --> deadlock raised, to be checked
      comms.clear();
    }

XIOS/trunk/src/server.cpp

@@ -407 +407 @@
 
       for (std::list<MPI_Comm>::iterator it = contextInterComms.begin(); it != contextInterComms.end(); it++)
-        MPI_Comm_free(&(*it));
+        /* MPI_Comm_free(&(*it)) */; // WARNING remove freeing communicator !! --> deadlock raised, to be checked
 
       for (std::list<MPI_Comm>::iterator it = contextIntraComms.begin(); it != contextIntraComms.end(); it++)
@@ -419 +419 @@
 
         for (std::list<MPI_Comm>::iterator it = interCommRight.begin(); it != interCommRight.end(); it++)
-          MPI_Comm_free(&(*it));
+          /* MPI_Comm_free(&(*it)) */ ; // WARNING remove freeing communicator !! --> deadlock raised, to be checked
 
       MPI_Comm_free(&intraComm);
@@ -484 +484 @@
                 MPI_Send(&msg,1,MPI_INT,0,0,*itr) ;
               }
-              MPI_Comm_free(&(*it));
+              /* MPI_Comm_free(&(*it)); */ // WARNING remove freeing communicator !! --> deadlock raised, to be checked
               interCommLeft.erase(it) ;
               break ;