From 5fac6b8d15374e83cf9938ff1b92a04e336a3d21 Mon Sep 17 00:00:00 2001 From: vimalk78 Date: Wed, 4 Jan 2017 00:52:21 +0530 Subject: [PATCH] etcdserver: resume compactor only if leader --- etcdserver/server.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/etcdserver/server.go b/etcdserver/server.go index f2ee1d787..37621c7e5 100644 --- a/etcdserver/server.go +++ b/etcdserver/server.go @@ -635,6 +635,9 @@ func (s *EtcdServer) run() { setSyncC(nil) } else { setSyncC(s.SyncTicker) + if s.compactor != nil { + s.compactor.Resume() + } } // TODO: remove the nil checking @@ -642,9 +645,6 @@ func (s *EtcdServer) run() { if s.stats != nil { s.stats.BecomeLeader() } - if s.compactor != nil { - s.compactor.Resume() - } if s.r.td != nil { s.r.td.Reset() }