Changeset 2526 for XIOS3/trunk/src/transport/one_sided_context_server.cpp

Timestamp:

06/29/23 11:17:44 (12 months ago)

Author:

jderouillat

Message:

Backport intracommunicator probing and a nonblocking communication fix for the one_sided protocol (2524-2525) in trunk

File:

• XIOS3/trunk/src/transport/one_sided_context_server.cpp (modified) (2 diffs)

XIOS3/trunk/src/transport/one_sided_context_server.cpp

@@ -98 +98 @@
     {
       traceOff();
-      MPI_Iprobe(MPI_ANY_SOURCE, 20,interComm, &flag, &status);
+      MPI_Iprobe(MPI_ANY_SOURCE, 20,interCommMerged_, &flag, &status);
       traceOn();
       if (flag==true)
       {
-        requests_.push_back(CRequest(interComm, status)) ;
-        if (requests_.back().test()) 
+        requests_.push_back(new CRequest(interCommMerged_, status)) ;
+        if (requests_.back()->test()) 
         {
-          processRequest(requests_.back()) ;
+          processRequest(*(requests_.back())) ;
+          delete requests_.back();
           requests_.pop_back() ;
         }
@@ -117 +118 @@
     while (it != requests_.end())
     {
-      if (it->test())
-      {
-        processRequest(*it) ;
+      if ((*it)->test())
+      {
+        processRequest(*(*it)) ;
+        delete (*it);
         auto it2=it ;
         ++it ;