Rename `.delete_sockaddr()` -> `.delete_addr()`

dereg_on_oserror
Tyler Goodlet 2025-09-30 01:09:16 -04:00
parent 11acdf8625
commit c9fda3ff2c
3 changed files with 7 additions and 7 deletions

View File

@ -474,7 +474,7 @@ def test_stale_entry_is_deleted(
async with tractor.find_actor(name) as maybe_portal: async with tractor.find_actor(name) as maybe_portal:
# because the transitive # because the transitive
# `._discovery.maybe_open_portal()` call should # `._discovery.maybe_open_portal()` call should
# fail and implicitly call `.delete_sockaddr()` # fail and implicitly call `.delete_addr()`
assert maybe_portal is None assert maybe_portal is None
registry: dict = await unpack_reg(_reg_ptl) registry: dict = await unpack_reg(_reg_ptl)
assert ptl.chan.aid.uid not in registry assert ptl.chan.aid.uid not in registry

View File

@ -218,8 +218,8 @@ async def maybe_open_portal(
# registar actor. # registar actor.
uid: tuple[str, str] = await reg_portal.run_from_ns( uid: tuple[str, str] = await reg_portal.run_from_ns(
'self', 'self',
'delete_sockaddr', 'delete_addr',
sockaddr=addr, addr=addr,
) )
log.warning( log.warning(
f'Deleted stale registry entry !\n' f'Deleted stale registry entry !\n'

View File

@ -1994,12 +1994,12 @@ class Arbiter(Actor):
f'Request to de-register {uid!r} failed?' f'Request to de-register {uid!r} failed?'
) )
async def delete_sockaddr( async def delete_addr(
self, self,
sockaddr: tuple[str, int|str], addr: tuple[str, int|str],
) -> tuple[str, str]: ) -> tuple[str, str]:
uid: tuple | None = self._registry.inverse.pop( uid: tuple | None = self._registry.inverse.pop(
sockaddr, addr,
None, None,
) )
if uid: if uid:
@ -2010,6 +2010,6 @@ class Arbiter(Actor):
log.warning( log.warning(
report report
+ +
f'{sockaddr!r}@{uid!r}' f'{addr!r}@{uid!r}'
) )
return uid return uid