consensus: stop wal

2018-07-01 12:53:51 -04:00 · 2018-07-01 12:53:51 -04:00 · af703620d4
parent 3a0dff7db2
commit af703620d4
1 changed files with 1 additions and 4 deletions
--- a/consensus/state.go
+++ b/consensus/state.go
@ -320,10 +320,7 @@ func (cs *ConsensusState) OnStop() {

 	cs.timeoutTicker.Stop()

-	// Make BaseService.Wait() wait until cs.wal.Wait()
-	if cs.IsRunning() {
-		cs.wal.Wait()
-	}
+	cs.wal.Stop()
 }

 // Wait waits for the the main routine to return.