Browse Source

Merge pull request #7090 from vimalk78/fix-comactor-resume-leadr-change#7040

etcdserver: resume compactor only if leader
Xiang Li 9 years ago
parent
commit
729dcd51ce
1 changed files with 3 additions and 3 deletions
  1. 3 3
      etcdserver/server.go

+ 3 - 3
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()
 			}