@@ -10,6 +10,7 @@ use tokio::{
10
10
runtime:: Runtime ,
11
11
sync:: broadcast:: Sender ,
12
12
} ;
13
+ use tracing:: error;
13
14
use url:: Url ;
14
15
15
16
pub ( crate ) struct ChaosProxy {
@@ -42,8 +43,8 @@ impl ChaosProxy {
42
43
43
44
let instance_clone = instance. clone ( ) ;
44
45
instance. runtime . spawn ( async move {
45
- if let Err ( err ) = instance_clone. server_loop ( listener) . await {
46
- eprintln ! ( "ChaosProxy server error: {err} " ) ;
46
+ if let Err ( error ) = instance_clone. server_loop ( listener) . await {
47
+ error ! ( %error , "ChaosProxy server error" ) ;
47
48
}
48
49
} ) ;
49
50
@@ -119,15 +120,17 @@ impl ChaosProxy {
119
120
120
121
let break_networking_send = self . break_networking_send . clone ( ) ;
121
122
tokio:: spawn ( async move {
122
- if let Err ( err) = proxy_data ( break_networking_send, client_read, backend_write) . await {
123
- eprintln ! ( "ChaosProxy connection error: {err}" ) ;
123
+ if let Err ( error) = proxy_data ( break_networking_send, client_read, backend_write) . await
124
+ {
125
+ error ! ( %error, "ChaosProxy connection error" ) ;
124
126
}
125
127
} ) ;
126
128
127
129
let break_networking_send = self . break_networking_send . clone ( ) ;
128
130
tokio:: spawn ( async move {
129
- if let Err ( err) = proxy_data ( break_networking_send, backend_read, client_write) . await {
130
- eprintln ! ( "ChaosProxy connection error: {err}" ) ;
131
+ if let Err ( error) = proxy_data ( break_networking_send, backend_read, client_write) . await
132
+ {
133
+ error ! ( %error, "ChaosProxy connection error" ) ;
131
134
}
132
135
} ) ;
133
136
0 commit comments