gnosis/lighthouse
1
0
Fork 0
mirror of https://github.com/sigp/lighthouse.git synced 2026-03-22 14:24:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Enable stdout logging in rpc_tests (#7506)

Browse Source 
Currently `test_delayed_rpc_response` is flaky (possibly specific to Windows?), but I'm not sure why.


  Enabled stdout logging in rpc_tests. Note that in nextest, std output is only displayed when a test fails.
This commit is contained in:
Akihito Nakano
2025-05-22 11:14:48 +09:00
committed by GitHub
parent 2e96e9769b
commit a8035d7395
1 changed files with 15 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
beacon_node/lighthouse_network/tests/rpc_tests.rs
View File

@@ -55,7 +55,7 @@ fn bellatrix_block_large(spec: &ChainSpec) -> BeaconBlock<E> {
fn test_tcp_status_rpc() { fn test_tcp_status_rpc() {
// Set up the logging. // Set up the logging.
let log_level = "debug"; let log_level = "debug";
let enable_logging = false; let enable_logging = true;
build_tracing_subscriber(log_level, enable_logging); build_tracing_subscriber(log_level, enable_logging);
let rt = Arc::new(Runtime::new().unwrap()); let rt = Arc::new(Runtime::new().unwrap());
@@ -159,7 +159,7 @@ fn test_tcp_status_rpc() {
fn test_tcp_blocks_by_range_chunked_rpc() { fn test_tcp_blocks_by_range_chunked_rpc() {
// Set up the logging. // Set up the logging.
let log_level = "debug"; let log_level = "debug";
let enable_logging = false; let enable_logging = true;
build_tracing_subscriber(log_level, enable_logging); build_tracing_subscriber(log_level, enable_logging);
let messages_to_send = 6; let messages_to_send = 6;
@@ -304,7 +304,7 @@ fn test_tcp_blocks_by_range_chunked_rpc() {
fn test_blobs_by_range_chunked_rpc() { fn test_blobs_by_range_chunked_rpc() {
// Set up the logging. // Set up the logging.
let log_level = "debug"; let log_level = "debug";
let enable_logging = false; let enable_logging = true;
build_tracing_subscriber(log_level, enable_logging); build_tracing_subscriber(log_level, enable_logging);
let slot_count = 32; let slot_count = 32;
@@ -425,7 +425,7 @@ fn test_blobs_by_range_chunked_rpc() {
fn test_tcp_blocks_by_range_over_limit() { fn test_tcp_blocks_by_range_over_limit() {
// Set up the logging. // Set up the logging.
let log_level = "debug"; let log_level = "debug";
let enable_logging = false; let enable_logging = true;
build_tracing_subscriber(log_level, enable_logging); build_tracing_subscriber(log_level, enable_logging);
let messages_to_send = 5; let messages_to_send = 5;
@@ -529,7 +529,7 @@ fn test_tcp_blocks_by_range_over_limit() {
fn test_tcp_blocks_by_range_chunked_rpc_terminates_correctly() { fn test_tcp_blocks_by_range_chunked_rpc_terminates_correctly() {
// Set up the logging. // Set up the logging.
let log_level = "debug"; let log_level = "debug";
let enable_logging = false; let enable_logging = true;
build_tracing_subscriber(log_level, enable_logging); build_tracing_subscriber(log_level, enable_logging);
let messages_to_send = 10; let messages_to_send = 10;
@@ -666,7 +666,7 @@ fn test_tcp_blocks_by_range_chunked_rpc_terminates_correctly() {
fn test_tcp_blocks_by_range_single_empty_rpc() { fn test_tcp_blocks_by_range_single_empty_rpc() {
// Set up the logging. // Set up the logging.
let log_level = "trace"; let log_level = "trace";
let enable_logging = false; let enable_logging = true;
build_tracing_subscriber(log_level, enable_logging); build_tracing_subscriber(log_level, enable_logging);
let rt = Arc::new(Runtime::new().unwrap()); let rt = Arc::new(Runtime::new().unwrap());
@@ -787,7 +787,7 @@ fn test_tcp_blocks_by_range_single_empty_rpc() {
fn test_tcp_blocks_by_root_chunked_rpc() { fn test_tcp_blocks_by_root_chunked_rpc() {
// Set up the logging. // Set up the logging.
let log_level = "debug"; let log_level = "debug";
let enable_logging = false; let enable_logging = true;
build_tracing_subscriber(log_level, enable_logging); build_tracing_subscriber(log_level, enable_logging);
let messages_to_send = 6; let messages_to_send = 6;
@@ -932,7 +932,7 @@ fn test_tcp_blocks_by_root_chunked_rpc() {
fn test_tcp_blocks_by_root_chunked_rpc_terminates_correctly() { fn test_tcp_blocks_by_root_chunked_rpc_terminates_correctly() {
// Set up the logging. // Set up the logging.
let log_level = "debug"; let log_level = "debug";
let enable_logging = false; let enable_logging = true;
build_tracing_subscriber(log_level, enable_logging); build_tracing_subscriber(log_level, enable_logging);
let messages_to_send: u64 = 10; let messages_to_send: u64 = 10;
@@ -1143,7 +1143,7 @@ fn goodbye_test(log_level: &str, enable_logging: bool, protocol: Protocol) {
#[allow(clippy::single_match)] #[allow(clippy::single_match)]
fn tcp_test_goodbye_rpc() { fn tcp_test_goodbye_rpc() {
let log_level = "debug"; let log_level = "debug";
let enabled_logging = false; let enabled_logging = true;
goodbye_test(log_level, enabled_logging, Protocol::Tcp); goodbye_test(log_level, enabled_logging, Protocol::Tcp);
} }
@@ -1152,13 +1152,15 @@ fn tcp_test_goodbye_rpc() {
#[allow(clippy::single_match)] #[allow(clippy::single_match)]
fn quic_test_goodbye_rpc() { fn quic_test_goodbye_rpc() {
let log_level = "debug"; let log_level = "debug";
let enabled_logging = false; let enabled_logging = true;
goodbye_test(log_level, enabled_logging, Protocol::Quic); goodbye_test(log_level, enabled_logging, Protocol::Quic);
} }
// Test that the receiver delays the responses during response rate-limiting. // Test that the receiver delays the responses during response rate-limiting.
#[test] #[test]
fn test_delayed_rpc_response() { fn test_delayed_rpc_response() {
// Set up the logging.
build_tracing_subscriber("debug", true);
let rt = Arc::new(Runtime::new().unwrap()); let rt = Arc::new(Runtime::new().unwrap());
let spec = Arc::new(E::default_spec()); let spec = Arc::new(E::default_spec());
@@ -1214,7 +1216,7 @@ fn test_delayed_rpc_response() {
app_request_id: _, app_request_id: _,
response, response,
} => { } => {
debug!(%request_id, "Sender received"); debug!(%request_id, elapsed = ?request_sent_at.elapsed(), "Sender received response");
assert_eq!(response, rpc_response); assert_eq!(response, rpc_response);
match request_id { match request_id {
@@ -1289,6 +1291,8 @@ fn test_delayed_rpc_response() {
// once, thanks to the self-limiter on the sender side. // once, thanks to the self-limiter on the sender side.
#[test] #[test]
fn test_active_requests() { fn test_active_requests() {
// Set up the logging.
build_tracing_subscriber("debug", true);
let rt = Arc::new(Runtime::new().unwrap()); let rt = Arc::new(Runtime::new().unwrap());
let spec = Arc::new(E::default_spec()); let spec = Arc::new(E::default_spec());