File tree 1 file changed +3
-3
lines changed
1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -77,7 +77,7 @@ impl ChaosProxy {
77
77
. expect ( "failed to send the restore_networking message" ) ;
78
78
}
79
79
80
- async fn server_loop ( self : Arc < Self > , initial_listener : TcpListener ) -> Result < ( ) , Error > {
80
+ async fn server_loop ( & self , initial_listener : TcpListener ) -> Result < ( ) , Error > {
81
81
let mut listener = Some ( initial_listener) ;
82
82
83
83
let mut break_networking_recv = self . break_networking_send . subscribe ( ) ;
@@ -87,7 +87,7 @@ impl ChaosProxy {
87
87
if let Some ( l) = & listener {
88
88
tokio:: select! {
89
89
accepted = l. accept( ) => {
90
- self . clone ( ) . accept_connection( accepted?. 0 ) . await ?;
90
+ self . accept_connection( accepted?. 0 ) . await ?;
91
91
} ,
92
92
93
93
_ = break_networking_recv. recv( ) => {
@@ -104,7 +104,7 @@ impl ChaosProxy {
104
104
}
105
105
}
106
106
107
- async fn accept_connection ( self : Arc < Self > , accepted : TcpStream ) -> Result < ( ) , Error > {
107
+ async fn accept_connection ( & self , accepted : TcpStream ) -> Result < ( ) , Error > {
108
108
let ( client_read, client_write) = accepted. into_split ( ) ;
109
109
let ( backend_read, backend_write) = TcpStream :: connect ( & self . backend_address )
110
110
. await ?
You can’t perform that action at this time.
0 commit comments