From 6f99b41d1392982f868b5f2ea08c44f26d8f6038 Mon Sep 17 00:00:00 2001 From: Yohan Boniface Date: Fri, 26 Jan 2018 09:35:31 +0100 Subject: [PATCH] Diff: adapt wait time according to replication interval --- replication/source.go | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/replication/source.go b/replication/source.go index 188d5c8..3bd9042 100644 --- a/replication/source.go +++ b/replication/source.go @@ -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{ baseUrl: url, dest: dest, lastSequence: seq, interval: interval, errWaittime: 60 * time.Second, - naWaittime: 10 * time.Second, + naWaittime: naWaittime, sequences: make(chan Sequence, 1), client: client, }