Skip to content

Commit d6de5eb

Browse files
committed
Use VecWriter for enqueue_message method.
1 parent dea9da3 commit d6de5eb

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

lightning/src/ln/peer_handler.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -461,8 +461,9 @@ impl<Descriptor: SocketDescriptor, CM: Deref, L: Deref> PeerManager<Descriptor,
461461

462462
/// Append a message to a peer's pending outbound/write buffer, and update the map of peers needing sends accordingly
463463
fn enqueue_message<M: Encode + Writeable>(&self, peers_needing_send: &mut HashSet<Descriptor>, peer: &mut Peer, descriptor: Descriptor, message: &M) {
464-
let mut encoded_message: Vec<u8> = vec![];
465-
wire::write(message, &mut encoded_message).unwrap(); // crash if the write failed
464+
let mut buffer = VecWriter(Vec::new());
465+
wire::write(message, &mut buffer).unwrap(); // crash if the write failed
466+
let encoded_message = buffer.0;
466467

467468
log_trace!(self.logger, "Enqueueing message of type {} to {}", message.type_id(), log_pubkey!(peer.their_node_id.unwrap()));
468469
peer.pending_outbound_buffer.push_back(peer.channel_encryptor.encrypt_message(&encoded_message[..]));

0 commit comments

Comments
 (0)