From e53660318ea436a9d104e64564c386e3fa9680a9 Mon Sep 17 00:00:00 2001 From: Pratik Patil Date: Thu, 1 May 2025 14:09:04 +0530 Subject: [PATCH] upstream: fixed consensus/* --- consensus/bor/bor_test.go | 2 +- consensus/bor/heimdall/client.go | 2 +- consensus/bor/heimdall/metrics.go | 22 +++++++++++----------- 3 files changed, 13 insertions(+), 13 deletions(-) diff --git a/consensus/bor/bor_test.go b/consensus/bor/bor_test.go index ed839d3476..cb087ad9e2 100644 --- a/consensus/bor/bor_test.go +++ b/consensus/bor/bor_test.go @@ -80,7 +80,7 @@ func TestGenesisContractChange(t *testing.T) { b.Finalize(chain, h, statedb, &types.Body{Withdrawals: nil, Transactions: nil, Uncles: nil}) // write state to database - root, err := statedb.Commit(0, false) + root, err := statedb.Commit(0, false, true) require.NoError(t, err) require.NoError(t, statedb.Database().TrieDB().Commit(root, true)) diff --git a/consensus/bor/heimdall/client.go b/consensus/bor/heimdall/client.go index ed7ca31b6d..02e4041f0d 100644 --- a/consensus/bor/heimdall/client.go +++ b/consensus/bor/heimdall/client.go @@ -346,7 +346,7 @@ func Fetch[T any](ctx context.Context, request *Request) (*T, error) { isSuccessful := false defer func() { - if metrics.Enabled { + if metrics.Enabled() { sendMetrics(ctx, request.start, isSuccessful) } }() diff --git a/consensus/bor/heimdall/metrics.go b/consensus/bor/heimdall/metrics.go index 8ad686f373..c2cbc7feb2 100644 --- a/consensus/bor/heimdall/metrics.go +++ b/consensus/bor/heimdall/metrics.go @@ -12,8 +12,8 @@ type ( requestType string meter struct { - request map[bool]metrics.Meter // map[isSuccessful]metrics.Meter - timer metrics.Timer + request map[bool]*metrics.Meter // map[isSuccessful]metrics.Meter + timer *metrics.Timer } ) @@ -41,63 +41,63 @@ func getRequestType(ctx context.Context) (requestType, bool) { var ( requestMeters = map[requestType]meter{ stateSyncRequest: { - request: map[bool]metrics.Meter{ + request: map[bool]*metrics.Meter{ true: metrics.NewRegisteredMeter("client/requests/statesync/valid", nil), false: metrics.NewRegisteredMeter("client/requests/statesync/invalid", nil), }, timer: metrics.NewRegisteredTimer("client/requests/statesync/duration", nil), }, spanRequest: { - request: map[bool]metrics.Meter{ + request: map[bool]*metrics.Meter{ true: metrics.NewRegisteredMeter("client/requests/span/valid", nil), false: metrics.NewRegisteredMeter("client/requests/span/invalid", nil), }, timer: metrics.NewRegisteredTimer("client/requests/span/duration", nil), }, checkpointRequest: { - request: map[bool]metrics.Meter{ + request: map[bool]*metrics.Meter{ true: metrics.NewRegisteredMeter("client/requests/checkpoint/valid", nil), false: metrics.NewRegisteredMeter("client/requests/checkpoint/invalid", nil), }, timer: metrics.NewRegisteredTimer("client/requests/checkpoint/duration", nil), }, checkpointCountRequest: { - request: map[bool]metrics.Meter{ + request: map[bool]*metrics.Meter{ true: metrics.NewRegisteredMeter("client/requests/checkpointcount/valid", nil), false: metrics.NewRegisteredMeter("client/requests/checkpointcount/invalid", nil), }, timer: metrics.NewRegisteredTimer("client/requests/checkpointcount/duration", nil), }, milestoneRequest: { - request: map[bool]metrics.Meter{ + request: map[bool]*metrics.Meter{ true: metrics.NewRegisteredMeter("client/requests/milestone/valid", nil), false: metrics.NewRegisteredMeter("client/requests/milestone/invalid", nil), }, timer: metrics.NewRegisteredTimer("client/requests/milestone/duration", nil), }, milestoneCountRequest: { - request: map[bool]metrics.Meter{ + request: map[bool]*metrics.Meter{ true: metrics.NewRegisteredMeter("client/requests/milestonecount/valid", nil), false: metrics.NewRegisteredMeter("client/requests/milestonecount/invalid", nil), }, timer: metrics.NewRegisteredTimer("client/requests/milestonecount/duration", nil), }, milestoneNoAckRequest: { - request: map[bool]metrics.Meter{ + request: map[bool]*metrics.Meter{ true: metrics.NewRegisteredMeter("client/requests/milestonenoack/valid", nil), false: metrics.NewRegisteredMeter("client/requests/milestonenoack/invalid", nil), }, timer: metrics.NewRegisteredTimer("client/requests/milestonenoack/duration", nil), }, milestoneLastNoAckRequest: { - request: map[bool]metrics.Meter{ + request: map[bool]*metrics.Meter{ true: metrics.NewRegisteredMeter("client/requests/milestonelastnoack/valid", nil), false: metrics.NewRegisteredMeter("client/requests/milestonelastnoack/invalid", nil), }, timer: metrics.NewRegisteredTimer("client/requests/milestonelastnoack/duration", nil), }, milestoneIDRequest: { - request: map[bool]metrics.Meter{ + request: map[bool]*metrics.Meter{ true: metrics.NewRegisteredMeter("client/requests/milestoneid/valid", nil), false: metrics.NewRegisteredMeter("client/requests/milestoneid/invalid", nil), },