fluencelabs/go-libp2p-kad-dht
1
0
Fork 0
mirror of https://github.com/fluencelabs/go-libp2p-kad-dht synced 2025-05-29 22:21:20 +00:00
Code Issues Projects Releases Wiki Activity

Merge pull request #455 from libp2p/fix/warn-to-error

Browse Source 
fix(providers): upgrade warnings to errors
This commit is contained in:
Steven Allen 2020-02-21 17:14:56 -05:00 committed by GitHub
commit de00be3435
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
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 { switch {
case err != nil: case err != nil:
// couldn't parse the time // couldn't parse the time
log.Warning("parsing providers record from disk: ", err) log.Error("parsing providers record from disk: ", err)
fallthrough fallthrough
case now.Sub(t) > ProvideValidity: case now.Sub(t) > ProvideValidity:
// or just expired // or just expired
err = dstore.Delete(ds.RawKey(e.Key)) err = dstore.Delete(ds.RawKey(e.Key))
if err != nil && err != ds.ErrNotFound { 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 continue
} }
@ -151,7 +151,7 @@ func loadProvSet(dstore ds.Datastore, k []byte) (*providerSet, error) {
log.Error("base32 decoding error: ", err) log.Error("base32 decoding error: ", err)
err = dstore.Delete(ds.RawKey(e.Key)) err = dstore.Delete(ds.RawKey(e.Key))
if err != nil && err != ds.ErrNotFound { 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 continue
} }
@ -264,13 +264,13 @@ func (pm *ProviderManager) run(proc goprocess.Process) {
switch { switch {
case err != nil: case err != nil:
// couldn't parse the time // couldn't parse the time
log.Warning("parsing providers record from disk: ", err) log.Error("parsing providers record from disk: ", err)
fallthrough fallthrough
case gcTime.Sub(t) > ProvideValidity: case gcTime.Sub(t) > ProvideValidity:
// or expired // or expired
err = pm.dstore.Delete(ds.RawKey(res.Key)) err = pm.dstore.Delete(ds.RawKey(res.Key))
if err != nil && err != ds.ErrNotFound { 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)
} }
} }