From c6d934a685c1a8d6f486765421d278552cb3cd23 Mon Sep 17 00:00:00 2001 From: Alexander Neumann Date: Mon, 9 May 2016 20:41:55 +0200 Subject: [PATCH] Fix flaky worker cancel test --- src/restic/worker/pool_test.go | 5 +---- 1 file changed, 1 insertion(+), 4 deletions(-) diff --git a/src/restic/worker/pool_test.go b/src/restic/worker/pool_test.go index 16b285702..5c7ca91e4 100644 --- a/src/restic/worker/pool_test.go +++ b/src/restic/worker/pool_test.go @@ -94,7 +94,6 @@ var errCancelled = errors.New("cancelled") type Job struct { suc chan struct{} - d time.Duration } func wait(job worker.Job, done <-chan struct{}) (interface{}, error) { @@ -102,8 +101,6 @@ func wait(job worker.Job, done <-chan struct{}) (interface{}, error) { select { case j.suc <- struct{}{}: return time.Now(), nil - case <-time.After(j.d): - return time.Now(), nil case <-done: return nil, errCancelled } @@ -114,7 +111,7 @@ func TestPoolCancel(t *testing.T) { suc := make(chan struct{}, 1) for i := 0; i < 20; i++ { - jobCh <- worker.Job{Data: Job{suc: suc, d: time.Second}} + jobCh <- worker.Job{Data: Job{suc: suc}} } <-suc