Skip to content
Snippets Groups Projects
Commit 04a5e5b2 authored by Wang, Ruonan's avatar Wang, Ruonan
Browse files

made changes as requested

parent da08bf5d
No related branches found
No related tags found
1 merge request!270Finished DataMan Transport Manager refactoring but full functionality still pending on Read API
......@@ -108,10 +108,10 @@ void DataManReader::Init()
}
m_Man.OpenWANTransports("zmq", adios2::OpenMode::Read, para, true);
std::string method_type;
int num_channels = 0;
lf_AssignString("method_type", method_type);
lf_AssignInt("num_channels", num_channels);
std::string methodType;
int numChannels = 0;
lf_AssignString("method_type", methodType);
lf_AssignInt("num_channels", numChannels);
}
else
{
......
......@@ -40,7 +40,6 @@ void DataManWriter::DoWriteCommon(Variable<T> &variable, const T *values)
variable.m_Start.assign(variable.m_Count.size(), 0);
}
std::cout << "DoWriteCommon begin" << std::endl;
nlohmann::json jmsg;
jmsg["doid"] = m_Name;
jmsg["var"] = variable.m_Name;
......@@ -53,7 +52,6 @@ void DataManWriter::DoWriteCommon(Variable<T> &variable, const T *values)
std::accumulate(variable.m_Shape.begin(), variable.m_Shape.end(),
sizeof(T), std::multiplies<size_t>());
std::cout << "DoWriteCommon end" << std::endl;
m_Man.WriteWAN(values, jmsg);
if (m_DoMonitor)
......
......@@ -56,7 +56,6 @@ void WANZmq::Open(const std::string &name, const OpenMode openMode)
m_Socket = zmq_socket(m_Context, ZMQ_REQ);
const std::string fullIP("tcp://" + m_IPAddress + ":" + m_Port);
std::cout << "full IP = " << fullIP << std::endl;
int err = zmq_connect(m_Socket, fullIP.c_str());
if (m_Profiler.IsActive)
......@@ -84,7 +83,6 @@ void WANZmq::Open(const std::string &name, const OpenMode openMode)
m_Socket = zmq_socket(m_Context, ZMQ_REP);
const std::string fullIP("tcp://" + m_IPAddress + ":" + m_Port);
std::cout << "full IP = " << fullIP << std::endl;
zmq_bind(m_Socket, fullIP.c_str());
if (m_Profiler.IsActive)
......
......@@ -51,10 +51,10 @@ private:
std::string m_Port;
/** context handler created by zmq, thread safe */
void *m_Context = NULL;
void *m_Context = nullptr;
/** socket handler created by zmq */
void *m_Socket = NULL;
void *m_Socket = nullptr;
};
} // end namespace transport
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment