diff --git a/consensus/reactor_test.go b/consensus/reactor_test.go index 55efd716..bc290c8d 100644 --- a/consensus/reactor_test.go +++ b/consensus/reactor_test.go @@ -106,7 +106,7 @@ func TestValidatorSetChanges(t *testing.T) { }) //--------------------------------------------------------------------------- - // Adding one validator + log.Info("Testing adding one validator") newValidatorPubKey1 := css[nVals].privValidator.(*types.PrivValidator).PubKey newValidatorTx1 := dummy.MakeValSetChangeTx(newValidatorPubKey1.Bytes(), uint64(testMinPower)) @@ -132,7 +132,7 @@ func TestValidatorSetChanges(t *testing.T) { waitForAndValidateBlock(t, nPeers, activeVals, eventChans, css) //--------------------------------------------------------------------------- - // Changing the voting power of one validator + log.Info("Testing changing the voting power of one validator") updateValidatorTx1 := dummy.MakeValSetChangeTx(newValidatorPubKey1.Bytes(), 25) previousTotalVotingPower := css[nVals].LastValidators.TotalVotingPower() @@ -146,7 +146,7 @@ func TestValidatorSetChanges(t *testing.T) { } //--------------------------------------------------------------------------- - // Adding two validators at once + log.Info("Testing adding two validators at once") newValidatorPubKey2 := css[nVals+1].privValidator.(*types.PrivValidator).PubKey newValidatorTx2 := dummy.MakeValSetChangeTx(newValidatorPubKey2.Bytes(), uint64(testMinPower)) @@ -162,7 +162,7 @@ func TestValidatorSetChanges(t *testing.T) { waitForAndValidateBlock(t, nPeers, activeVals, eventChans, css) //--------------------------------------------------------------------------- - // Removing two validators at once + log.Info("Testing removing two validators at once") removeValidatorTx2 := dummy.MakeValSetChangeTx(newValidatorPubKey2.Bytes(), 0) removeValidatorTx3 := dummy.MakeValSetChangeTx(newValidatorPubKey3.Bytes(), 0) @@ -215,17 +215,15 @@ func timeoutWaitGroup(t *testing.T, n int, f func(*sync.WaitGroup, int)) { go f(wg, i) } - // Make wait into a channel done := make(chan struct{}) go func() { wg.Wait() close(done) }() - tick := time.NewTicker(time.Second * 3) select { case <-done: - case <-tick.C: + case <-time.After(time.Second * 3): t.Fatalf("Timed out waiting for all validators to commit a block") } }