do not broadcast unless shard changed.

This commit is contained in:
Dan Lambright 2021-12-14 16:21:58 -05:00
parent 9f4ac866cd
commit f91afcd626
1 changed files with 1 additions and 1 deletions

View File

@ -413,7 +413,7 @@ ACTOR Future<Void> resolveBatch(Reference<Resolver> self, ResolveTransactionBatc
reply.tpcvMap.clear();
} else {
std::set<uint16_t> writtenTLogs;
if (shardChanged || reply.privateMutationCount) {
if (shardChanged) {
for (int i = 0; i < self->numLogs; i++) {
writtenTLogs.insert(i);
}