@@ -1037,7 +1037,7 @@ fn test_tcp_columns_by_root_chunked_rpc() {
10371037 loop {
10381038 match sender. next_event ( ) . await {
10391039 NetworkEvent :: PeerConnectedOutgoing ( peer_id) => {
1040- tracing :: info!( "Sending RPC" ) ;
1040+ info ! ( "Sending RPC" ) ;
10411041 tokio:: time:: sleep ( Duration :: from_secs ( 1 ) ) . await ;
10421042 sender
10431043 . send_request ( peer_id, AppRequestId :: Router , rpc_request. clone ( ) )
@@ -1051,7 +1051,7 @@ fn test_tcp_columns_by_root_chunked_rpc() {
10511051 Response :: DataColumnsByRoot ( Some ( sidecar) ) => {
10521052 assert_eq ! ( sidecar, data_column. clone( ) ) ;
10531053 messages_received += 1 ;
1054- tracing :: info!( "Chunk received" ) ;
1054+ info ! ( "Chunk received" ) ;
10551055 }
10561056 Response :: DataColumnsByRoot ( None ) => {
10571057 // should be exactly messages_to_send
@@ -1078,27 +1078,27 @@ fn test_tcp_columns_by_root_chunked_rpc() {
10781078 } => {
10791079 if request_type == rpc_request {
10801080 // send the response
1081- tracing :: info!( "Receiver got request" ) ;
1081+ info ! ( "Receiver got request" ) ;
10821082
10831083 for _ in 0 ..messages_to_send {
10841084 receiver. send_response (
10851085 peer_id,
10861086 inbound_request_id,
10871087 rpc_response. clone ( ) ,
10881088 ) ;
1089- tracing :: info!( "Sending message" ) ;
1089+ info ! ( "Sending message" ) ;
10901090 }
10911091 // send the stream termination
10921092 receiver. send_response (
10931093 peer_id,
10941094 inbound_request_id,
10951095 Response :: DataColumnsByRoot ( None ) ,
10961096 ) ;
1097- tracing :: info!( "Send stream term" ) ;
1097+ info ! ( "Send stream term" ) ;
10981098 }
10991099 }
11001100 e => {
1101- tracing :: info!( ?e, "Got event" ) ;
1101+ info ! ( ?e, "Got event" ) ;
11021102 } // Ignore other events
11031103 }
11041104 }
@@ -1179,7 +1179,7 @@ fn test_tcp_columns_by_range_chunked_rpc() {
11791179 loop {
11801180 match sender. next_event ( ) . await {
11811181 NetworkEvent :: PeerConnectedOutgoing ( peer_id) => {
1182- tracing :: info!( "Sending RPC" ) ;
1182+ info ! ( "Sending RPC" ) ;
11831183 sender
11841184 . send_request ( peer_id, AppRequestId :: Router , rpc_request. clone ( ) )
11851185 . unwrap ( ) ;
@@ -1192,7 +1192,7 @@ fn test_tcp_columns_by_range_chunked_rpc() {
11921192 Response :: DataColumnsByRange ( Some ( sidecar) ) => {
11931193 assert_eq ! ( sidecar, data_column. clone( ) ) ;
11941194 messages_received += 1 ;
1195- tracing :: info!( "Chunk received" ) ;
1195+ info ! ( "Chunk received" ) ;
11961196 }
11971197 Response :: DataColumnsByRange ( None ) => {
11981198 // should be exactly messages_to_send
@@ -1219,23 +1219,23 @@ fn test_tcp_columns_by_range_chunked_rpc() {
12191219 } => {
12201220 if request_type == rpc_request {
12211221 // send the response
1222- tracing :: info!( "Receiver got request" ) ;
1222+ info ! ( "Receiver got request" ) ;
12231223
12241224 for _ in 0 ..messages_to_send {
12251225 receiver. send_response (
12261226 peer_id,
12271227 inbound_request_id,
12281228 rpc_response. clone ( ) ,
12291229 ) ;
1230- tracing :: info!( "Sending message" ) ;
1230+ info ! ( "Sending message" ) ;
12311231 }
12321232 // send the stream termination
12331233 receiver. send_response (
12341234 peer_id,
12351235 inbound_request_id,
12361236 Response :: DataColumnsByRange ( None ) ,
12371237 ) ;
1238- tracing :: info!( "Send stream term" ) ;
1238+ info ! ( "Send stream term" ) ;
12391239 }
12401240 }
12411241 _ => { } // Ignore other events
0 commit comments