Reset receive buffer with send(). (#2343)

pymodbus-dev · Sep 28, 2024 · a4cf640 · a4cf640
1 parent a6abdab
commit a4cf640
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/pymodbus/transport/transport.py b/pymodbus/transport/transport.py
@@ -377,6 +377,7 @@ def send(self, data: bytes, addr: tuple | None = None) -> None:
             Log.error("Cancel send, because not connected!")
             return
         Log.debug("send: {}", data, ":hex")
+        self.recv_buffer = b""
         if self.comm_params.handle_local_echo:
             self.sent_buffer += data
         if self.comm_params.comm_type == CommType.UDP:

diff --git a/test/transport/test_comm.py b/test/transport/test_comm.py
@@ -242,7 +242,7 @@ async def test_connected_multiple(self, client, server, use_port):
 
         client2.send(test_data)
         await asyncio.sleep(0.5)
-        assert server2_connected.recv_buffer == test2_data + test_data
+        assert server2_connected.recv_buffer ==  test_data
         client2.close()
         server.close()
         await asyncio.sleep(0.5)