# HG changeset patch
# User alfadur
# Date 1711315421 -10800
# Node ID 14fe5bfe98627f62f1a0b5446d82987d6ba783ad
# Parent  7c8697fa019ffe5823e00011adf0dbfca906f6c2
grow network buffer periodically

diff -r 7c8697fa019f -r 14fe5bfe9862 rust/hedgewars-server/src/protocol.rs
--- a/rust/hedgewars-server/src/protocol.rs	Mon Mar 25 00:04:13 2024 +0300
+++ b/rust/hedgewars-server/src/protocol.rs	Mon Mar 25 00:23:41 2024 +0300
@@ -87,6 +87,7 @@
                 Err(nom::Err::Incomplete(_)) => {}
                 Err(nom::Err::Failure(e) | nom::Err::Error(e)) => {
                     debug!("Invalid message: {:?}", e);
+                    trace!("Buffer content: {:?}", String::from_utf8_lossy(&self.buffer[..]));
                     self.recover();
                 }
             }
@@ -101,7 +102,11 @@
         use ProtocolError::*;
 
         loop {
-            if !self.buffer.has_remaining() {
+            if self.buffer.capacity() < 1024 {
+                self.buffer.reserve(1024 - self.buffer.capacity());
+            }
+
+            if !self.buffer.has_remaining() || self.is_recovering {
                 //todo!("ensure the buffer doesn't grow indefinitely")
                 match timeout(self.read_timeout, stream.read_buf(&mut self.buffer)).await {
                     Err(_) => return Err(Timeout),