forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-20 02:42:27 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/storage/localstore: add more context to pull sub log messages

Browse source
This commit is contained in:
Janos Guljas 2019-01-25 17:38:29 +01:00
parent ad5b329a39
commit 8d15e823f9
1 changed files with 10 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
swarm/storage/localstore/subscription_pull.go
View file

@ -20,6 +20,7 @@ import (
"bytes"
"context"
"errors"
"fmt"
"sync"
"github.com/ethereum/go-ethereum/log"
@ -117,7 +118,7 @@ func (db *DB) SubscribePull(ctx context.Context, bin uint8, since, until *ChunkD
// if until is reached
return
}
log.Error("localstore pull subscription iteration", "err", err)
log.Error("localstore pull subscription iteration", "bin", bin, "since", since, "until", until, "err", err)
return
}
case <-stopChan:
@ -131,7 +132,7 @@ func (db *DB) SubscribePull(ctx context.Context, bin uint8, since, until *ChunkD
case <-ctx.Done():
err := ctx.Err()
if err != nil {
log.Error("localstore pull subscription", "err", err)
log.Error("localstore pull subscription", "bin", bin, "since", since, "until", until, "err", err)
}
return
}
@ -164,6 +165,13 @@ type ChunkDescriptor struct {
StoreTimestamp int64
}
func (c *ChunkDescriptor) String() string {
if c == nil {
return "none"
}
return fmt.Sprintf("%s stored at %v", c.Address.Hex(), c.StoreTimestamp)
}
// triggerPullSubscriptions is used internally for starting iterations
// on Pull subscriptions for a particular bin. When new item with address
// that is in particular bin for DB's baseKey is added to pull index