Skip to content
Snippets Groups Projects
Commit 39c3cb84 authored by William F Godoy's avatar William F Godoy
Browse files

Fixing DataMan conflict name

parent de7d5d20
No related branches found
No related tags found
1 merge request!294Bp1read : Initial Reading Capabilities and latest API
...@@ -24,10 +24,12 @@ DataMan::DataMan(MPI_Comm mpiComm, const bool debugMode) ...@@ -24,10 +24,12 @@ DataMan::DataMan(MPI_Comm mpiComm, const bool debugMode)
: TransportMan(mpiComm, debugMode) : TransportMan(mpiComm, debugMode)
{ {
} }
void DataMan::OpenWANTransports(const std::string &name, const Mode openMode, void DataMan::OpenWANTransports(const std::string &name, const Mode mode,
const std::vector<Params> &parametersVector, const std::vector<Params> &parametersVector,
const bool profile) const bool profile)
{ {
size_t counter = 0;
for (const auto &parameters : parametersVector) for (const auto &parameters : parametersVector)
{ {
std::shared_ptr<Transport> wanTransport, controlTransport; std::shared_ptr<Transport> wanTransport, controlTransport;
...@@ -73,18 +75,19 @@ void DataMan::OpenWANTransports(const std::string &name, const Mode openMode, ...@@ -73,18 +75,19 @@ void DataMan::OpenWANTransports(const std::string &name, const Mode openMode,
controlTransport = std::make_shared<transport::WANZmq>( controlTransport = std::make_shared<transport::WANZmq>(
ipAddress, portControl, m_MPIComm, m_DebugMode); ipAddress, portControl, m_MPIComm, m_DebugMode);
wanTransport->Open(messageName, openMode); wanTransport->Open(messageName, mode);
m_Transports.emplace(counter, std::move(wanTransport)); m_Transports.emplace(counter, std::move(wanTransport));
controlTransport->Open(messageName, openMode); controlTransport->Open(messageName, mode);
m_ControlTransports.push_back(std::move(controlTransport)); m_ControlTransports.push_back(std::move(controlTransport));
if (openMode == OpenMode::Read) if (mode == Mode::Read)
{ {
m_Listening = true; m_Listening = true;
m_ControlThreads.push_back(std::thread(&DataMan::ReadThread, m_ControlThreads.push_back(std::thread(&DataMan::ReadThread,
this, wanTransport, this, wanTransport,
controlTransport)); controlTransport));
} }
++counter;
#else #else
throw std::invalid_argument( throw std::invalid_argument(
......
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