Changeset 2492 for XIOS3/dev/XIOS_ATTACHED/src
- Timestamp:
- 04/21/23 20:45:21 (15 months ago)
- Location:
- XIOS3/dev/XIOS_ATTACHED/src
- Files:
-
- 2 added
- 3 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS3/dev/XIOS_ATTACHED/src/filter/client_online_reader_filter.hpp
r2491 r2492 1 #ifndef __XIOS_ ONLINE_READER_FILTER__2 #define __XIOS_ ONLINE_READER_FILTER__1 #ifndef __XIOS_CLIENT_ONLINE_READER_FILTER__ 2 #define __XIOS_CLIENT_ONLINE_READER_FILTER__ 3 3 4 4 #include <map> … … 62 62 } // namespace xios 63 63 64 #endif // __XIOS_ ONLINE_READER_FILTER__64 #endif // __XIOS_CLIENT_ONLINE_READER_FILTER__ -
XIOS3/dev/XIOS_ATTACHED/src/node/field.cpp
r2482 r2492 803 803 } 804 804 805 /* 805 806 void CField::connectToOnlineWriter(CGarbageCollector& gc) 806 807 { … … 826 827 } 827 828 } 829 */ 830 void CField::connectToOnlineWriter(CGarbageCollector& gc) 831 { 832 // insert temporal filter before sending to files 833 clientOnlineWriterFilter_ = std::shared_ptr<CClientOnlineWriterFilter>(new CClientOnlineWriterFilter(gc,this)) ; 834 getTemporalDataFilter(gc, fileOut_->output_freq)->connectOutput(clientOnlineReaderFilter_, 0); 835 836 const bool buildGraph_ = !build_workflow_graph.isEmpty() && build_workflow_graph == true ; 837 838 if(buildGraph_) 839 { 840 // to do 841 } 842 } 828 843 829 844 void CField::connectToOnlineReader(CGarbageCollector& gc) -
XIOS3/dev/XIOS_ATTACHED/src/node/field.hpp
r2482 r2492 29 29 #include "file_reader_source_filter.hpp" 30 30 #include "client_online_reader_filter.hpp" 31 #include "client_online_writer_filter.hpp" 31 32 32 33 … … 403 404 std::shared_ptr<CServerToClientStoreFilter> serverToClientStoreFilter_; 404 405 405 //! the filter to redistribute data before to call the fileWriterStoreFilter 406 //! the filter to redistribute data before to call the fileWriterStoreFilter ==> to remove 406 407 std::shared_ptr<CGridRedistributeFilter> redistributeFilter_ ; 407 408 … … 409 410 std::shared_ptr<CClientOnlineReaderFilter> clientOnlineReaderFilter_ ; 410 411 412 //! the filter to connect to online writer 413 std::shared_ptr<CClientOnlineWriterFilter> clientOnlineWriterFilter_ ; 414 415 411 416 }; // class CField 412 417
Note: See TracChangeset
for help on using the changeset viewer.