Changeset 1930 for XIOS/dev/dev_ym/XIOS_COUPLING/src/distribution/distributed_view.hpp

Timestamp:

09/10/20 13:51:02 (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".

YM

File:

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

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

@@ -15 +15 @@
 
       CDistributedView(CDistributedElement* parent, CElementView::type type, const std::map<int,CArray<int,1>>& indexView) ;
+      CDistributedView(CDistributedElement* parent, CElementView::type type, const std::map<int,CArray<bool,1>>& maskView) ;
       
       std::map<int,CArray<int,1>>&  getIndex(void) { return index_ ;}
@@ -21 +22 @@
       std::map<int, int>& getLocalSize(void) { return localSize_ ;}
       size_t getGlobalSize(void) { return globalSize_ ;}
+
+      void getGlobalIndexView(map<int,CArray<size_t,1>>& globalIndexView)
+      {
+        for(auto& it : globalIndex_)
+        {
+          int rank=it.first ;
+          auto& globalIndex = it.second;
+          auto& globalIndView = globalIndexView[rank] ;
+          auto& index = index_[rank] ;
+          auto& size = size_[rank] ;
+          auto& localSize = localSize_[rank] ;
+          globalIndView.resize(size) ;
+          int pos=0 ;
+          for(int i=0 ; i<size ; i++)
+          {
+            if (index(i)>=0 && index(i)<localSize) 
+            {
+              globalIndView(i) = globalIndex(index(i)) ;
+              pos++ ;
+            }
+          }
+          globalIndView.resizeAndPreserve(pos) ;
+      }
+    }   
 
       void getGlobalIndex(int rank, vector<size_t>& globalIndex, size_t sliceIndex, size_t* sliceSize, CDistributedView** view, int pos)