fix: we need to copy the txsTag on satellite logs

This commit is contained in:
Evan Tschannen 2018-06-10 20:30:44 -07:00
parent a5c2a8ee8a
commit b60264024a
1 changed files with 2 additions and 2 deletions

View File

@ -1748,8 +1748,8 @@ struct TagPartitionedLogSystem : ILogSystem, ReferenceCounted<TagPartitionedLogS
logSystem->tLogs[1]->logServers.resize( recr.satelliteTLogs.size() ); // Dummy interfaces, so that logSystem->getPushLocations() below uses the correct size
logSystem->tLogs[1]->updateLocalitySet(satelliteLocalities);
for(int i = 0; i < oldLogSystem->logRouterTags; i++) {
Tag tag(tagLocalityLogRouter, i);
for(int i = -1; i < oldLogSystem->logRouterTags; i++) {
Tag tag = i == -1 ? txsTag : Tag(tagLocalityLogRouter, i);
locations.clear();
logSystem->tLogs[1]->getPushLocations( vector<Tag>(1, tag), locations, 0 );
for(int loc : locations)