Changeset 2343 for XIOS/dev/dev_ym/XIOS_COUPLING/src/event_client.hpp

Timestamp:

06/29/22 18:19:45 (2 years ago)

Author:

ymipsl

Message:

• Implement new infrastructure for transfert protocol.
• new purelly one sided protocol is now available, the previous protocol (legacy, mix send/recv and one sided) is still available. Other specific protocol could be implemented more easilly in future.
• switch can be operate with "transport_protocol" variable in XIOS context :

ex:
<variable id="transport_protocol" type="string">one_sided</variable>

Available protocols are : one_sided, legacy or default. The default protocol is "legacy".

YM

File:

• XIOS/dev/dev_ym/XIOS_COUPLING/src/event_client.hpp (modified) (3 diffs)

XIOS/dev/dev_ym/XIOS_COUPLING/src/event_client.hpp

@@ -17 +17 @@
       void push(int rank, int nbSender, CMessage& msg);
       void send(size_t timeLine, const std::list<int>& sizes, std::list<CBufferOut*>&); 
-
       bool isEmpty(void);
       std::list<int> getRanks(void);
@@ -24 +23 @@
       int getTypeId(void) { return typeId; }
       
+      void setFirst(void)
+      {
+        itRanks=ranks.begin() ;
+        itNbSenders=nbSenders.begin() ;
+        itMessages=messages.begin() ;
+      }
+
+      bool isFirst(void)
+      {
+        return itRanks==ranks.begin() ;
+      }
+
+      void next(void)
+      {
+        itRanks++ ;
+        if (itRanks==ranks.end()) itRanks=ranks.begin() ;
+        itNbSenders++ ;
+        if (itNbSenders==nbSenders.end()) itNbSenders=nbSenders.begin() ;
+        itMessages++ ;
+        if (itMessages==messages.end()) itMessages=messages.begin() ;
+      }
+      
+      void remove(void)
+      {
+        auto removedRank = itRanks;
+        itRanks++ ;
+        ranks.erase(removedRank) ;
+        if (itRanks==ranks.end()) itRanks=ranks.begin() ;
+
+        auto removedNbSender = itNbSenders ;
+        itNbSenders++ ;
+        nbSenders.erase(removedNbSender) ;
+        if (itNbSenders==nbSenders.end()) itNbSenders=nbSenders.begin() ;
+
+        auto removedMessage = itMessages ;
+        itMessages++ ;
+        messages.erase(removedMessage) ;
+        if (itMessages==messages.end()) itMessages=messages.begin() ;
+      }
+
+      int getRank(void) { return *itRanks ;}
+      int getNbSender(void) { return *itNbSenders ;}
+      int getSize(void) { return (*itMessages)->size() + headerSize;}
+      void send(size_t timeLine, int size, CBufferOut* buffer) ;
     private:
       int classId;
@@ -30 +73 @@
       std::list<int> nbSenders;
       std::list<CMessage*> messages;
+      
+      std::list<int>::iterator       itRanks;
+      std::list<int>::iterator       itNbSenders;
+      std::list<CMessage*>::iterator itMessages;
   };
 }