| 1030 | |
| 1031 | loop choose { |
| 1032 | when(Promise<int64_t> req = waitNext(getAverageShardBytes)) { |
| 1033 | req.send(self.maxShardSize->get().get() / 2); |
| 1034 | } |
| 1035 | when(wait(loggingTrigger)) { |
| 1036 | TraceEvent("DDTrackerStats", self.distributorId) |
| 1037 | .detail("Shards", self.shards.size()) |
no test coverage detected