Fix race in stream (#1632)

jonjohnsonjr · web-flow · commit 4a79e94bb338 · 2023-04-06T15:45:49.000-04:00
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
 	}

Original file line number	Diff line number	Diff line change
`@@ -130,6 +130,8 @@ func (l *Layer) Uncompressed() (io.ReadCloser, error) {`
`130`	`130`
`131`	`131`	`// Compressed implements v1.Layer.`
`132`	`132`	`func (l *Layer) Compressed() (io.ReadCloser, error) {`
	`133`	`+ l.mu.Lock()`
	`134`	`+ defer l.mu.Unlock()`
`133`	`135`	`if l.consumed {`
`134`	`136`	`return nil, ErrConsumed`
`135`	`137`	`}`