Commit 70baa4d5 authored by Ruonan Wang's avatar Ruonan Wang
Browse files

modified test parameters for the new handshake mechanism

parent efe04da7
......@@ -238,6 +238,44 @@ MpiHandshake::GetReaderMap(const std::string &filename)
return m_ReadersMap[filename];
}
void MpiHandshake::PrintMaps(const int printRank)
{
if (m_WorldRank == printRank)
{
std::cout << "Writers: " << std::endl;
for (const auto &stream : m_WritersMap)
{
std::cout << " Stream " << stream.first << std::endl;
for (const auto &app : stream.second)
{
std::cout << " App Master Rank " << app.first
<< std::endl;
std::cout << " ";
for (const auto &rank : app.second)
{
std::cout << rank << ", ";
}
std::cout << std::endl;
}
}
std::cout << "Readers: " << std::endl;
for (const auto &stream : m_ReadersMap)
{
std::cout << " Stream " << stream.first << std::endl;
for (const auto &app : stream.second)
{
std::cout << " App Master Rank " << app.first
<< std::endl;
std::cout << " ";
for (const auto &rank : app.second)
{
std::cout << rank << ", ";
}
std::cout << std::endl;
}
}
}
}
void MpiHandshake::PrintMaps()
{
for (int printRank = 0; printRank < m_WorldSize; ++printRank)
......
......@@ -73,6 +73,7 @@ public:
static const std::map<int, std::vector<int>> &
GetReaderMap(const std::string &filename);
static void PrintMaps();
static void PrintMaps(const int printRank);
private:
static void Test();
......
......@@ -500,7 +500,7 @@ void Reader2(const Dims &shape, const Dims &start, const Dims &count,
TEST_F(SscEngineTest, TestSscMultiApp)
{
std::string filename = "TestSscMultiApp";
adios2::Params engineParams = {};
adios2::Params engineParams = {{"RendezvousAppCount", "4"}};
int worldRank, worldSize;
Dims start, count, shape;
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment