Changeset 2525

Timestamp:

06/27/23 11:08:52 (12 months ago)

Author:

jderouillat

Message:

Use a list<CRequest*> in the one-sided protocol to handle safely the nonblocking communication associated to CRequest

Location:

XIOS3/branches/xios-3.0-beta/src/transport

Files:

• one_sided_context_server.cpp (modified) (2 diffs)
• one_sided_context_server.hpp (modified) (1 diff)

XIOS3/branches/xios-3.0-beta/src/transport/one_sided_context_server.cpp

@@ -102 +102 @@
       if (flag==true)
       {
-        requests_.push_back(CRequest(interCommMerged_, 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 ;

XIOS3/branches/xios-3.0-beta/src/transport/one_sided_context_server.hpp

@@ -106 +106 @@
       MPI_Request processEventRequest_ ;
 
-      std::list<CRequest> requests_ ;
+      std::list<CRequest*> requests_ ;
 
       std::map<size_t, SPendingEvent> pendingEvents_   ;