kubernetes
/
git-sync
mirror of https://github.com/kubernetes/git-sync.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Clean up global flRoot use

This commit is contained in:
Tim Hockin 2021-05-21 17:10:57 -07:00
parent 246584d9eb
commit e9e682e25e
1 changed files with 13 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

27
cmd/git-sync/main.go
View File

@ -164,6 +164,7 @@ const (
type customLogger struct { type customLogger struct {
logr.Logger logr.Logger
root string
errorFile string errorFile string
} }
@ -211,16 +212,16 @@ func (l *customLogger) exportError(content string) {
// writeContent writes the error content to the error file. // writeContent writes the error content to the error file.
func (l *customLogger) writeContent(content []byte) { func (l *customLogger) writeContent(content []byte) {
if _, err := os.Stat(*flRoot); os.IsNotExist(err) { if _, err := os.Stat(l.root); os.IsNotExist(err) {
fileMode := os.FileMode(0755) fileMode := os.FileMode(0755)
if err := os.Mkdir(*flRoot, fileMode); err != nil { if err := os.Mkdir(l.root, fileMode); err != nil {
l.Logger.Error(err, "can't create the root directory", "root", *flRoot) l.Logger.Error(err, "can't create the root directory", "root", l.root)
return return
} }
} }
tmpFile, err := ioutil.TempFile(*flRoot, "tmp-err-") tmpFile, err := ioutil.TempFile(l.root, "tmp-err-")
if err != nil { if err != nil {
l.Logger.Error(err, "can't create temporary error-file", "directory", *flRoot, "prefix", "tmp-err-") l.Logger.Error(err, "can't create temporary error-file", "directory", l.root, "prefix", "tmp-err-")
return return
} }
defer func() { defer func() {
@ -234,8 +235,9 @@ func (l *customLogger) writeContent(content []byte) {
return return
} }
if err := os.Rename(tmpFile.Name(), l.errorFile); err != nil { errorFile := filepath.Join(l.root, l.errorFile)
l.Logger.Error(err, "can't rename to error-file", "temp-file", tmpFile.Name(), "error-file", l.errorFile) if err := os.Rename(tmpFile.Name(), errorFile); err != nil {
l.Logger.Error(err, "can't rename to error-file", "temp-file", tmpFile.Name(), "error-file", errorFile)
return return
} }
} }
@ -245,11 +247,12 @@ func (l *customLogger) deleteErrorFile() {
if l.errorFile == "" { if l.errorFile == "" {
return return
} }
if err := os.Remove(l.errorFile); err != nil { errorFile := filepath.Join(l.root, l.errorFile)
if err := os.Remove(errorFile); err != nil {
if os.IsNotExist(err) { if os.IsNotExist(err) {
return return
} }
l.Logger.Error(err, "can't delete the error-file", "filename", l.errorFile) l.Logger.Error(err, "can't delete the error-file", "filename", errorFile)
} }
} }
@ -338,11 +341,7 @@ func main() {
setFlagDefaults() setFlagDefaults()
flag.Parse() flag.Parse()
var errorFile string log = &customLogger{glogr.New(), *flRoot, *flErrorFile}
if *flErrorFile != "" {
errorFile = filepath.Join(*flRoot, *flErrorFile)
}
log = &customLogger{glogr.New(), errorFile}
if *flVer { if *flVer {
fmt.Println(version.VERSION) fmt.Println(version.VERSION)