fix: the same team was being added multiple times to primaryTeams

This commit is contained in:
Evan Tschannen 2018-07-12 12:10:18 -07:00
parent cd63c7a7cc
commit d12dac60ec
1 changed files with 10 additions and 2 deletions

View File

@ -451,11 +451,19 @@ ACTOR Future<Reference<InitialDataDistribution>> getInitialDataDistribution( Dat
}
} else {
info.primarySrc = src;
result->primaryTeams.insert( src );
auto srcIter = team_cache.find(src);
if(srcIter == team_cache.end()) {
result->primaryTeams.insert( src );
team_cache[src] = std::pair<vector<UID>, vector<UID>>();
}
if (dest.size()) {
info.hasDest = true;
info.primaryDest = dest;
result->primaryTeams.insert( dest );
auto destIter = team_cache.find(dest);
if(destIter == team_cache.end()) {
result->primaryTeams.insert( dest );
team_cache[dest] = std::pair<vector<UID>, vector<UID>>();
}
}
}
result->shards.push_back( info );