Revert "Revert "adding an MPI init test in case of that MPI was initialized repeatedly""

This reverts commit 23ebe452a5.
This commit is contained in:
Qiwei Ye 2015-12-18 12:40:38 +08:00
Родитель 315e53a16f
Коммит ebaf9885ea
1 изменённых файлов: 6 добавлений и 1 удалений

Просмотреть файл

@ -112,7 +112,12 @@ namespace Microsoft { namespace MSR { namespace CNTK {
fprintf(stderr, "MPIWrapper: initializing MPI\n");
fflush(stderr);
MPI_Init_DL() || MpiFail("mpiaggregator: MPI_Init");
int flag = 0;
MPI_Initialized(&flag);
if (!flag)
{
MPI_Init_DL() || MpiFail("mpiaggregator: MPI_Init");
}
MPI_Comm_rank(MPI_COMM_WORLD, &m_myRank);
MPI_Comm_size(MPI_COMM_WORLD, &m_numMPINodes);
m_numNodesInUse = m_numMPINodes;