fluencelabs/tendermint
1
0
Fork 0
mirror of https://github.com/fluencelabs/tendermint synced 2025-05-22 02:41:19 +00:00
Code Issues Projects Releases Wiki Activity

remove BaseService.OnStart

Browse Source
This commit is contained in:
Ethan Buchman 2017-03-28 12:09:11 -04:00
parent 85e83934a1
commit 4fd1471f11
7 changed files with 0 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
blockchain/pool.go
View File

@ -63,7 +63,6 @@ func NewBlockPool(start int, requestsCh chan<- BlockRequest, timeoutsCh chan<- s
} }
func (pool *BlockPool) OnStart() error { func (pool *BlockPool) OnStart() error {
pool.BaseService.OnStart()
go pool.makeRequestersRoutine() go pool.makeRequestersRoutine()
pool.startTime = time.Now() pool.startTime = time.Now()
return nil return nil
@ -409,7 +408,6 @@ func newBPRequester(pool *BlockPool, height int) *bpRequester {
} }
func (bpr *bpRequester) OnStart() error { func (bpr *bpRequester) OnStart() error {
bpr.BaseService.OnStart()
go bpr.requestRoutine() go bpr.requestRoutine()
return nil return nil
} }

2
consensus/replay_file.go
View File

@ -127,8 +127,6 @@ func (pb *playback) replayReset(count int, newStepCh chan interface{}) error {
} }
func (cs *ConsensusState) startForReplay() { func (cs *ConsensusState) startForReplay() {
// don't want to start full cs
cs.BaseService.OnStart()
log.Warn("Replay commands are disabled until someone updates them and writes tests") log.Warn("Replay commands are disabled until someone updates them and writes tests")
/* TODO:! /* TODO:!

1
consensus/state.go
View File

@ -340,7 +340,6 @@ func (cs *ConsensusState) LoadCommit(height int) *types.Commit {
} }
func (cs *ConsensusState) OnStart() error { func (cs *ConsensusState) OnStart() error {
cs.BaseService.OnStart()
walFile := cs.config.GetString("cs_wal_file") walFile := cs.config.GetString("cs_wal_file")
if err := cs.OpenWAL(walFile); err != nil { if err := cs.OpenWAL(walFile); err != nil {

1
consensus/ticker.go
View File

@ -45,7 +45,6 @@ func NewTimeoutTicker() TimeoutTicker {
} }
func (t *timeoutTicker) OnStart() error { func (t *timeoutTicker) OnStart() error {
t.BaseService.OnStart()
go t.timeoutRoutine() go t.timeoutRoutine()

1
consensus/wal.go
View File

@ -55,7 +55,6 @@ func NewWAL(walFile string, light bool) (*WAL, error) {
} }
func (wal *WAL) OnStart() error { func (wal *WAL) OnStart() error {
wal.BaseService.OnStart()
size, err := wal.group.Head.Size() size, err := wal.group.Head.Size()
if err != nil { if err != nil {
return err return err

1
node/node.go
View File

@ -194,7 +194,6 @@ func NewNode(config cfg.Config, privValidator *types.PrivValidator, clientCreato
} }
func (n *Node) OnStart() error { func (n *Node) OnStart() error {
n.BaseService.OnStart()
// Create & add listener // Create & add listener
protocol, address := ProtocolAndAddress(n.config.GetString("node_laddr")) protocol, address := ProtocolAndAddress(n.config.GetString("node_laddr"))

1
proxy/multi_app_conn.go
View File

@ -72,7 +72,6 @@ func (app *multiAppConn) Query() AppConnQuery {
} }
func (app *multiAppConn) OnStart() error { func (app *multiAppConn) OnStart() error {
app.BaseService.OnStart()
// query connection // query connection
querycli, err := app.clientCreator.NewABCIClient() querycli, err := app.clientCreator.NewABCIClient()