yacloud/tunasync
1
0
Fork 0
mirror of https://github.com/tuna/tunasync.git synced 2025-04-20 11:42:43 +00:00
Code Issues Packages Projects Releases Wiki Activity

check Retry configuration in providers

Browse Source
This commit is contained in:
zyx 2019-04-13 11:01:56 +08:00
parent 1aa4ae9cc1
commit 9f91d90fc5
3 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
worker/cmd_provider.go
View File

@ -24,6 +24,9 @@ type cmdProvider struct {
func newCmdProvider(c cmdConfig) (*cmdProvider, error) { func newCmdProvider(c cmdConfig) (*cmdProvider, error) {
// TODO: check config options // TODO: check config options
if c.retry == 0 {
c.retry = defaultMaxRetry
}
provider := &cmdProvider{ provider := &cmdProvider{
baseProvider: baseProvider{ baseProvider: baseProvider{
name: c.name, name: c.name,

3
worker/rsync_provider.go
View File

@ -32,6 +32,9 @@ func newRsyncProvider(c rsyncConfig) (*rsyncProvider, error) {
if !strings.HasSuffix(c.upstreamURL, "/") { if !strings.HasSuffix(c.upstreamURL, "/") {
return nil, errors.New("rsync upstream URL should ends with /") return nil, errors.New("rsync upstream URL should ends with /")
} }
if c.retry == 0 {
c.retry = defaultMaxRetry
}
provider := &rsyncProvider{ provider := &rsyncProvider{
baseProvider: baseProvider{ baseProvider: baseProvider{
name: c.name, name: c.name,

3
worker/two_stage_rsync_provider.go
View File

@ -43,6 +43,9 @@ func newTwoStageRsyncProvider(c twoStageRsyncConfig) (*twoStageRsyncProvider, er
if !strings.HasSuffix(c.upstreamURL, "/") { if !strings.HasSuffix(c.upstreamURL, "/") {
return nil, errors.New("rsync upstream URL should ends with /") return nil, errors.New("rsync upstream URL should ends with /")
} }
if c.retry == 0 {
c.retry = defaultMaxRetry
}
provider := &twoStageRsyncProvider{ provider := &twoStageRsyncProvider{
baseProvider: baseProvider{ baseProvider: baseProvider{