one to rule them all

Author: kostasrim

src/server/replica.cc

@@ -508,11 +508,15 @@ error_code Replica::InitiateDflySync(std::optional<LastMasterSyncData> last_mast
   // Initialize shard flows.
   shard_flows_.resize(master_context_.num_flows);
   DCHECK(!shard_flows_.empty());
-  for (unsigned i = 0; i < shard_flows_.size(); ++i) {
-    shard_flows_[i].reset(
-        new DflyShardReplica(server(), master_context_, i, &service_, multi_shard_exe_));
-  }
   thread_flow_map_ = Partition(shard_flows_.size());
+  const size_t pool_sz = shard_set->pool()->size();
+
+  shard_set->pool()->AwaitFiberOnAll([pool_sz, this](auto index, auto* ctx) {
+    for (unsigned i = index; i < shard_flows_.size(); i += pool_sz) {
+      shard_flows_[i].reset(
+          new DflyShardReplica(server(), master_context_, i, &service_, multi_shard_exe_));
+    }
+  });
 
   // Blocked on until all flows got full sync cut.
   BlockingCounter sync_block{unsigned(shard_flows_.size())};