Fix race in stream (#1632)

google · Apr 6, 2023 · 4a79e94 · 4a79e94
1 parent 65e78dc
commit 4a79e94
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/pkg/v1/stream/layer.go b/pkg/v1/stream/layer.go
@@ -130,6 +130,8 @@ func (l *Layer) Uncompressed() (io.ReadCloser, error) {
 
 // Compressed implements v1.Layer.
 func (l *Layer) Compressed() (io.ReadCloser, error) {
+	l.mu.Lock()
+	defer l.mu.Unlock()
 	if l.consumed {
 		return nil, ErrConsumed
 	}