(release/v20.07) Pause rollups during snapshot streaming. (#6611)

(cherry picked from commit b777913)
hypermodeinc · Oct 2, 2020 · 0b7483f · 0b7483f
1 parent 1e29664
commit 0b7483f
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/worker/snapshot.go b/worker/snapshot.go
@@ -253,6 +253,13 @@ func doStreamSnapshot(snap *pb.Snapshot, out pb.Worker_StreamSnapshotServer) err
 }
 
 func (w *grpcWorker) StreamSnapshot(stream pb.Worker_StreamSnapshotServer) error {
+	// Pause rollups during snapshot streaming.
+	closer, err := groups().Node.startTask(opSnapshot)
+	if err != nil {
+		return err
+	}
+	defer closer.Done()
+
 	n := groups().Node
 	if n == nil || n.Raft() == nil {
 		return conn.ErrNoNode