Loading testing/adios2/engine/dataman/TestDataMan.h +8 −2 Original line number Diff line number Diff line Loading @@ -172,13 +172,18 @@ void UserCallBack1(void *data, const std::string &doid, const std::string &var, size_t varsize = std::accumulate(varshape.begin(), varshape.end(), 1, std::multiplies<std::size_t>()); size_t dumpsteps = 10; size_t dumpsize = 128; if (varsize < dumpsize) { dumpsize = varsize; } std::cout << "Printing data for the first " << dumpsize << " elements: "; if (step < dumpsteps) { std::cout << "Printing data for the first " << dumpsize << " elements: "; #define declare_type(T) \ if (dtype == adios2::helper::GetType<T>()) \ Loading @@ -192,6 +197,7 @@ void UserCallBack1(void *data, const std::string &doid, const std::string &var, ADIOS2_FOREACH_TYPE_1ARG(declare_type) #undef declare_type } } void DataManWriter(const Dims &shape, const Dims &start, const Dims &count, const size_t steps, const adios2::Params &engineParams, Loading testing/adios2/engine/dataman/TestDataManP2P2DMemSelect.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -359,7 +359,7 @@ TEST_F(DataManEngineTest, WriteRead_2D_MemSelect) size_t steps = 1; adios2::Params engineParams = {{"WorkflowMode", "p2p"}}; std::vector<adios2::Params> transportParams = {{ {"Library", "ZMQ"}, {"IPAddress", "127.0.0.1"}, {"Port", "12322"}, {"Library", "ZMQ"}, {"IPAddress", "127.0.0.1"}, {"Port", "12312"}, }}; // run workflow auto r = Loading testing/adios2/engine/dataman/TestDataManP2P3DMemSelect.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -200,7 +200,7 @@ TEST_F(DataManEngineTest, WriteRead_3D_MemSelect) size_t steps = 1; adios2::Params engineParams = {{"WorkflowMode", "p2p"}}; std::vector<adios2::Params> transportParams = {{ {"Library", "ZMQ"}, {"IPAddress", "127.0.0.1"}, {"Port", "12322"}, {"Library", "ZMQ"}, {"IPAddress", "127.0.0.1"}, {"Port", "12313"}, }}; // run workflow auto r = Loading Loading
testing/adios2/engine/dataman/TestDataMan.h +8 −2 Original line number Diff line number Diff line Loading @@ -172,13 +172,18 @@ void UserCallBack1(void *data, const std::string &doid, const std::string &var, size_t varsize = std::accumulate(varshape.begin(), varshape.end(), 1, std::multiplies<std::size_t>()); size_t dumpsteps = 10; size_t dumpsize = 128; if (varsize < dumpsize) { dumpsize = varsize; } std::cout << "Printing data for the first " << dumpsize << " elements: "; if (step < dumpsteps) { std::cout << "Printing data for the first " << dumpsize << " elements: "; #define declare_type(T) \ if (dtype == adios2::helper::GetType<T>()) \ Loading @@ -192,6 +197,7 @@ void UserCallBack1(void *data, const std::string &doid, const std::string &var, ADIOS2_FOREACH_TYPE_1ARG(declare_type) #undef declare_type } } void DataManWriter(const Dims &shape, const Dims &start, const Dims &count, const size_t steps, const adios2::Params &engineParams, Loading
testing/adios2/engine/dataman/TestDataManP2P2DMemSelect.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -359,7 +359,7 @@ TEST_F(DataManEngineTest, WriteRead_2D_MemSelect) size_t steps = 1; adios2::Params engineParams = {{"WorkflowMode", "p2p"}}; std::vector<adios2::Params> transportParams = {{ {"Library", "ZMQ"}, {"IPAddress", "127.0.0.1"}, {"Port", "12322"}, {"Library", "ZMQ"}, {"IPAddress", "127.0.0.1"}, {"Port", "12312"}, }}; // run workflow auto r = Loading
testing/adios2/engine/dataman/TestDataManP2P3DMemSelect.cpp +1 −1 Original line number Diff line number Diff line Loading @@ -200,7 +200,7 @@ TEST_F(DataManEngineTest, WriteRead_3D_MemSelect) size_t steps = 1; adios2::Params engineParams = {{"WorkflowMode", "p2p"}}; std::vector<adios2::Params> transportParams = {{ {"Library", "ZMQ"}, {"IPAddress", "127.0.0.1"}, {"Port", "12322"}, {"Library", "ZMQ"}, {"IPAddress", "127.0.0.1"}, {"Port", "12313"}, }}; // run workflow auto r = Loading