@@ -86,7 +86,7 @@ impl Connection {
86
86
if event_receiver. recv ( ) . await . is_none ( ) {
87
87
return ;
88
88
}
89
- peer_manager. pm ( ) . process_events ( ) ;
89
+ peer_manager. as_ref ( ) . process_events ( ) ;
90
90
}
91
91
}
92
92
@@ -130,15 +130,15 @@ impl Connection {
130
130
tokio:: select! {
131
131
v = write_avail_receiver. recv( ) => {
132
132
assert!( v. is_some( ) ) ; // We can't have dropped the sending end, its in the us Arc!
133
- if peer_manager. pm ( ) . write_buffer_space_avail( & mut our_descriptor) . is_err( ) {
133
+ if peer_manager. as_ref ( ) . write_buffer_space_avail( & mut our_descriptor) . is_err( ) {
134
134
break Disconnect :: CloseConnection ;
135
135
}
136
136
} ,
137
137
_ = read_wake_receiver. recv( ) => { } ,
138
138
read = reader. read( & mut buf) , if !read_paused => match read {
139
139
Ok ( 0 ) => break Disconnect :: PeerDisconnected ,
140
140
Ok ( len) => {
141
- let read_res = peer_manager. pm ( ) . read_event( & mut our_descriptor, & buf[ 0 ..len] ) ;
141
+ let read_res = peer_manager. as_ref ( ) . read_event( & mut our_descriptor, & buf[ 0 ..len] ) ;
142
142
let mut us_lock = us. lock( ) . unwrap( ) ;
143
143
match read_res {
144
144
Ok ( pause_read) => {
@@ -167,8 +167,8 @@ impl Connection {
167
167
let _ = writer. shutdown ( ) . await ;
168
168
}
169
169
if let Disconnect :: PeerDisconnected = disconnect_type {
170
- peer_manager. pm ( ) . socket_disconnected ( & our_descriptor) ;
171
- peer_manager. pm ( ) . process_events ( ) ;
170
+ peer_manager. as_ref ( ) . socket_disconnected ( & our_descriptor) ;
171
+ peer_manager. as_ref ( ) . process_events ( ) ;
172
172
}
173
173
}
174
174
@@ -225,7 +225,7 @@ where PM::Target: APeerManager<Descriptor = SocketDescriptor> {
225
225
#[ cfg( test) ]
226
226
let last_us = Arc :: clone ( & us) ;
227
227
228
- let handle_opt = if peer_manager. pm ( ) . new_inbound_connection ( SocketDescriptor :: new ( us. clone ( ) ) , remote_addr) . is_ok ( ) {
228
+ let handle_opt = if peer_manager. as_ref ( ) . new_inbound_connection ( SocketDescriptor :: new ( us. clone ( ) ) , remote_addr) . is_ok ( ) {
229
229
Some ( tokio:: spawn ( Connection :: schedule_read ( peer_manager, us, reader, read_receiver, write_receiver) ) )
230
230
} else {
231
231
// Note that we will skip socket_disconnected here, in accordance with the PeerManager
@@ -267,7 +267,7 @@ where PM::Target: APeerManager<Descriptor = SocketDescriptor> {
267
267
let ( reader, mut write_receiver, read_receiver, us) = Connection :: new ( stream) ;
268
268
#[ cfg( test) ]
269
269
let last_us = Arc :: clone ( & us) ;
270
- let handle_opt = if let Ok ( initial_send) = peer_manager. pm ( ) . new_outbound_connection ( their_node_id, SocketDescriptor :: new ( us. clone ( ) ) , remote_addr) {
270
+ let handle_opt = if let Ok ( initial_send) = peer_manager. as_ref ( ) . new_outbound_connection ( their_node_id, SocketDescriptor :: new ( us. clone ( ) ) , remote_addr) {
271
271
Some ( tokio:: spawn ( async move {
272
272
// We should essentially always have enough room in a TCP socket buffer to send the
273
273
// initial 10s of bytes. However, tokio running in single-threaded mode will always
@@ -286,7 +286,7 @@ where PM::Target: APeerManager<Descriptor = SocketDescriptor> {
286
286
} ,
287
287
_ => {
288
288
eprintln ! ( "Failed to write first full message to socket!" ) ;
289
- peer_manager. pm ( ) . socket_disconnected ( & SocketDescriptor :: new ( Arc :: clone ( & us) ) ) ;
289
+ peer_manager. as_ref ( ) . socket_disconnected ( & SocketDescriptor :: new ( Arc :: clone ( & us) ) ) ;
290
290
break Err ( ( ) ) ;
291
291
}
292
292
}
0 commit comments