diff --git a/consensus/state.go b/consensus/state.go index c7767cab8c..b26a6466c9 100644 --- a/consensus/state.go +++ b/consensus/state.go @@ -255,7 +255,7 @@ func (cs *State) GetStateWithTimeout(timeout time.Duration) (sm.State, error) { return res, nil case <-time.After(timeout): - return sm.State{}, fmt.Errorf("timeout after %v", timeout) + return sm.State{}, fmt.Errorf("GetStateWithTimeout: timeout after %v", timeout) } } diff --git a/oracle/service/runner/runner.go b/oracle/service/runner/runner.go index 03a3b72421..515848e1f6 100644 --- a/oracle/service/runner/runner.go +++ b/oracle/service/runner/runner.go @@ -209,8 +209,8 @@ func Run(oracleInfo *types.OracleInfo, consensusState *cs.State, chainId string) // drop old votes when channel hits half cap if len(oracleInfo.SignVotesChan) >= cap(oracleInfo.SignVotesChan)/2 { - log.Warnf("dropping old vote from signVotesChan as it is at half capacity") - <-oracleInfo.SignVotesChan + voteToDrop := <-oracleInfo.SignVotesChan + log.Warnf("dropped vote as oracle sign votes channel cap is half full, vote: %+v at %v", voteToDrop, time.Now().Unix()) } oracleInfo.SignVotesChan <- res.Vote