fix: exclude context canccel error from forward error counting

proxyd/backend.go

@@ -383,6 +383,8 @@ func (b *Backend) Forward(ctx context.Context, reqs []*RPCReq, isBatch bool) ([]
 		res, err := b.doForward(ctx, reqs, isBatch)
 		switch err {
 		case nil: // do nothing
+		case context.Canceled:
+			return nil, err
 		case ErrBackendResponseTooLarge:
 			log.Warn(
 				"backend response too large",
@@ -583,6 +585,10 @@ func (b *Backend) doForward(ctx context.Context, rpcReqs []*RPCReq, isBatch bool
 	start := time.Now()
 	httpRes, err := b.client.DoLimited(httpReq)
 	if err != nil {
+		// if it's canceld, we don't want to count it as an error
+		if errors.Is(err, context.Canceled) {
+			return nil, err
+		}
 		b.intermittentErrorsSlidingWindow.Incr()
 		RecordBackendNetworkErrorRateSlidingWindow(b, b.ErrorRate())
 		return nil, wrapErr(err, "error in backend request")
@@ -1327,6 +1333,9 @@ type LimitedHTTPClient struct {
 
 func (c *LimitedHTTPClient) DoLimited(req *http.Request) (*http.Response, error) {
 	if err := c.sem.Acquire(req.Context(), 1); err != nil {
+		if errors.Is(err, context.Canceled) {
+			return nil, err
+		}
 		tooManyRequestErrorsTotal.WithLabelValues(c.backendName).Inc()
 		return nil, wrapErr(err, "too many requests")
 	}
@@ -1406,6 +1415,14 @@ func (bg *BackendGroup) ForwardRequestToBackendGroup(
 		if len(rpcReqs) > 0 {
 
 			res, err = back.Forward(ctx, rpcReqs, isBatch)
+			if err != nil && errors.Is(err, context.Canceled) {
+				log.Info("context canceled", "req_id", GetReqID(ctx), "auth", GetAuthCtx(ctx))
+				return &BackendGroupRPCResponse{
+					RPCRes:   nil,
+					ServedBy: "",
+					error:    err,
+				}
+			}
 
 			if errors.Is(err, ErrConsensusGetReceiptsCantBeBatched) ||
 				errors.Is(err, ErrConsensusGetReceiptsInvalidTarget) ||

proxyd/backend_test.go

@@ -1,9 +1,12 @@
 package proxyd
 
 import (
+	"context"
+	"encoding/json"
 	"testing"
 
 	"github.com/stretchr/testify/assert"
+	"golang.org/x/sync/semaphore"
 )
 
 func TestStripXFF(t *testing.T) {
@@ -20,3 +23,22 @@ func TestStripXFF(t *testing.T) {
 		assert.Equal(t, test.out, actual)
 	}
 }
+
+func TestForwardContextCanceled(t *testing.T) {
+	ctx, cancel := context.WithCancel(context.Background())
+	cancel()
+	sem := semaphore.NewWeighted(100)
+	backend := NewBackend(
+		"test",
+		"http://localhost:8545",
+		"ws://localhost:8545",
+		sem,
+	)
+	_, err := backend.Forward(ctx, []*RPCReq{
+		{JSONRPC: "2.0", Method: "eth_blockNumber", ID: json.RawMessage("1")},
+	}, true)
+	assert.ErrorIs(t, context.Canceled, err)
+	assert.Equal(t, uint(1), backend.networkRequestsSlidingWindow.Count())
+	assert.Equal(t, uint(0), backend.intermittentErrorsSlidingWindow.Count())
+	assert.Zero(t, backend.ErrorRate())
+}