kemko/nomad
1
0
Fork 0
mirror of https://github.com/kemko/nomad.git synced 2026-01-06 10:25:42 +03:00
Code Issues Packages Projects Releases Wiki Activity

Changing the logic of purging old rotated files

Browse Source
This commit is contained in:
Diptanu Choudhury
2016-01-20 15:52:52 -08:00
parent 306d5d281f
commit 87ccaab00b
1 changed files with 13 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
client/driver/logs.go
View File

@@ -80,7 +80,7 @@ func (l *LogRotator) Start(r io.Reader) error {
if err != nil {
return err
}
l.logger.Println("[INFO] client.logrotator: opened a new file: %s", logFileName)
l.logger.Printf("[DEBUG] client.logrotator: opened a new file: %s", logFileName)
// closing the current log file if it doesn't have any more capacity
if remainingSize < 1 {
l.logFileIdx = l.logFileIdx + 1
@@ -125,12 +125,12 @@ func (l *LogRotator) Start(r io.Reader) error {
// PurgeOldFiles removes older files and keeps only the last N files rotated for
// a file
func (l *LogRotator) PurgeOldFiles() {
fIndexes := make([]int, l.maxFiles)
var fIndexes []int
files, err := ioutil.ReadDir(l.path)
if err != nil {
return
}
count := 0
// Inserting all the rotated files in a slice
for _, f := range files {
if strings.HasPrefix(f.Name(), l.fileName) {
fileIdx := strings.TrimPrefix(f.Name(), fmt.Sprintf("%s.", l.fileName))
@@ -138,15 +138,16 @@ func (l *LogRotator) PurgeOldFiles() {
if err != nil {
continue
}
if count == l.maxFiles {
sort.Sort(sort.Reverse(sort.IntSlice(fIndexes)))
fname := filepath.Join(l.path, fmt.Sprintf("%s.%d", l.fileName, fIndexes[count-1]))
l.logger.Printf("[DEBUG] client.logrator: removing file: %v", fname)
os.RemoveAll(fname)
count -= 1
}
fIndexes[count] = n
count += 1
fIndexes = append(fIndexes, n)
}
}
// sorting the file indexes so that we can purge the older files and keep
// only the number of files as configured by the user
sort.Sort(sort.IntSlice(fIndexes))
toDelete := fIndexes[l.maxFiles-1 : len(fIndexes)-1]
for _, fIndex := range toDelete {
fname := filepath.Join(l.path, fmt.Sprintf("%s.%d", l.fileName, fIndex))
os.RemoveAll(fname)
}
}