diff options
| author | Valery Piashchynski <[email protected]> | 2021-07-27 12:39:01 +0300 |
|---|---|---|
| committer | Valery Piashchynski <[email protected]> | 2021-07-27 12:39:01 +0300 |
| commit | 1e59ec2755a9cdafd26864ba532fa4d3eff46ecd (patch) | |
| tree | 68c7c7e8d9f4d99debc4895ab8469e323c60f47b /tests/plugins/jobs/jobs_with_toxics_test.go | |
| parent | d72181126867c7e8fc05e5ac927bd90d01e0dbc7 (diff) | |
Initial support for the cancellation via context
Signed-off-by: Valery Piashchynski <[email protected]>
Diffstat (limited to 'tests/plugins/jobs/jobs_with_toxics_test.go')
| -rw-r--r-- | tests/plugins/jobs/jobs_with_toxics_test.go | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/tests/plugins/jobs/jobs_with_toxics_test.go b/tests/plugins/jobs/jobs_with_toxics_test.go index 85fd4fa8..7e2bd8be 100644 --- a/tests/plugins/jobs/jobs_with_toxics_test.go +++ b/tests/plugins/jobs/jobs_with_toxics_test.go @@ -132,18 +132,18 @@ func TestDurabilityAMQP(t *testing.T) { time.Sleep(time.Second * 3) go func() { - time.Sleep(time.Second * 2) - t.Run("PushPipelineWhileRedialing-1", pushToPipe("test-1")) - t.Run("PushPipelineWhileRedialing-2", pushToPipe("test-2")) + time.Sleep(time.Second * 5) + enableProxy("redial", t) }() - time.Sleep(time.Second * 5) - enableProxy("redial", t) + t.Run("PushPipelineWhileRedialing-1", pushToPipeErr("test-1")) + t.Run("PushPipelineWhileRedialing-2", pushToPipeErr("test-2")) + time.Sleep(time.Second * 15) t.Run("PushPipelineWhileRedialing-1", pushToPipe("test-1")) t.Run("PushPipelineWhileRedialing-2", pushToPipe("test-2")) - time.Sleep(time.Second * 10) + time.Sleep(time.Second * 5) stopCh <- struct{}{} wg.Wait() |