storage: avoid deadlock on (*Stopper).Quiesce

See #37954 (comment). Closes #37954. Release note: None
cockroachdb · Jun 4, 2019 · a0d0daf · a0d0daf
1 parent 2428567
commit a0d0daf
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/storage/closedts/provider/provider.go b/pkg/storage/closedts/provider/provider.go
@@ -275,6 +275,8 @@ func (p *Provider) Subscribe(ctx context.Context, ch chan<- ctpb.Entry) {
 		for _, entry := range entries {
 			select {
 			case ch <- entry:
+			case <-p.cfg.Stopper.ShouldQuiesce():
+				return
 			case <-ctx.Done():
 				return
 			}
@@ -324,6 +326,8 @@ func (p *Provider) Subscribe(ctx context.Context, ch chan<- ctpb.Entry) {
 
 			select {
 			case ch <- entry:
+			case <-p.cfg.Stopper.ShouldQuiesce():
+				return
 			case <-ctx.Done():
 				return
 			}