@@ -3,14 +3,14 @@ package cleaner
33
44import (
55 "io/ioutil"
6+ "log"
67 "os"
78 "path/filepath"
89 "strings"
910 "time"
1011
1112 "github.com/deis/builder/pkg/k8s"
1213 "github.com/deis/builder/pkg/sshd"
13- "github.com/deis/pkg/log"
1414 "k8s.io/kubernetes/pkg/api"
1515 "k8s.io/kubernetes/pkg/fields"
1616 "k8s.io/kubernetes/pkg/labels"
@@ -69,47 +69,51 @@ func stripSuffixes(strs []string, suffix string) []string {
6969 return ret
7070}
7171
72- // Run starts the deleted app cleaner. Every pollSleepDuration, it compares the result of nsLister.List with the directories in the top level of gitHome on the local file system. On any error, it uses log.Debug to output a human readable description of what happened.
72+ // Run starts the deleted app cleaner. Every pollSleepDuration, it compares the result of nsLister.List with the directories in the top level of gitHome on the local file system. On any error, it uses log messages to output a human readable description of what happened.
7373func Run (gitHome string , nsLister k8s.NamespaceLister , repoLock sshd.RepositoryLock , pollSleepDuration time.Duration ) error {
7474 for {
7575 nsList , err := nsLister .List (labels .Everything (), fields .Everything ())
7676 if err != nil {
77- log .Err ("Cleaner error listing namespaces (%s)" , err )
77+ log .Printf ("Cleaner error listing namespaces (%s)" , err )
7878 continue
7979 } else {
8080 lst := make ([]string , len (nsList .Items ))
8181 for i , ns := range nsList .Items {
8282 lst [i ] = strings .ToLower (ns .Name )
8383 }
84- log .Debug ("Cleaner found namespaces %s" , lst )
84+ log .Printf ("Cleaner found namespaces %s" , lst )
8585 }
8686
8787 gitDirs , err := localDirs (gitHome )
8888 if err != nil {
89- log .Err ("Cleaner error listing local git directories (%s)" , err )
89+ log .Printf ("Cleaner error listing local git directories (%s)" , err )
9090 continue
9191 } else {
92- log .Debug ("Cleaner found local git directories in %s: %s" , gitHome , gitDirs )
92+ log .Printf ("Cleaner found local git directories in %s: %s" , gitHome , gitDirs )
9393 }
9494
9595 gitDirs = stripSuffixes (gitDirs , dotGitSuffix )
9696
97- dirsToDelete := getDiff (nsList .Items , gitDirs )
98- if len (dirsToDelete ) > 0 {
99- log .Debug ("Cleaner found the following git directories to delete: %s " , dirsToDelete )
97+ appsToDelete := getDiff (nsList .Items , gitDirs )
98+ if len (appsToDelete ) > 0 {
99+ log .Printf ("Cleaner found the following %d apps to delete: %v " , len ( appsToDelete ), appsToDelete )
100100 } else {
101- log .Debug ("Cleaner found no git directories to delete" )
101+ log .Printf ("Cleaner found no apps to delete" )
102102 }
103- for _ , dirToDelete := range dirsToDelete {
104- if err := repoLock .Lock (dirToDelete , time .Duration (0 )); err != nil {
105- log .Err ("Cleaner error locking repository %s for deletion (%s)" , dirToDelete , err )
103+ for _ , appToDelete := range appsToDelete {
104+ if err := repoLock .Lock (appToDelete , time .Duration (0 )); err != nil {
105+ log .Printf ("Cleaner error locking repository %s for deletion (%s)" , appToDelete , err )
106106 continue
107107 }
108+ dirToDelete := appToDelete + dotGitSuffix
109+ log .Printf ("Cleaner deleting %s" , dirToDelete )
108110 if err := os .RemoveAll (dirToDelete ); err != nil {
109- log .Err ("Cleaner error removing deleted app %s (%s)" , dirToDelete , err )
111+ log .Printf ("Cleaner error removing deleted app %s (%s)" , dirToDelete , err )
110112 }
111- if err := repoLock .Unlock (dirToDelete , time .Duration (0 )); err != nil {
112- log .Err ("Cleaner error unlocking repository %s for deletion (%s)" , dirToDelete , err )
113+ log .Printf ("Cleaner deleted %s" , dirToDelete )
114+
115+ if err := repoLock .Unlock (appToDelete , time .Duration (0 )); err != nil {
116+ log .Printf ("Cleaner error unlocking repository %s for deletion (%s)" , appToDelete , err )
113117 continue
114118 }
115119 }
0 commit comments