fluencelabs/go-libp2p-kad-dht
1
0
Fork 0
mirror of https://github.com/fluencelabs/go-libp2p-kad-dht synced 2025-04-24 14:22:13 +00:00
Code Issues Projects Releases Wiki Activity

fix(providers): upgrade warnings to errors

Browse Source 
These errors all mean something is going very wrong.
This commit is contained in:
Steven Allen 2020-02-18 12:40:49 -05:00
parent 2bceee5bb2
commit 9f0782bdac
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
providers/providers.go
View File

@ -133,13 +133,13 @@ func loadProvSet(dstore ds.Datastore, k []byte) (*providerSet, error) {
switch {
case err != nil:
// couldn't parse the time
log.Warning("parsing providers record from disk: ", err)
log.Error("parsing providers record from disk: ", err)
fallthrough
case now.Sub(t) > ProvideValidity:
// or just expired
err = dstore.Delete(ds.RawKey(e.Key))
if err != nil && err != ds.ErrNotFound {
log.Warning("failed to remove provider record from disk: ", err)
log.Error("failed to remove provider record from disk: ", err)
}
continue
}
@ -151,7 +151,7 @@ func loadProvSet(dstore ds.Datastore, k []byte) (*providerSet, error) {
log.Error("base32 decoding error: ", err)
err = dstore.Delete(ds.RawKey(e.Key))
if err != nil && err != ds.ErrNotFound {
log.Warning("failed to remove provider record from disk: ", err)
log.Error("failed to remove provider record from disk: ", err)
}
continue
}
@ -264,13 +264,13 @@ func (pm *ProviderManager) run(proc goprocess.Process) {
switch {
case err != nil:
// couldn't parse the time
log.Warning("parsing providers record from disk: ", err)
log.Error("parsing providers record from disk: ", err)
fallthrough
case gcTime.Sub(t) > ProvideValidity:
// or expired
err = pm.dstore.Delete(ds.RawKey(res.Key))
if err != nil && err != ds.ErrNotFound {
log.Warning("failed to remove provider record from disk: ", err)
log.Error("failed to remove provider record from disk: ", err)
}
}