Changeset 1054 for XIOS/dev/dev_olga/src/context_client.hpp
- Timestamp:
- 02/17/17 19:51:36 (8 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/dev_olga/src/context_client.hpp
r1021 r1054 31 31 // Send event to server 32 32 void sendEvent(CEventClient& event); 33 bool sendTemporarilyBufferedEvent(); 33 34 void waitEvent(list<int>& ranks); 34 35 35 // Functions relatesto set/get buffers36 list<CBufferOut*> getBuffers(list<int>& serverlist, list<int>& sizeList);36 // Functions to set/get buffers 37 bool getBuffers(const list<int>& serverList, const list<int>& sizeList, list<CBufferOut*>& retBuffers, bool nonBlocking = false); 37 38 void newBuffer(int rank); 38 39 bool checkBuffers(list<int>& ranks); … … 46 47 47 48 bool isAttachedModeEnabled() const; 49 bool hasTemporarilyBufferedEvent() const { return !tmpBufferedEvent.isEmpty(); }; 48 50 49 51 // Close and finalize context client 50 void closeContext(void); 52 // void closeContext(void); Never been implemented. 51 53 void finalize(void); 52 54 … … 68 70 MPI_Comm intraComm; //!< Communicator of client group 69 71 70 map<int,CClientBuffer*> buffers; //!< Buffers for connection to servers72 map<int,CClientBuffer*> buffers; //!< Buffers for connection to servers 71 73 72 74 private: … … 75 77 //! Maximum number of events that can be buffered 76 78 StdSize maxBufferedEvents; 79 80 struct { 81 std::list<int> ranks, sizes; 82 std::list<CBufferOut*> buffers; 83 84 bool isEmpty() const { return ranks.empty(); }; 85 void clear() { 86 ranks.clear(); 87 sizes.clear(); 88 89 for (std::list<CBufferOut*>::iterator it = buffers.begin(); it != buffers.end(); it++) 90 delete *it; 91 92 buffers.clear(); 93 }; 94 } tmpBufferedEvent; //! Event temporarily buffered (used only on the server) 77 95 78 96 //! Context for server (Only used in attached mode)
Note: See TracChangeset
for help on using the changeset viewer.