From 8f5ee3184ba9552c6878f6687dd04d40833dd33c Mon Sep 17 00:00:00 2001 From: Saxon Date: Fri, 27 Mar 2020 23:56:36 +1030 Subject: [PATCH] revid: added ring buffer write timeout to TestMtsSenderDiscontinuity --- revid/senders_test.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/revid/senders_test.go b/revid/senders_test.go index 8105b818..80b18746 100644 --- a/revid/senders_test.go +++ b/revid/senders_test.go @@ -224,7 +224,7 @@ func TestMtsSenderFailedSend(t *testing.T) { // Create destination, the mtsSender and the mtsEncoder const clipToFailAt = 3 dst := &destination{t: t, testFails: true, failAt: clipToFailAt, done: make(chan struct{})} - rb, err := vring.NewBuffer(rbMaxElements, rbCapacity, 0) + rb, err := vring.NewBuffer(rbMaxElements, rbCapacity, 10*time.Millisecond) if err != nil { t.Fatalf("could not initialise ring buffer: %v", err) } @@ -309,7 +309,7 @@ func TestMtsSenderDiscontinuity(t *testing.T) { // Create destination, the mtsSender and the mtsEncoder. const clipToDelay = 3 dst := &destination{t: t, sendDelay: 10 * time.Millisecond, delayAt: clipToDelay, done: make(chan struct{})} - rb, err := vring.NewBuffer(1, rbCapacity, 0) + rb, err := vring.NewBuffer(1, rbCapacity, 10*time.Millisecond) if err != nil { t.Fatalf("could not initialise ring buffer: %v", err) }