diff options
| author | Viktor Trón <viktor.tron@gmail.com> | 2017-02-13 20:20:50 +0800 |
|---|---|---|
| committer | Felix Lange <fjl@users.noreply.github.com> | 2017-02-13 20:20:50 +0800 |
| commit | e23e86921b55cb1ee2fca6b6fb9ed91f5532f9fd (patch) | |
| tree | edbe1cd7381c69deae9b31df527d6ce1c6c664b3 /swarm/network/syncer.go | |
| parent | 65ed6a9def4d23bbe6109ae4b841a56510d0c476 (diff) | |
| download | go-tangerine-e23e86921b55cb1ee2fca6b6fb9ed91f5532f9fd.tar go-tangerine-e23e86921b55cb1ee2fca6b6fb9ed91f5532f9fd.tar.gz go-tangerine-e23e86921b55cb1ee2fca6b6fb9ed91f5532f9fd.tar.bz2 go-tangerine-e23e86921b55cb1ee2fca6b6fb9ed91f5532f9fd.tar.lz go-tangerine-e23e86921b55cb1ee2fca6b6fb9ed91f5532f9fd.tar.xz go-tangerine-e23e86921b55cb1ee2fca6b6fb9ed91f5532f9fd.tar.zst go-tangerine-e23e86921b55cb1ee2fca6b6fb9ed91f5532f9fd.zip | |
swarm/network: fix chunk integrity checks (#3665)
* swarm/network: integrity on incoming known chunks
* swarm/network: fix integrity check for incoming chunks
* swarm/storage: imrpoved integrity checking on chunks
* dbstore panics on corrupt chunk entry an prompts user to run cleandb
* memstore adds logging for garbage collection
* dbstore refactor item delete. correct partial deletes in Get
* cmd/swarm: added cleandb subcommand
Diffstat (limited to 'swarm/network/syncer.go')
| -rw-r--r-- | swarm/network/syncer.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/swarm/network/syncer.go b/swarm/network/syncer.go index e871666bd..b6b1ea3b6 100644 --- a/swarm/network/syncer.go +++ b/swarm/network/syncer.go @@ -438,7 +438,7 @@ LOOP: for priority = High; priority >= 0; priority-- { // the first priority channel that is non-empty will be assigned to keys if len(self.keys[priority]) > 0 { - glog.V(logger.Detail).Infof("syncer[%v]: reading request with priority %v", self.key.Log(), priority) + glog.V(logger.Detail).Infof("syncer[%v]: reading request with priority %v", self.key.Log(), priority) keys = self.keys[priority] break PRIORITIES } @@ -551,10 +551,10 @@ LOOP: } if sreq, err := self.newSyncRequest(req, priority); err == nil { // extract key from req - glog.V(logger.Detail).Infof("syncer(priority %v): request %v (synced = %v)", self.key.Log(), priority, req, state.Synced) + glog.V(logger.Detail).Infof("syncer[%v]: (priority %v): request %v (synced = %v)", self.key.Log(), priority, req, state.Synced) unsynced = append(unsynced, sreq) } else { - glog.V(logger.Warn).Infof("syncer(priority %v): error creating request for %v: %v)", self.key.Log(), priority, req, state.Synced, err) + glog.V(logger.Warn).Infof("syncer[%v]: (priority %v): error creating request for %v: %v)", self.key.Log(), priority, req, state.Synced, err) } } |