We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ee6f508 commit 75261f5Copy full SHA for 75261f5
services/archiver/archiver_test.go
@@ -184,7 +184,15 @@ func TestArchive_Basic(t *testing.T) {
184
assert.Equal(t, 2, len(archiveInProgress))
185
releaseOneEntry(t, inFlight)
186
assert.Equal(t, 1, len(archiveInProgress))
187
+
188
+ // Test waiting for completion on one, which should be relatively
189
+ // straightforward. We'll hold the queue-lock and release an entry. It will
190
+ // wait to acquire the queue lock, which we'll drop when we
191
+ // WaitForCompletion(), to be woken up later.
192
+ LockQueue()
193
194
+ WaitForCompletion()
195
+ UnlockQueue()
196
assert.Equal(t, 0, len(archiveInProgress))
197
198
zipReq2 = DeriveRequestFrom(ctx, firstCommit+".zip")
0 commit comments