diff --git a/examples/hello/datamanWriter/helloDataManWriter_nompi.cpp b/examples/hello/datamanWriter/helloDataManWriter_nompi.cpp index b7ad9693b85fb6ed380fa17a2f23c8d9613eee4c..c5c68a96b5aa7cffb40eae9cfb52bbde83ae4620 100644 --- a/examples/hello/datamanWriter/helloDataManWriter_nompi.cpp +++ b/examples/hello/datamanWriter/helloDataManWriter_nompi.cpp @@ -32,12 +32,13 @@ int main( int argc, char* argv [] ) //Define variable and local size //Define variable and local size auto& ioMyFloats = adios.DefineVariable<float>( "myfloats", adios::Dims{Nx} ); + auto& ioMyFloat = adios.DefineVariable<float>( "myfloat", adios::Dims{1} ); // auto& ioMyDoubles = adios.DefineVariable<double>( "myDoubles", adios::Dims{Nx} ); // auto& ioMyCFloats = adios.DefineVariable<std::complex<float>>( "myCFloats", {3} ); //Define method for engine creation, it is basically straight-forward parameters adios::Method& datamanSettings = adios.DeclareMethod( "WAN", "DataManWriter" ); //default method type is Writer - datamanSettings.SetParameters( "real_time=yes", "method_type=stream", "method=zmq", "local_ip=127.0.0.1", "remote_ip=127.0.0.1", "local_port=12306", "remote_port=12307" ); + datamanSettings.SetParameters( "real_time=yes", "method_type=stream", "method=dump", "local_ip=127.0.0.1", "remote_ip=127.0.0.1", "local_port=12306", "remote_port=12307" ); // datamanSettings.AddTransport( "Mdtm", "localIP=128.0.0.0.1", "remoteIP=128.0.0.0.2", "tolerances=1,2,3" ); //datamanSettings.AddTransport( "ZeroMQ", "localIP=128.0.0.0.1.1", "remoteIP=128.0.0.0.2.1", "tolerances=1,2,3" ); not yet supported , will throw an exception @@ -49,6 +50,7 @@ int main( int argc, char* argv [] ) throw std::ios_base::failure( "ERROR: failed to create DataMan I/O engine at Open\n" ); datamanWriter->Write( ioMyFloats, myFloats.data() ); // Base class Engine own the Write<T> that will call overloaded Write from Derived + datamanWriter->Write( ioMyFloat, (float) 1.12 ); // Base class Engine own the Write<T> that will call overloaded Write from Derived // datamanWriter->Write( ioMyCFloats, myCFloats.data() ); datamanWriter->Close( ); } diff --git a/include/engine/dataman/DataManWriter.h b/include/engine/dataman/DataManWriter.h index 51247e7d6620f87430911519d0ba18a1765165d4..2d85c1fb1ba00dcdb00219586366cf61e891a290 100644 --- a/include/engine/dataman/DataManWriter.h +++ b/include/engine/dataman/DataManWriter.h @@ -118,12 +118,19 @@ private: jmsg["doid"] = m_Name; jmsg["var"] = variable.m_Name; jmsg["dtype"] = GetType<T>(); + std::cout << "variable.m_Dimensions.size() = " << variable.m_Dimensions.size() << endl; jmsg["putshape"] = variable.m_Dimensions; +// if(variable.m_GlobalDimensions.size() == 0) variable.m_GlobalDimensions = variable.m_Dimensions; jmsg["varshape"] = variable.m_GlobalDimensions; +// if(variable.m_GlobalOffsets.size() == 0) variable.m_GlobalOffsets.assign(variable.m_Dimensions.size(),0); jmsg["offset"] = variable.m_GlobalOffsets; jmsg["timestep"] = 0; m_Man.put(values, jmsg); + std::cout << "putshape " << variable.m_Dimensions.size() << endl; + std::cout << "varshape " << variable.m_GlobalDimensions.size() << endl; + std::cout << "offset " << variable.m_GlobalOffsets.size() << endl; + std::cout << "I am hooked to the DataMan library\n"; MPI_Barrier( m_MPIComm );