Changeset 2343 for XIOS/dev/dev_ym/XIOS_COUPLING/src/event_client.hpp
- Timestamp:
- 06/29/22 18:19:45 (2 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/dev_ym/XIOS_COUPLING/src/event_client.hpp
r1377 r2343 17 17 void push(int rank, int nbSender, CMessage& msg); 18 18 void send(size_t timeLine, const std::list<int>& sizes, std::list<CBufferOut*>&); 19 20 19 bool isEmpty(void); 21 20 std::list<int> getRanks(void); … … 24 23 int getTypeId(void) { return typeId; } 25 24 25 void setFirst(void) 26 { 27 itRanks=ranks.begin() ; 28 itNbSenders=nbSenders.begin() ; 29 itMessages=messages.begin() ; 30 } 31 32 bool isFirst(void) 33 { 34 return itRanks==ranks.begin() ; 35 } 36 37 void next(void) 38 { 39 itRanks++ ; 40 if (itRanks==ranks.end()) itRanks=ranks.begin() ; 41 itNbSenders++ ; 42 if (itNbSenders==nbSenders.end()) itNbSenders=nbSenders.begin() ; 43 itMessages++ ; 44 if (itMessages==messages.end()) itMessages=messages.begin() ; 45 } 46 47 void remove(void) 48 { 49 auto removedRank = itRanks; 50 itRanks++ ; 51 ranks.erase(removedRank) ; 52 if (itRanks==ranks.end()) itRanks=ranks.begin() ; 53 54 auto removedNbSender = itNbSenders ; 55 itNbSenders++ ; 56 nbSenders.erase(removedNbSender) ; 57 if (itNbSenders==nbSenders.end()) itNbSenders=nbSenders.begin() ; 58 59 auto removedMessage = itMessages ; 60 itMessages++ ; 61 messages.erase(removedMessage) ; 62 if (itMessages==messages.end()) itMessages=messages.begin() ; 63 } 64 65 int getRank(void) { return *itRanks ;} 66 int getNbSender(void) { return *itNbSenders ;} 67 int getSize(void) { return (*itMessages)->size() + headerSize;} 68 void send(size_t timeLine, int size, CBufferOut* buffer) ; 26 69 private: 27 70 int classId; … … 30 73 std::list<int> nbSenders; 31 74 std::list<CMessage*> messages; 75 76 std::list<int>::iterator itRanks; 77 std::list<int>::iterator itNbSenders; 78 std::list<CMessage*>::iterator itMessages; 32 79 }; 33 80 }
Note: See TracChangeset
for help on using the changeset viewer.