@@ -153,15 +153,15 @@ extern "C" fn init() {
153
153
let ( connection_reader, connection_writer) = connection. split ( ) ;
154
154
155
155
let stream = ProxyChains :: connect ( target, config ( ) ) . await ;
156
-
157
- if let Ok ( mut stream) = stream {
158
- let ( mut reader, mut writer) = stream. split ( ) ;
156
+ match stream {
157
+ Ok ( mut stream) => {
158
+ let ( mut reader, mut writer) = stream. split ( ) ;
159
159
let _ = futures:: join!(
160
160
copy( connection_reader, & mut writer) ,
161
161
copy( & mut reader, connection_writer)
162
162
) ;
163
- } else {
164
- // LOG: failed to connect proxychains
163
+ } ,
164
+ Err ( e ) => eprintln ! ( "Failed to create proxychains. {}" , e . to_string ( ) ) ,
165
165
}
166
166
} ) ;
167
167
}
@@ -188,7 +188,7 @@ fn connect(socket: c_int, address: *const sockaddr, len: socklen_t) -> c_int {
188
188
if let Ok ( _) = ( * CONNECTION_SENDER ) . send ( ( socket as u32 , socket_addr) ) {
189
189
( * CONNECTION_LISTENER_WAKER ) . clone ( ) . wake ( ) ;
190
190
} else {
191
- // LOG: failed to send new connection info over the cahnnel
191
+ eprintln ! ( "Failed to send new connection info over the cahnnel." ) ;
192
192
}
193
193
}
194
194
}
@@ -214,7 +214,7 @@ fn write(fd: c_int, buf: *const c_void, count: size_t) -> ssize_t {
214
214
if let Ok ( _) = connection. get_reader_sender ( ) . send ( content) {
215
215
waker. wake ( ) ;
216
216
} else {
217
- // LOG: failed to redirect data to Connection
217
+ eprintln ! ( "Failed to get reader waker." ) ;
218
218
}
219
219
}
220
220
0 commit comments