pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-06-11 16:31:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

Don't queue messages after shutdown (#1476)

Browse Source
This commit is contained in:
Pierre Krieger
2019-01-19 12:37:07 +01:00
committed by Gav Wood
parent a69a09a165
commit f1f32ac620
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
substrate/core/network-libp2p/src/custom_proto/upgrade.rs
+5
View File
@@ -103,10 +103,15 @@ impl<TSubstream> RegisteredProtocolSubstream<TSubstream> {
/// After calling this, the stream is guaranteed to finish soon-ish.
pub fn shutdown(&mut self) {
self.is_closing = true;
self.send_queue.clear();
}
/// Sends a message to the substream.
pub fn send_message(&mut self, data: Bytes) {
if self.is_closing {
return
}
self.send_queue.push_back(data);
// If the length of the queue goes over a certain arbitrary threshold, we print a warning.