forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-18 09:53:48 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Merge pull request #455 from ethersphere/correct_log_line

Browse source 
swarm/api: remove redundant log line
This commit is contained in:
Viktor Trón 2018-04-27 14:47:33 +02:00 committed by GitHub
commit 1e2b2f8a93
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 8 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
swarm/api/http/server.go
View file

@ -863,8 +863,7 @@ func (s *Server) ServeHTTP(rw http.ResponseWriter, r *http.Request) {
req.uri = uri req.uri = uri
log.Debug("parsed request path", "ruid", req.ruid, "method", req.Method, "uri", req.uri) log.Debug("parsed request path", "ruid", req.ruid, "method", req.Method, "uri.Addr", req.uri.Addr, "uri.Path", req.uri.Path, "uri.Scheme", req.uri.Scheme)
log.Debug("parsed request path", "uri.Addr", req.uri.Addr, "uri.path", req.uri.Path, "uri.Scheme", req.uri.Scheme)
switch r.Method { switch r.Method {
case "POST": case "POST":

5
swarm/storage/localstore.go
View file

@ -211,6 +211,11 @@ func (self *LocalStore) GetOrCreateRequest(key Key) (chunk *Chunk, created bool)
return chunk, true return chunk, true
} }
// RequestsCacheLen returns the current number of outgoing requests stored in the cache
func (self *LocalStore) RequestsCacheLen() int {
return self.memStore.requests.Len()
}
// Close the local store // Close the local store
func (self *LocalStore) Close() { func (self *LocalStore) Close() {
self.DbStore.Close() self.DbStore.Close()

3
swarm/swarm.go
View file

@ -58,7 +58,7 @@ var (
startCounter = metrics.NewRegisteredCounter("stack,start", nil) startCounter = metrics.NewRegisteredCounter("stack,start", nil)
stopCounter = metrics.NewRegisteredCounter("stack,stop", nil) stopCounter = metrics.NewRegisteredCounter("stack,stop", nil)
uptimeGauge = metrics.NewRegisteredGauge("stack.uptime", nil) uptimeGauge = metrics.NewRegisteredGauge("stack.uptime", nil)
cacheSizeGauge = metrics.NewRegisteredGauge("storage.db.cache.size", nil) requestsCacheGauge = metrics.NewRegisteredGauge("storage.cache.requests.size", nil)
) )
// the swarm stack // the swarm stack
@ -420,6 +420,7 @@ func (self *Swarm) periodicallyUpdateGauges() {
func (self *Swarm) updateGauges() { func (self *Swarm) updateGauges() {
uptimeGauge.Update(time.Since(startTime).Nanoseconds()) uptimeGauge.Update(time.Since(startTime).Nanoseconds())
requestsCacheGauge.Update(int64(self.lstore.RequestsCacheLen()))
} }
// implements the node.Service interface // implements the node.Service interface