Adjusting client to allow it to wipe a connections receive buffer before starting a new request/response session.
This commit is contained in:
@@ -8,6 +8,7 @@ import logging
|
|||||||
import signal
|
import signal
|
||||||
import time
|
import time
|
||||||
from threading import Lock
|
from threading import Lock
|
||||||
|
from msgpack import Unpacker
|
||||||
from msgpack.exceptions import OutOfData
|
from msgpack.exceptions import OutOfData
|
||||||
from typing import Callable, Self, Union, Optional
|
from typing import Callable, Self, Union, Optional
|
||||||
from traceback import format_exc
|
from traceback import format_exc
|
||||||
@@ -117,6 +118,7 @@ class Client:
|
|||||||
if dest not in self._connection_locks:
|
if dest not in self._connection_locks:
|
||||||
self._connection_locks[dest] = Lock()
|
self._connection_locks[dest] = Lock()
|
||||||
with self._connection_locks[dest]:
|
with self._connection_locks[dest]:
|
||||||
|
conn.data = Unpacker()
|
||||||
conn.send_data(req.pack())
|
conn.send_data(req.pack())
|
||||||
cutoff_date = datetime.datetime.now() + datetime.timedelta(seconds=timeout)
|
cutoff_date = datetime.datetime.now() + datetime.timedelta(seconds=timeout)
|
||||||
logging.debug(f"{datetime.datetime.now()}: Request timeout date is {cutoff_date}")
|
logging.debug(f"{datetime.datetime.now()}: Request timeout date is {cutoff_date}")
|
||||||
|
|||||||
Reference in New Issue
Block a user