@@ -1024,7 +1024,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref> PeerManager<D
10241024 wire:: Message :: ChannelAnnouncement ( ref msg) => {
10251025 let encoded_msg = encode_msg ! ( msg) ;
10261026
1027- for ( _, ref mut peer) in peers. peers . iter_mut ( ) {
1027+ for ( _, peer) in peers. peers . iter_mut ( ) {
10281028 if !peer. channel_encryptor . is_ready_for_encryption ( ) || peer. their_features . is_none ( ) ||
10291029 !peer. should_forward_channel_announcement ( msg. contents . short_channel_id ) {
10301030 continue
@@ -1045,7 +1045,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref> PeerManager<D
10451045 wire:: Message :: NodeAnnouncement ( ref msg) => {
10461046 let encoded_msg = encode_msg ! ( msg) ;
10471047
1048- for ( _, ref mut peer) in peers. peers . iter_mut ( ) {
1048+ for ( _, peer) in peers. peers . iter_mut ( ) {
10491049 if !peer. channel_encryptor . is_ready_for_encryption ( ) || peer. their_features . is_none ( ) ||
10501050 !peer. should_forward_node_announcement ( msg. contents . node_id ) {
10511051 continue
@@ -1065,7 +1065,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref> PeerManager<D
10651065 wire:: Message :: ChannelUpdate ( ref msg) => {
10661066 let encoded_msg = encode_msg ! ( msg) ;
10671067
1068- for ( _, ref mut peer) in peers. peers . iter_mut ( ) {
1068+ for ( _, peer) in peers. peers . iter_mut ( ) {
10691069 if !peer. channel_encryptor . is_ready_for_encryption ( ) || peer. their_features . is_none ( ) ||
10701070 !peer. should_forward_channel_announcement ( msg. contents . short_channel_id ) {
10711071 continue
@@ -1291,7 +1291,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref, RM: Deref, L: Deref> PeerManager<D
12911291 }
12921292 }
12931293
1294- for ( descriptor, ref mut peer) in peers. peers . iter_mut ( ) {
1294+ for ( descriptor, peer) in peers. peers . iter_mut ( ) {
12951295 self . do_attempt_write_data ( & mut ( * descriptor) . clone ( ) , peer) ;
12961296 }
12971297 }
0 commit comments