etcdserver: resume compactor only if leader

This commit is contained in:
vimalk78 2017-01-04 00:52:21 +05:30
parent 61064a7be3
commit 5fac6b8d15

View File

@ -635,6 +635,9 @@ func (s *EtcdServer) run() {
setSyncC(nil) setSyncC(nil)
} else { } else {
setSyncC(s.SyncTicker) setSyncC(s.SyncTicker)
if s.compactor != nil {
s.compactor.Resume()
}
} }
// TODO: remove the nil checking // TODO: remove the nil checking
@ -642,9 +645,6 @@ func (s *EtcdServer) run() {
if s.stats != nil { if s.stats != nil {
s.stats.BecomeLeader() s.stats.BecomeLeader()
} }
if s.compactor != nil {
s.compactor.Resume()
}
if s.r.td != nil { if s.r.td != nil {
s.r.td.Reset() s.r.td.Reset()
} }