From 3cde8a9941d80e3f45727a32a86d10c0c4a40d66 Mon Sep 17 00:00:00 2001 From: Yao Zengzeng Date: Tue, 16 Jul 2019 00:52:03 +0800 Subject: [PATCH] pass error up if WALWathcer.segments() return err (#5741) Signed-off-by: YaoZengzeng --- storage/remote/wal_watcher.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/storage/remote/wal_watcher.go b/storage/remote/wal_watcher.go index 48fba02d65..c399c0bace 100644 --- a/storage/remote/wal_watcher.go +++ b/storage/remote/wal_watcher.go @@ -234,7 +234,7 @@ func (w *WALWatcher) run() error { func (w *WALWatcher) findSegmentForIndex(index int) (int, error) { refs, err := w.segments(w.walDir) if err != nil { - return -1, nil + return -1, err } for _, r := range refs { @@ -249,7 +249,7 @@ func (w *WALWatcher) findSegmentForIndex(index int) (int, error) { func (w *WALWatcher) firstAndLast() (int, int, error) { refs, err := w.segments(w.walDir) if err != nil { - return -1, -1, nil + return -1, -1, err } if len(refs) == 0 {