Skip to content

Commit

Permalink
mpi: remove unused getMpiMockedPendingMigrations
Browse files Browse the repository at this point in the history
  • Loading branch information
csegarragonz committed Feb 3, 2022
1 parent c090a16 commit 68f33b8
Showing 1 changed file with 0 additions and 11 deletions.
11 changes: 0 additions & 11 deletions src/scheduler/MpiWorld.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -53,9 +53,6 @@ static std::vector<faabric::MpiHostsToRanksMessage> rankMessages;
static std::map<int, std::vector<std::shared_ptr<faabric::MPIMessage>>>
mpiMockedMessages;

static std::vector<std::shared_ptr<faabric::PendingMigrations>>
mpiMockedPendingMigrations;

std::vector<faabric::MpiHostsToRanksMessage> getMpiHostsToRanksMessages()
{
faabric::util::UniqueLock lock(mockMutex);
Expand All @@ -69,13 +66,6 @@ std::vector<std::shared_ptr<faabric::MPIMessage>> getMpiMockedMessages(
return mpiMockedMessages[sendRank];
}

std::vector<std::shared_ptr<faabric::PendingMigrations>>
getMpiMockedPendingMigrations()
{
faabric::util::UniqueLock lock(mockMutex);
return mpiMockedPendingMigrations;
}

MpiWorld::MpiWorld()
: thisHost(faabric::util::getSystemConfig().endpointHost)
, basePort(faabric::util::getSystemConfig().mpiBasePort)
Expand Down Expand Up @@ -350,7 +340,6 @@ void MpiWorld::destroy()
// Clear structures used for mocking
rankMessages.clear();
mpiMockedMessages.clear();
mpiMockedPendingMigrations.clear();
}

void MpiWorld::initialiseFromMsg(faabric::Message& msg)
Expand Down

0 comments on commit 68f33b8

Please sign in to comment.