fix(backend): fixed possible panic in the defer
This commit is contained in:
parent
c2d1bcdb35
commit
3132db6205
1 changed files with 9 additions and 6 deletions
|
|
@ -16,6 +16,8 @@ import (
|
|||
"openreplay/backend/pkg/storage"
|
||||
)
|
||||
|
||||
const RetryTimeout = 2 * time.Minute
|
||||
|
||||
func main() {
|
||||
log.SetFlags(log.LstdFlags | log.LUTC | log.Llongfile)
|
||||
|
||||
|
|
@ -28,17 +30,18 @@ func main() {
|
|||
if retryCount <= 0 {
|
||||
return
|
||||
}
|
||||
|
||||
file, err := os.Open(FS_DIR + "/" + key)
|
||||
defer file.Close()
|
||||
if err != nil {
|
||||
log.Printf("File error: %v; Will retry %v more time(s)\n", err, retryCount)
|
||||
time.AfterFunc(2*time.Minute, func() {
|
||||
time.AfterFunc(RetryTimeout, func() {
|
||||
uploadKey(key, retryCount-1)
|
||||
})
|
||||
} else {
|
||||
if err := storage.Upload(gzipFile(file), key, "application/octet-stream", true); err != nil {
|
||||
log.Fatalf("Storage upload error: %v\n", err)
|
||||
}
|
||||
}
|
||||
defer file.Close()
|
||||
|
||||
if err := storage.Upload(gzipFile(file), key, "application/octet-stream", true); err != nil {
|
||||
log.Fatalf("Storage upload error: %v\n", err)
|
||||
}
|
||||
}
|
||||
|
||||
|
|
|
|||
Loading…
Add table
Reference in a new issue