Skip to content

Commit

Permalink
Merge pull request #9693 from mohitsoni/release-3.1
Browse files Browse the repository at this point in the history
Cherry-picking PR 7967 to release-3.1
  • Loading branch information
gyuho authored May 4, 2018
2 parents d2f6065 + ea82927 commit 01d9b36
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions etcdserver/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -588,18 +588,21 @@ func (s *EtcdServer) start() {
}

func (s *EtcdServer) purgeFile() {
var serrc, werrc <-chan error
var dberrc, serrc, werrc <-chan error
if s.Cfg.MaxSnapFiles > 0 {
dberrc = fileutil.PurgeFile(s.Cfg.SnapDir(), "snap.db", s.Cfg.MaxSnapFiles, purgeFileInterval, s.done)
serrc = fileutil.PurgeFile(s.Cfg.SnapDir(), "snap", s.Cfg.MaxSnapFiles, purgeFileInterval, s.done)
}
if s.Cfg.MaxWALFiles > 0 {
werrc = fileutil.PurgeFile(s.Cfg.WALDir(), "wal", s.Cfg.MaxWALFiles, purgeFileInterval, s.done)
}
select {
case e := <-werrc:
plog.Fatalf("failed to purge wal file %v", e)
case e := <-dberrc:
plog.Fatalf("failed to purge snap db file %v", e)
case e := <-serrc:
plog.Fatalf("failed to purge snap file %v", e)
case e := <-werrc:
plog.Fatalf("failed to purge wal file %v", e)
case <-s.stopping:
return
}
Expand Down

0 comments on commit 01d9b36

Please sign in to comment.