jc211
/
tractor
forked from goodboy/tractor
1
0
Fork 0
Code Pull Requests Activity
tractor/tractor
History
Tyler Goodlet d23d8c1779 Start a `._rpc` module 
Since `._runtime` was getting pretty long (> 2k LOC) and much of the RPC
low-level machinery is fairly isolated to a handful of task-funcs, it
makes sense to re-org the RPC task scheduling and driving msg loop to
its own code space.

The move includes:
- `process_messages()` which is the main IPC business logic.
- `try_ship_error_to_remote()` helper, to box local errors for the wire.
- `_invoke()`, the core task scheduler entrypoing used in the msg loop.
- `_invoke_non_context()`, holds impls for non-`@context` task starts.
- `_errors_relayed_via_ipc()` which does all error catch-n-boxing for
   wire-msg shipment using `try_ship_error_to_remote()` internally.

Also inside `._runtime` improve some `Actor` methods docs.
 		2024-03-13 15:57:15 -04:00
..
_testing Add (back) a `tractor._testing` sub-pkg 2024-03-13 09:09:08 -04:00
devx Woops, fix `_post_mortem()` type sig.. 2024-03-07 21:24:34 -05:00
experimental Move move context code into new `._context` mod 2023-05-15 10:00:45 -04:00
msg Make `NamespacePath` kinda support methods.. 2024-02-29 17:37:02 -05:00
trionics Try allowing multi-pops of `_Cache.locks` for now? 2024-01-23 11:13:07 -05:00
__init__.py Use `import <name> as <name>,` style over `__all__` in pkg mod 2024-01-02 10:25:17 -05:00
_child.py ._child: remove some unused imports.. 2024-01-02 10:24:39 -05:00
_clustering.py Passthrough runtime kwargs from `open_actor_cluster()` 2022-12-11 19:56:08 -05:00
_context.py Move `Portal.open_context()` impl to `._context` 2024-03-13 12:09:38 -04:00
_discovery.py More spaceless union type annots 2024-03-11 10:33:06 -04:00
_entry.py `._entry`: use same msg info in start/terminate log 2024-03-05 12:30:34 -05:00
_exceptions.py Add "fancier" remote-error `.__repr__()`-ing 2024-02-29 18:56:31 -05:00
_forkserver_override.py Re-license code base for distribution under AGPL 2021-12-14 23:33:27 -05:00
_ipc.py Attempt at better internal traceback hiding 2024-03-13 10:44:51 -04:00
_mp_fixup_main.py Avoid importing mp for as long as possible 2022-02-17 11:55:26 -05:00
_multiaddr.py Fix doc string "its" typo.. 2023-11-06 15:44:21 -05:00
_portal.py Move `Portal.open_context()` impl to `._context` 2024-03-13 12:09:38 -04:00
_root.py More spaceless union type annots 2024-03-11 10:33:06 -04:00
_rpc.py Start a `._rpc` module 2024-03-13 15:57:15 -04:00
_runtime.py Start a `._rpc` module 2024-03-13 15:57:15 -04:00
_shm.py Updates from latest `piker.data._sharedmem` changes 2023-06-22 17:16:17 -04:00
_spawn.py Attempt at better internal traceback hiding 2024-03-13 10:44:51 -04:00
_state.py Add a `._state._runtime_vars['_registry_addrs']` 2024-03-08 15:34:20 -05:00
_streaming.py Attempt at better internal traceback hiding 2024-03-13 10:44:51 -04:00
_supervise.py Add `an: ActorNursery` var placeholder for final log msg 2024-03-12 08:56:17 -04:00
log.py .log: more multi-line styling 2024-02-20 13:22:44 -05:00
to_asyncio.py Unify some log msgs in `.to_asyncio` 2024-03-08 16:07:17 -05:00