summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRuss White <russ@riw.us>2025-01-07 09:38:05 -0500
committerGitHub <noreply@github.com>2025-01-07 09:38:05 -0500
commit8ed117ae1954fc679b03ad273f3658190a2eb74a (patch)
tree20295fe724dbfa725027260ab1bbad6937e77aab
parent2a90c80f49db89c3a1cad0249bca4ad055c6f0d0 (diff)
parentb331ebdbacb907ce2fb05c32f4e6953b23992cda (diff)
Merge pull request #17700 from Andrew-Dickinson/fix-socket-gc
ospfclient: fix crash due to streamwriter garbage collect
-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):