Changeset 638

Timestamp:

07/17/15 13:58:12 (9 years ago)

Author:

rlacroix

Message:

Add a source filter and two terminal filters.

Location:

XIOS/trunk/src

Files:

• filter/file_writer_filter.cpp (added)
• filter/file_writer_filter.hpp (added)
• filter/source_filter.cpp (added)
• filter/source_filter.hpp (added)
• filter/store_filter.cpp (added)
• filter/store_filter.hpp (added)
• node/field.cpp (modified) (2 diffs)
• node/field.hpp (modified) (1 diff)

XIOS/trunk/src/node/field.cpp

@@ -10 +10 @@
 #include "xios_spl.hpp"
 #include "type.hpp"
+#include "timer.hpp"
 #include "context_client.hpp"
 #include "context_server.hpp"
@@ -202 +203 @@
 
     for (list< CArray<double,1>* >::iterator it = list_data.begin(); it != list_data.end(); it++) delete *it;
+  }
+
+  void CField::sendUpdateData(const CArray<double,1>& data)
+  {
+    CTimer::get("XIOS Send Data").resume();
+
+    CContext* context = CContext::getCurrent();
+    CContextClient* client = context->client;
+
+    CEventClient event(getType(), EVENT_ID_UPDATE_DATA);
+
+    map<int, CArray<int,1>* >::iterator it;
+    list<CMessage> list_msg;
+    list<CArray<double,1> > list_data;
+
+    if (!grid->doGridHaveDataDistributed())
+    {
+       if (0 == client->clientRank)
+       {
+          for (it = grid->storeIndex_toSrv.begin(); it != grid->storeIndex_toSrv.end(); it++)
+          {
+            int rank = (*it).first;
+            CArray<int,1>& index = *(it->second);
+
+            list_msg.push_back(CMessage());
+            list_data.push_back(CArray<double,1>(index.numElements()));
+
+            CArray<double,1>& data_tmp = list_data.back();
+            for (int n = 0; n < data_tmp.numElements(); n++) data_tmp(n) = data(index(n));
+
+            list_msg.back() << getId() << data_tmp;
+            event.push(rank, 1, list_msg.back());
+          }
+          client->sendEvent(event);
+       } else client->sendEvent(event);
+    }
+    else
+    {
+      for (it = grid->storeIndex_toSrv.begin(); it != grid->storeIndex_toSrv.end(); it++)
+      {
+        int rank = (*it).first;
+        CArray<int,1>& index = *(it->second);
+
+        list_msg.push_back(CMessage());
+        list_data.push_back(CArray<double,1>(index.numElements()));
+
+        CArray<double,1>& data_tmp = list_data.back();
+        for (int n = 0; n < data_tmp.numElements(); n++) data_tmp(n) = data(index(n));
+
+        list_msg.back() << getId() << data_tmp;
+        event.push(rank, grid->nbSenders[rank], list_msg.back());
+      }
+      client->sendEvent(event);
+    }
+    
+    CTimer::get("XIOS Send Data").suspend();
   }
 

XIOS/trunk/src/node/field.hpp

@@ -139 +139 @@
         static bool dispatchEvent(CEventServer& event) ;
         void sendUpdateData(void) ;
+        void sendUpdateData(const CArray<double,1>& data);
         static void recvUpdateData(CEventServer& event) ;
         void recvUpdateData(vector<int>& ranks, vector<CBufferIn*>& buffers) ;