Browse Source

address comments, pr #643

pull/703/head
Zach Ramsay 7 years ago
committed by Ethan Buchman
parent
commit
563faa98de
4 changed files with 4 additions and 2 deletions
  1. +1
    -1
      blockchain/pool.go
  2. +1
    -0
      cmd/tendermint/commands/reset_priv_validator.go
  3. +1
    -1
      consensus/reactor.go
  4. +1
    -0
      consensus/state.go

+ 1
- 1
blockchain/pool.go View File

@ -313,7 +313,7 @@ func (pool *BlockPool) makeNextRequester() {
_, err := request.Start() _, err := request.Start()
if err != nil { if err != nil {
pool.Logger.Error("Error starting block pool", "err", err)
request.Logger.Error("Error starting request", "err", err)
} }
} }


+ 1
- 0
cmd/tendermint/commands/reset_priv_validator.go View File

@ -49,6 +49,7 @@ func ResetAll(dbDir, privValFile string, logger log.Logger) {
resetPrivValidatorLocal(privValFile, logger) resetPrivValidatorLocal(privValFile, logger)
if err := os.RemoveAll(dbDir); err != nil { if err := os.RemoveAll(dbDir); err != nil {
logger.Error("Error removing directory", "err", err) logger.Error("Error removing directory", "err", err)
return
} }
logger.Info("Removed all data", "dir", dbDir) logger.Info("Removed all data", "dir", dbDir)
} }


+ 1
- 1
consensus/reactor.go View File

@ -99,7 +99,7 @@ func (conR *ConsensusReactor) SwitchToConsensus(state *sm.State, blocksSynced in
} }
_, err := conR.conS.Start() _, err := conR.conS.Start()
if err != nil { if err != nil {
conR.Logger.Error("Error starting conR", "err", err)
conR.Logger.Error("Error starting conS", "err", err)
} }
} }


+ 1
- 0
consensus/state.go View File

@ -260,6 +260,7 @@ func (cs *ConsensusState) startRoutines(maxSteps int) {
_, err := cs.timeoutTicker.Start() _, err := cs.timeoutTicker.Start()
if err != nil { if err != nil {
cs.Logger.Error("Error starting timeout ticker", "err", err) cs.Logger.Error("Error starting timeout ticker", "err", err)
return
} }
go cs.receiveRoutine(maxSteps) go cs.receiveRoutine(maxSteps)
} }


Loading…
Cancel
Save