Skip to content

Commit c08b4bb

Browse files
committed
simulators/eth/engine: Optimize log level instantiation.
1 parent d0511a3 commit c08b4bb

File tree

2 files changed

+13
-11
lines changed

2 files changed

+13
-11
lines changed

simulators/ethereum/engine/client/hive_rpc/hive_rpc.go

Lines changed: 7 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -7,6 +7,8 @@ import (
77
"math/big"
88
"net"
99
"net/http"
10+
"os"
11+
"strconv"
1012
"strings"
1113
"sync"
1214
"time"
@@ -108,10 +110,12 @@ func (s HiveRPCEngineStarter) StartClient(T *hivesim.T, testContext context.Cont
108110
if err := CheckEthEngineLive(c); err != nil {
109111
return nil, fmt.Errorf("Engine/Eth ports were never open for client: %v", err)
110112
}
113+
hiveLogLevel, _ := strconv.Atoi(os.Getenv("HIVE_LOGLEVEL"))
111114
ec := NewHiveRPCEngineClient(c, enginePort, ethPort, jwtSecret, ttd, &helper.LoggingRoundTrip{
112-
Logger: T,
113-
ID: c.Container,
114-
Inner: http.DefaultTransport,
115+
Logger: T,
116+
ID: c.Container,
117+
Inner: http.DefaultTransport,
118+
LogLevel: hiveLogLevel,
115119
})
116120
return ec, nil
117121
}

simulators/ethereum/engine/helper/helper.go

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -2,7 +2,6 @@ package helper
22

33
import (
44
"context"
5-
"strconv"
65
"sync"
76
"time"
87

@@ -39,9 +38,10 @@ type LogF interface {
3938
}
4039

4140
type LoggingRoundTrip struct {
42-
Logger LogF
43-
ID string
44-
Inner http.RoundTripper
41+
Logger LogF
42+
ID string
43+
Inner http.RoundTripper
44+
LogLevel int
4545
}
4646

4747
const MAX_LOG_BYTES = 1024 * 4
@@ -54,9 +54,7 @@ func (rt *LoggingRoundTrip) RoundTrip(req *http.Request) (*http.Response, error)
5454
return nil, err
5555
}
5656
reqLogBytes := bytes.TrimSpace(reqBytes[:])
57-
58-
hiveLogLevel, _ := strconv.Atoi(os.Getenv("HIVE_LOGLEVEL"))
59-
reqTrimLogs := len(reqLogBytes) > MAX_LOG_BYTES && hiveLogLevel <= 3
57+
reqTrimLogs := len(reqLogBytes) > MAX_LOG_BYTES && rt.LogLevel <= 3
6058
if reqTrimLogs {
6159
rt.Logger.Logf(">> (%s) %s... (Log trimmed)", rt.ID, reqLogBytes[:MAX_LOG_BYTES])
6260
} else {
@@ -81,7 +79,7 @@ func (rt *LoggingRoundTrip) RoundTrip(req *http.Request) (*http.Response, error)
8179
respCopy.Body = io.NopCloser(bytes.NewReader(respBytes))
8280
respLogBytes := bytes.TrimSpace(respBytes[:])
8381

84-
respTrimLogs := len(respLogBytes) > MAX_LOG_BYTES && hiveLogLevel <= 3
82+
respTrimLogs := len(respLogBytes) > MAX_LOG_BYTES && rt.LogLevel <= 3
8583
if respTrimLogs {
8684
rt.Logger.Logf("<< (%s) %s... (Log trimmed)", rt.ID, respLogBytes[:MAX_LOG_BYTES])
8785
} else {

0 commit comments

Comments
 (0)