From 2b9d696b49286998849a0f239526e57b01a0b67a Mon Sep 17 00:00:00 2001
From: Christian Schwarz <me@cschwarz.com>
Date: Tue, 7 Apr 2020 23:35:42 +0200
Subject: [PATCH] replication/driver: envconst for experimental parallel
 replication

refs #140
refs #302
---
 replication/driver/replication_driver.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/replication/driver/replication_driver.go b/replication/driver/replication_driver.go
index 02450a3..6069d98 100644
--- a/replication/driver/replication_driver.go
+++ b/replication/driver/replication_driver.go
@@ -355,7 +355,7 @@ func (a *attempt) do(ctx context.Context, prev *attempt) {
 	// invariant: prevs contains an entry for each unambiguous correspondence
 
 	stepQueue := newStepQueue()
-	defer stepQueue.Start(1)() // TODO parallel replication
+	defer stepQueue.Start(envconst.Int("ZREPL_REPLICATION_EXPERIMENTAL_REPLICATION_CONCURRENCY", 1))() // TODO parallel replication
 	var fssesDone sync.WaitGroup
 	for _, f := range a.fss {
 		fssesDone.Add(1)