provider queue: don't repeatedly retry the same item if we fail
License: MIT Signed-off-by: Steven Allen <steven@stebalien.com>
Steven Allen committed
Apr 4, 2019 at 04:34 UTC
1c3c138733423ef5c4d8ae59733df0c7d8216530
1 file changed
+6
-5
provider/queue.go
+6
-5
@@ -72,13 +72,14 @@ func (q *Queue) nextEntry() (datastore.Key, cid.Cid) {
72
key := q.queueKey(q.head)
73
value, err := q.ds.Get(key)
74
75
- if err == datastore.ErrNotFound {
76
- log.Warningf("Error missing entry in queue: %s", key)
75
+ if err != nil {
76
+ if err == datastore.ErrNotFound {
77
+ log.Warningf("Error missing entry in queue: %s", key)
78
+ } else {
79
+ log.Errorf("Error fetching from queue: %s", err)
80
+ }
81
q.head++ // move on
82
continue
79
- } else if err != nil {
80
- log.Warningf("Error fetching from queue: %s", err)
81
- continue
83
}
84
85
c, err := cid.Parse(value)