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

agent: retrying when uploading

This commit is contained in:
Gyu-Ho Lee 2016-03-22 00:52:40 -07:00
parent b345242fcb
commit 934c2dec84
1 changed files with 23 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
agent/agent.go
View File

@ -464,18 +464,34 @@ func (t *transporterServer) Transfer(ctx context.Context, r *Request) (*Response
} }
log.Printf("Uploading %s to %s", srcDatabaseLogPath, dstDatabaseLogPath) log.Printf("Uploading %s to %s", srcDatabaseLogPath, dstDatabaseLogPath)
if err := u.UploadFile(t.req.GoogleCloudStorageBucketName, srcDatabaseLogPath, dstDatabaseLogPath); err != nil { var uerr error
log.Fatal(err) for k := 0; k < 5; k++ {
if uerr = u.UploadFile(t.req.GoogleCloudStorageBucketName, srcDatabaseLogPath, dstDatabaseLogPath); uerr != nil {
log.Println(uerr)
continue
} else {
break
}
} }
log.Printf("Uploading %s to %s", srcMonitorResultPath, dstMonitorResultPath) log.Printf("Uploading %s to %s", srcMonitorResultPath, dstMonitorResultPath)
if err := u.UploadFile(t.req.GoogleCloudStorageBucketName, srcMonitorResultPath, dstMonitorResultPath); err != nil { for k := 0; k < 5; k++ {
log.Fatal(err) if uerr = u.UploadFile(t.req.GoogleCloudStorageBucketName, srcMonitorResultPath, dstMonitorResultPath); uerr != nil {
log.Println(uerr)
continue
} else {
break
}
} }
log.Printf("Uploading %s", srcAgentLogPath, dstAgentLogPath) log.Printf("Uploading %s to %s", srcAgentLogPath, dstAgentLogPath)
if err := u.UploadFile(t.req.GoogleCloudStorageBucketName, srcAgentLogPath, dstAgentLogPath); err != nil { for k := 0; k < 5; k++ {
log.Fatal(err) if uerr = u.UploadFile(t.req.GoogleCloudStorageBucketName, srcAgentLogPath, dstAgentLogPath); uerr != nil {
log.Println(uerr)
continue
} else {
break
}
} }
return return