From ad70fb01ef762ab597f38d0a025622398163dee4 Mon Sep 17 00:00:00 2001 From: Michael Woods Date: Sun, 16 Feb 2025 14:36:38 -0500 Subject: [PATCH] Adjusting client to allow it to wipe a connections receive buffer before starting a new request/response session. --- src/packetserver/client/__init__.py | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/packetserver/client/__init__.py b/src/packetserver/client/__init__.py index 3cb03a3..a598672 100644 --- a/src/packetserver/client/__init__.py +++ b/src/packetserver/client/__init__.py @@ -8,6 +8,7 @@ import logging import signal import time from threading import Lock +from msgpack import Unpacker from msgpack.exceptions import OutOfData from typing import Callable, Self, Union, Optional from traceback import format_exc @@ -117,6 +118,7 @@ class Client: if dest not in self._connection_locks: self._connection_locks[dest] = Lock() with self._connection_locks[dest]: + conn.data = Unpacker() conn.send_data(req.pack()) cutoff_date = datetime.datetime.now() + datetime.timedelta(seconds=timeout) logging.debug(f"{datetime.datetime.now()}: Request timeout date is {cutoff_date}")