Changeset 1934 for XIOS/dev/dev_ym/XIOS_COUPLING/src/distribution

Timestamp:

09/16/20 18:34:23 (4 years ago)

Author:

ymipsl

Message:

Big update on on going work related to data distribution and transfer between clients and servers.
Revisite of the source and store filter using "connectors".

-> inputs work again

YM

File:

• XIOS/dev/dev_ym/XIOS_COUPLING/src/distribution/grid_scatterer_connector.hpp (modified) (2 diffs)

XIOS/dev/dev_ym/XIOS_COUPLING/src/distribution/grid_scatterer_connector.hpp

@@ -68 +68 @@
       {
         list<CMessage> messages;
-        for(auto ranksData : dataOut)
+        for(auto& ranksData : dataOut)
         {
           int rank = ranksData.first ;
@@ -78 +78 @@
         }
         client->sendEvent(event) ;
-      }
- 
+      } 
+      
+      void transfer(CContextClient* client, CEventClient& event, const CMessage& messageHeader)
+      {
+        list<CMessage> messages;
+        for(auto& it : nbSenders_)
+        {
+          int rank = it.first ;
+          auto& nbSender = it.second ;
+
+          messages.push_back(CMessage(messageHeader));
+          event.push(rank, nbSenders_[rank], messages.back());
+        }
+        client->sendEvent(event) ;
+      }  
   };
 }