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

rpc: address comments

Browse source
This commit is contained in:
rjl493456442 2020-04-01 18:21:40 +08:00
parent ad574507a6
commit c6cae32932
2 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
rpc/handler.go
View file

@ -333,14 +333,14 @@ func (h *handler) handleCall(cp *callProc, msg *jsonrpcMessage) *jsonrpcMessage
// Collect the statistics for RPC calls if metrics is enabled.
// We only care about pure rpc call. Filter out subscription.
if callb != h.unsubscribeCb {
jsonrpcRequestGauge.Inc(1)
rpcRequestGauge.Inc(1)
if answer.Error != nil {
failedReqeustGauge.Inc(1)
} else {
successfulRequestGauge.Inc(1)
}
jsonrpcServingTimer.UpdateSince(start)
newJsonrpcServingTimer(msg.Method, answer.Error == nil).UpdateSince(start)
rpcServingTimer.UpdateSince(start)
newRPCServingTimer(msg.Method, answer.Error == nil).UpdateSince(start)
}
return answer
}

12
rpc/metrics.go
View file

@ -23,17 +23,17 @@ import (
)
var (
jsonrpcRequestGauge = metrics.NewRegisteredGauge("rpc/jsonrpc/requests", nil)
successfulRequestGauge = metrics.NewRegisteredGauge("rpc/jsonrpc/success", nil)
failedReqeustGauge = metrics.NewRegisteredGauge("rpc/jsonrpc/failure", nil)
jsonrpcServingTimer = metrics.NewRegisteredTimer("rpc/jsonrpc/duration/all", nil)
rpcRequestGauge = metrics.NewRegisteredGauge("rpc/requests", nil)
successfulRequestGauge = metrics.NewRegisteredGauge("rpc/success", nil)
failedReqeustGauge = metrics.NewRegisteredGauge("rpc/failure", nil)
rpcServingTimer = metrics.NewRegisteredTimer("rpc/duration/all", nil)
)
func newJsonrpcServingTimer(method string, valid bool) metrics.Timer {
func newRPCServingTimer(method string, valid bool) metrics.Timer {
flag := "success"
if !valid {
flag = "failure"
}
m := fmt.Sprintf("rpc/jsonrpc/duration/%s/%s", method, flag)
m := fmt.Sprintf("rpc/duration/%s/%s", method, flag)
return metrics.GetOrRegisterTimer(m, nil)
}