File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -279,6 +279,7 @@ impl<Descriptor: SocketDescriptor> PeerManager<Descriptor> {
279
279
let act_three = try_potential_handleerror ! ( peer. channel_encryptor. process_act_two( & peer. pending_read_buffer[ ..] , & self . our_node_secret) ) . to_vec ( ) ;
280
280
peer. pending_outbound_buffer . push_back ( act_three) ;
281
281
peer. pending_read_buffer = [ 0 ; 18 ] . to_vec ( ) ; // Message length header is 18 bytes
282
+ peer. pending_read_is_header = true ;
282
283
283
284
insert_node_id = Some ( peer. their_node_id . unwrap ( ) ) ;
284
285
encode_and_send_msg ! ( msgs:: Init {
@@ -317,7 +318,9 @@ impl<Descriptor: SocketDescriptor> PeerManager<Descriptor> {
317
318
if msg. local_features . requires_unknown_bits ( ) {
318
319
return Err ( PeerHandleError { } ) ;
319
320
}
320
- //TODO: Store features!
321
+ //TODO: Store features (and check that we've
322
+ //received Init prior to any other messages)!
323
+ //TODO: Respond to Init with Init if we're inbound.
321
324
} ,
322
325
17 => {
323
326
// Error msg
You can’t perform that action at this time.
0 commit comments