From 9586323f21e726ae208b17c16cbf7cbaf7f06de5 Mon Sep 17 00:00:00 2001 From: YACOVM Date: Sun, 16 Apr 2017 18:33:48 +0300 Subject: [PATCH] [FAB-3175] Fix Intermittent CI failure deliveryService This commit attempts to fix an intermittent CI failure that was introduced lately. Change-Id: I364fcabf9afcfa12244bb9ebf0df3e1d8d4f0745 Signed-off-by: Yacov Manevich --- core/deliverservice/deliveryclient_test.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/deliverservice/deliveryclient_test.go b/core/deliverservice/deliveryclient_test.go index da2c3a267bb..ac104e94cc4 100644 --- a/core/deliverservice/deliveryclient_test.go +++ b/core/deliverservice/deliveryclient_test.go @@ -76,7 +76,7 @@ func (*mockMCS) ValidateIdentity(peerIdentity api.PeerIdentityType) error { func TestNewDeliverService(t *testing.T) { defer ensureNoGoroutineLeak(t)() - gossipServiceAdapter := &mocks.MockGossipServiceAdapter{GossipBlockDisseminations: make(chan uint64)} + gossipServiceAdapter := &mocks.MockGossipServiceAdapter{GossipBlockDisseminations: make(chan uint64, 1)} factory := &struct{ mockBlocksDelivererFactory }{} blocksDeliverer := &mocks.MockBlocksDeliverer{} @@ -110,7 +110,7 @@ func TestNewDeliverService(t *testing.T) { assert.Error(t, service.StopDeliverForChannel("TEST_CHAINID2"), "can't stop delivery") // Let it try to simulate a few recv -> gossip rounds - time.Sleep(time.Duration(10) * time.Millisecond) + time.Sleep(time.Second) assert.NoError(t, service.StopDeliverForChannel("TEST_CHAINID")) time.Sleep(time.Duration(10) * time.Millisecond) // Make sure to stop all blocks providers