Skip to content

Commit c3116b7

Browse files
committed
Swap read_event read type for a slice isntead of a Vec
It looks like we don't currently use the Vec as a Vec, and can happily take a slice, which makes things easier on the calling side.
1 parent afd266b commit c3116b7

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

fuzz/src/full_stack.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -380,7 +380,7 @@ pub fn do_test(data: &[u8], logger: &Arc<dyn Logger>) {
380380
3 => {
381381
let peer_id = get_slice!(1)[0];
382382
if !peers.borrow()[peer_id as usize] { return; }
383-
match loss_detector.handler.read_event(&mut Peer{id: peer_id, peers_connected: &peers}, get_slice!(get_slice!(1)[0]).to_vec()) {
383+
match loss_detector.handler.read_event(&mut Peer{id: peer_id, peers_connected: &peers}, get_slice!(get_slice!(1)[0])) {
384384
Ok(res) => assert!(!res),
385385
Err(_) => { peers.borrow_mut()[peer_id as usize] = false; }
386386
}

lightning-net-tokio/src/lib.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ impl Connection {
6262
//TODO: There's a race where we don't meet the requirements of disconnect_socket if its
6363
//called right here, after we release the us_ref lock in the scope above, but before we
6464
//call read_event!
65-
match peer_manager.read_event(&mut SocketDescriptor::new(us_ref.clone(), peer_manager.clone()), pending_read) {
65+
match peer_manager.read_event(&mut SocketDescriptor::new(us_ref.clone(), peer_manager.clone()), &pending_read) {
6666
Ok(pause_read) => {
6767
if pause_read {
6868
let mut lock = us_ref.lock().unwrap();
@@ -181,7 +181,7 @@ impl<CMH: ChannelMessageHandler> peer_handler::SocketDescriptor for SocketDescri
181181
}
182182
if !read_data.is_empty() {
183183
let mut us_clone = $us_ref.clone();
184-
match $us_ref.peer_manager.read_event(&mut us_clone, read_data) {
184+
match $us_ref.peer_manager.read_event(&mut us_clone, &read_data) {
185185
Ok(pause_read) => {
186186
if pause_read { return Ok(()); }
187187
},

lightning/src/ln/peer_handler.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -448,7 +448,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref> PeerManager<Descriptor, CM> where
448448
/// this file descriptor has resume_read set (preventing DoS issues in the send buffer).
449449
///
450450
/// Panics if the descriptor was not previously registered in a new_*_connection event.
451-
pub fn read_event(&self, peer_descriptor: &mut Descriptor, data: Vec<u8>) -> Result<bool, PeerHandleError> {
451+
pub fn read_event(&self, peer_descriptor: &mut Descriptor, data: &[u8]) -> Result<bool, PeerHandleError> {
452452
match self.do_read_event(peer_descriptor, data) {
453453
Ok(res) => Ok(res),
454454
Err(e) => {
@@ -458,7 +458,7 @@ impl<Descriptor: SocketDescriptor, CM: Deref> PeerManager<Descriptor, CM> where
458458
}
459459
}
460460

461-
fn do_read_event(&self, peer_descriptor: &mut Descriptor, data: Vec<u8>) -> Result<bool, PeerHandleError> {
461+
fn do_read_event(&self, peer_descriptor: &mut Descriptor, data: &[u8]) -> Result<bool, PeerHandleError> {
462462
let pause_read = {
463463
let mut peers_lock = self.peers.lock().unwrap();
464464
let peers = &mut *peers_lock;

0 commit comments

Comments
 (0)