Diff: adapt wait time according to replication interval
parent
e277d8da24
commit
6f99b41d13
|
@ -71,13 +71,23 @@ func newDownloader(dest, url string, seq int, interval time.Duration) *downloade
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
|
|
||||||
|
var naWaittime time.Duration
|
||||||
|
switch interval {
|
||||||
|
case 24 * time.Hour:
|
||||||
|
naWaittime = 5 * time.Minute
|
||||||
|
case time.Hour:
|
||||||
|
naWaittime = 60 * time.Second
|
||||||
|
default:
|
||||||
|
naWaittime = 10 * time.Second
|
||||||
|
}
|
||||||
|
|
||||||
dl := &downloader{
|
dl := &downloader{
|
||||||
baseUrl: url,
|
baseUrl: url,
|
||||||
dest: dest,
|
dest: dest,
|
||||||
lastSequence: seq,
|
lastSequence: seq,
|
||||||
interval: interval,
|
interval: interval,
|
||||||
errWaittime: 60 * time.Second,
|
errWaittime: 60 * time.Second,
|
||||||
naWaittime: 10 * time.Second,
|
naWaittime: naWaittime,
|
||||||
sequences: make(chan Sequence, 1),
|
sequences: make(chan Sequence, 1),
|
||||||
client: client,
|
client: client,
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue