summaryrefslogtreecommitdiff
path: root/ospfclient/ospfclient.py
diff options
context:
space:
mode:
authorAndrew Dickinson <andrewjd@amazon.com>2024-12-20 14:40:50 -0500
committerAndrew Dickinson <andrewjd@amazon.com>2024-12-20 14:41:20 -0500
commitb331ebdbacb907ce2fb05c32f4e6953b23992cda (patch)
treebb0d99aa66cec3713047643f5b3c27ce5cbc4314 /ospfclient/ospfclient.py
parent2f0f5d9ab134f1b7d73bb3b206c6cb2fd7b512d7 (diff)
ospfclient: fix crash due to streamwriter garbage collect
Signed-off-by: Andrew Dickinson <andrew.dickinson.0216@gmail.com>
Diffstat (limited to 'ospfclient/ospfclient.py')
-rwxr-xr-xospfclient/ospfclient.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/ospfclient/ospfclient.py b/ospfclient/ospfclient.py
index 7477ef8191..588c1c9fdd 100755
--- a/ospfclient/ospfclient.py
+++ b/ospfclient/ospfclient.py
@@ -306,7 +306,7 @@ class OspfApiClient:
self._s = None
self._as = None
self._ls = None
- self._ar = self._r = self._w = None
+ self._ar = self._r = self._aw = self._w = None
self.server = server
self.handlers = handlers if handlers is not None else dict()
self.write_lock = Lock()
@@ -345,7 +345,7 @@ class OspfApiClient:
logging.debug("%s: success", self)
self._r, self._w = await asyncio.open_connection(sock=self._s)
- self._ar, _ = await asyncio.open_connection(sock=self._as)
+ self._ar, self._aw = await asyncio.open_connection(sock=self._as)
self._seq = 1
async def connect(self):