Ignore:
Timestamp:
01/11/17 15:14:22 (7 years ago)
Author:
mhnguyen
Message:

Merging working version of coupler

+) Add some changes of domain and axis: Retransfer the atttributes in a generic ways for each level of client (or server)
+) Remove some spoiled files from the previous commits

Test
+) No test

File:
1 edited

Legend:

Unmodified
Added
Removed

  • XIOS/dev/dev_olga/src/node/axis.hpp

    r987 r1025  
    4848           EVENT_ID_INDEX, 
    4949           EVENT_ID_DISTRIBUTED_VALUE, 
    50            EVENT_ID_NON_DISTRIBUTED_VALUE 
     50           EVENT_ID_NON_DISTRIBUTED_VALUE, 
     51           EVENT_ID_NON_DISTRIBUTED_ATTRIBUTES, 
     52           EVENT_ID_DISTRIBUTED_ATTRIBUTES 
    5153         } ; 
    5254 
    … …  
    7678         int getOffsetWrittenIndexes() const; 
    7779 
     80         int getStartWriteIndex() const; 
     81         int getCountWriteIndex() const; 
     82         int getLocalWriteSize() const; 
     83         int getGlobalWriteSize() const; 
     84 
    7885         std::map<int, StdSize> getAttributesBufferSize(); 
    7986 
    … …  
    101108         static ENodeType GetType(void); 
    102109 
    103          void sendServerAttribut(const std::vector<int>& globalDim, int orderPositionInGrid, 
    104                                  CServerDistributionDescription::ServerDistributionType distType); 
     110         // void sendServerAttribut(const std::vector<int>& globalDim, int orderPositionInGrid, 
     111         //                         CServerDistributionDescription::ServerDistributionType distType); 
    105112         static bool dispatchEvent(CEventServer& event); 
    106113         static void recvServerAttribut(CEventServer& event); 
    107          void recvServerAttribut(CBufferIn& buffer) ; 
     114         // void recvServerAttribut(CBufferIn& buffer) ; 
    108115         void checkAttributesOnClient(); 
    109116         void checkAttributesOnClientAfterTransformation(const std::vector<int>& globalDim, int orderPositionInGrid, 
    … …  
    134141         void checkMask(); 
    135142         void checkZoom(); 
    136          void checkBounds(); 
    137          void checkTransformations(); 
    138          void sendValue(); 
     143         void checkBounds();          
     144         void sendAttributes(); 
    139145         void computeConnectedServer(const std::vector<int>& globalDim, int orderPositionInGrid, 
    140146                                     CServerDistributionDescription::ServerDistributionType distType); 
    141          void sendDistributedValue(); 
    142          void sendNonDistributedValue(); 
    143147 
    144          static void recvIndex(CEventServer& event); 
    145          static void recvDistributedValue(CEventServer& event); 
    146          static void recvNonDistributedValue(CEventServer& event); 
    147          void recvIndex(int rank, CBufferIn& buffer); 
    148          void recvDistributedValue(int rank, CBufferIn& buffer); 
    149          void recvNonDistributedValue(int rank, CBufferIn& buffer); 
     148         void sendNonDistributedAttributes(void); 
     149         void sendDistributedAttributes(void); 
     150 
     151         static void recvNonDistributedAttributes(CEventServer& event); 
     152         static void recvDistributedAttributes(CEventServer& event); 
     153         void recvNonDistributedAttributes(int rank, CBufferIn& buffer); 
     154         void recvDistributedAttributes(vector<int>& rank, vector<CBufferIn*> buffers); 
    150155 
    151156         void setTransformations(const TransMapTypes&); 
    … …  
    161166         bool isCompressible_; 
    162167         std::map<int,int> nbConnectedClients_; // Mapping of number of communicating client to a server 
    163          std::map<int, vector<size_t> > indSrv_; // Global index of each client sent to server 
     168         boost::unordered_map<int, vector<size_t> > indSrv_; // Global index of each client sent to server 
    164169         std::map<int, vector<int> > indWrittenSrv_; // Global written index of each client sent to server 
     170         boost::unordered_map<size_t,size_t> globalLocalIndexMap_; 
    165171         std::vector<int> indexesToWrite; 
    166172         int numberWrittenIndexes_, totalNumberWrittenIndexes_, offsetWrittenIndexes_; 
    … …  
    168174         std::map<int, CArray<int,1> > indiSrv_; 
    169175         bool hasBounds_; 
     176 
     177         int start_write_index_; 
     178         int count_write_index_; 
     179         int local_write_size_; 
     180         int global_write_size_; 
    170181 
    171182       private: 
Note: See TracChangeset for help on using the changeset viewer.