f add docs and fix bool set

TheBlueMatt · TheBlueMatt · commit 44ecfc791803 · 2025-10-27T19:55:21.000Z
diff --git a/lightning/src/ln/peer_handler.rs b/lightning/src/ln/peer_handler.rs
@@ -781,6 +781,8 @@ struct Peer {
 	/// Note that these messages are *not* encrypted/MAC'd, and are only serialized.
 	gossip_broadcast_buffer: VecDeque<MessageBuf>,
 	awaiting_write_event: bool,
+	/// Set to true if the last call to [`Descriptor::send_data`] for this peer had the
+	/// `should_read` flag unset, indicating we've told the driver to stop reading from this peer.
 	sent_pause_read: bool,
 
 	pending_read_buffer: Vec<u8>,
@@ -1546,7 +1548,7 @@ where
 			}
 		} else {
 			if peer.sent_pause_read {
-				force_one_write = false;
+				force_one_write = true;
 			}
 		}
 		while force_one_write || !peer.awaiting_write_event {

Original file line number	Diff line number	Diff line change
`@@ -781,6 +781,8 @@ struct Peer {`
`781`	`781`	`/// Note that these messages are not encrypted/MAC'd, and are only serialized.`
`782`	`782`	`gossip_broadcast_buffer: VecDeque<MessageBuf>,`
`783`	`783`	`awaiting_write_event: bool,`
	`784`	+ /// Set to true if the last call to [`Descriptor::send_data`] for this peer had the
	`785`	+ /// `should_read` flag unset, indicating we've told the driver to stop reading from this peer.
`784`	`786`	`sent_pause_read: bool,`
`785`	`787`
`786`	`788`	`pending_read_buffer: Vec<u8>,`
`@@ -1546,7 +1548,7 @@ where`
`1546`	`1548`	`}`
`1547`	`1549`	`} else {`
`1548`	`1550`	`if peer.sent_pause_read {`
`1549`		`- force_one_write = false;`
	`1551`	`+ force_one_write = true;`
`1550`	`1552`	`}`
`1551`	`1553`	`}`
`1552`	`1554`	`while force_one_write \|\| !peer.awaiting_write_event {`