A container registry that uses the AT Protocol for manifest storage and S3 for blob storage.
ugh
+3
-4
+3
-4
pkg/appview/middleware/registry.go
+3
-4
pkg/appview/middleware/registry.go
···
133
133
}
134
134
}
135
135
136
-
// Mark as in-flight and create done channel if needed
137
-
if entry.done == nil {
138
-
entry.done = make(chan struct{})
139
-
}
136
+
// Mark as in-flight and create fresh done channel for this fetch
137
+
// IMPORTANT: Always create a new channel - a closed channel is not nil
138
+
entry.done = make(chan struct{})
140
139
entry.inFlight = true
141
140
done := entry.done
142
141
entry.mu.Unlock()