Skip to content

Commit c9fda3f

Browse files
committed
Rename .delete_sockaddr() -> .delete_addr()
1 parent 11acdf8 commit c9fda3f

File tree

3 files changed

+7
-7
lines changed

3 files changed

+7
-7
lines changed

tests/test_discovery.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -474,7 +474,7 @@ async def main():
474474
async with tractor.find_actor(name) as maybe_portal:
475475
# because the transitive
476476
# `._discovery.maybe_open_portal()` call should
477-
# fail and implicitly call `.delete_sockaddr()`
477+
# fail and implicitly call `.delete_addr()`
478478
assert maybe_portal is None
479479
registry: dict = await unpack_reg(_reg_ptl)
480480
assert ptl.chan.aid.uid not in registry

tractor/_discovery.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -218,8 +218,8 @@ async def maybe_open_portal(
218218
# registar actor.
219219
uid: tuple[str, str] = await reg_portal.run_from_ns(
220220
'self',
221-
'delete_sockaddr',
222-
sockaddr=addr,
221+
'delete_addr',
222+
addr=addr,
223223
)
224224
log.warning(
225225
f'Deleted stale registry entry !\n'

tractor/_runtime.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1994,12 +1994,12 @@ async def unregister_actor(
19941994
f'Request to de-register {uid!r} failed?'
19951995
)
19961996

1997-
async def delete_sockaddr(
1997+
async def delete_addr(
19981998
self,
1999-
sockaddr: tuple[str, int|str],
1999+
addr: tuple[str, int|str],
20002000
) -> tuple[str, str]:
20012001
uid: tuple | None = self._registry.inverse.pop(
2002-
sockaddr,
2002+
addr,
20032003
None,
20042004
)
20052005
if uid:
@@ -2010,6 +2010,6 @@ async def delete_sockaddr(
20102010
log.warning(
20112011
report
20122012
+
2013-
f'{sockaddr!r}@{uid!r}'
2013+
f'{addr!r}@{uid!r}'
20142014
)
20152015
return uid

0 commit comments

Comments
 (0)