Compare commits
1
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
c2650c263b |
+6
-6
@@ -706,12 +706,12 @@ func TestFeedHashJobsClosesJobsWhenCancelled(t *testing.T) {
|
|||||||
// hashWorker's other cancellation exit, abandoning the send of a
|
// hashWorker's other cancellation exit, abandoning the send of a
|
||||||
// result, is reachable from the scan: stop cancels the pool before it
|
// result, is reachable from the scan: stop cancels the pool before it
|
||||||
// drains results, so a worker waiting on that send can leave through
|
// drains results, so a worker waiting on that send can leave through
|
||||||
// it. TestScanHashWriteFailureUnwindsPool reaches it in some runs only,
|
// it. The tests that stop a scan mid-hash, among them
|
||||||
// depending on whether the workers have filled the results channel when
|
// TestScanHashWriteFailureUnwindsPool, reach it in some runs only,
|
||||||
// stop runs, and no test fails without it, since stop's drain frees a
|
// depending on timing, and no test fails without it, since stop's
|
||||||
// waiting worker anyway. This test, for its part, catches a removed
|
// drain frees a waiting worker anyway. This test, for its part, catches
|
||||||
// drop check in some runs only: a worker that hashes the run anyway
|
// a removed drop check in some runs only: a worker that hashes the run
|
||||||
// then picks at random between sending the result and leaving.
|
// anyway then picks at random between sending the result and leaving.
|
||||||
func TestHashWorkerDropsQueuedRuns(t *testing.T) {
|
func TestHashWorkerDropsQueuedRuns(t *testing.T) {
|
||||||
t.Parallel()
|
t.Parallel()
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user