diff --git a/gossip/service/gossip_service_test.go b/gossip/service/gossip_service_test.go index 70e0f27533b..81d993687bb 100644 --- a/gossip/service/gossip_service_test.go +++ b/gossip/service/gossip_service_test.go @@ -51,7 +51,7 @@ import ( "google.golang.org/grpc" ) -const TIMEOUT = 45 * time.Second +const TIMEOUT = 90 * time.Second func init() { util.SetupTestLogging() @@ -610,7 +610,9 @@ func (jmc *joinChanMsg) AnchorPeersOf(org api.OrgIdentityType) []api.AnchorPeer } func waitForFullMembershipOrFailNow(t *testing.T, channel string, gossips []*gossipGRPC, peersNum int, timeout time.Duration, testPollInterval time.Duration) { - end := time.Now().Add(timeout) + logger.Warning("Waiting for", peersNum, "members") + start := time.Now() + end := start.Add(timeout) var correctPeers int for time.Now().Before(end) { correctPeers = 0 @@ -620,6 +622,7 @@ func waitForFullMembershipOrFailNow(t *testing.T, channel string, gossips []*gos } } if correctPeers == peersNum { + logger.Warning("Established full channel membership in", time.Since(start)) return } time.Sleep(testPollInterval) diff --git a/gossip/service/integration_test.go b/gossip/service/integration_test.go index 452e203815e..0681124b6c1 100644 --- a/gossip/service/integration_test.go +++ b/gossip/service/integration_test.go @@ -105,7 +105,7 @@ func TestLeaderYield(t *testing.T) { // Add peers to the channel addPeersToChannel(channelName, gossips, peerIndexes) // Prime the membership view of the peers - waitForFullMembershipOrFailNow(t, channelName, gossips, n, time.Second*30, time.Millisecond*100) + waitForFullMembershipOrFailNow(t, channelName, gossips, n, TIMEOUT, time.Millisecond*100) grpcClient, err := comm.NewGRPCClient(comm.ClientConfig{}) require.NoError(t, err)