The Structural Dynamics of Flow: finally a formalized modular transport layer -> `tractor.ipc` 😎 #375

Merged

goodboy merged 74 commits intomainfrom

structural_dynamics_of_flow

Jul 13, 2025

Commits on Jul 8, 2025

IPC ring bug impl with async read

Guillermo Rodriguez
authored and
goodboy
committed
General improvements

Guillermo Rodriguez
authored and
goodboy
committed
move tractor._ipc.py into tractor.ipc._chan.py

Guillermo Rodriguez
authored and
goodboy
committed
Move tractor._shm to tractor.ipc._shm

Guillermo Rodriguez
authored and
goodboy
committed
Move linux specifics from tractor.ipc._shm into tractor.ipc._linux

Guillermo Rodriguez
authored and
goodboy
committed
Move RingBuffSender|Receiver to its own tractor.ipc._ringbuf module

Guillermo Rodriguez
authored and
goodboy
committed
Add module headers and fix spacing on tractor._ipc._linux

Guillermo Rodriguez
authored and
goodboy
committed
Handle cancelation on EventFD.read

Guillermo Rodriguez
authored and
goodboy
committed
Address some of fomo\'s comments

Guillermo Rodriguez
authored and
goodboy
committed
Make ring buf api use pickle-able RBToken

Guillermo Rodriguez
authored and
goodboy
committed
Add buf_size to RBToken and add sender cancel test, move disable_mantracker to its own _mp_bs module

Guillermo Rodriguez
authored and
goodboy
committed
Break out transport protocol and tcp specifics into their own submodules under tractor.ipc

Guillermo Rodriguez
authored and
goodboy
committed
Starting to make `.ipc.Channel` work with multiple MsgTransports

Guillermo Rodriguez
authored and
goodboy
committed
Add root and random addr getters on MsgTransport type

Guillermo Rodriguez
authored and
goodboy
committed
Finally switch to using address protocol in all runtime

Guillermo Rodriguez
authored and
goodboy
committed
Trying to make full suite pass with uds

Guillermo Rodriguez
authored and
goodboy
committed
Rework/simplify transport addressing
goodboy
committed
Implement peer-info tracking for UDS streams
goodboy
committed
Adjust imports to use new `UnwrappedAddress`
goodboy
committed
Allocate bind-addrs in subactors
goodboy
committed
Add a big boi `Channel.pformat()/__repr__()`
goodboy
committed
Slight typing and multi-line styling tweaks in `.ipc` sugpkg
goodboy
committed
Adjust lowlevel-tb hiding logic for `MsgStream`
goodboy
committed
Add `bidict` pkg as dep since used in `._addr` for now
goodboy
committed
Adjust `._child` instantiation of `Actor` to use newly named `uuid` arg
goodboy
committed
Bit of multi-line styling for `LocalPortal`
goodboy
committed
Emphasize internal error block header-comment a bit
goodboy
committed
Handle broken-pipes from `MsgpackTransport.send()`
goodboy
committed
Even more `tractor._addr.Address` simplifying
goodboy
committed
Add a `MsgpackTransport.pformat()`
goodboy
committed
Add an `Actor.pformat()`
goodboy
committed
Factor `breakpoint()` blocking into `@acm`
goodboy
committed
Add `psutil` to `--dev` / testing deps
goodboy
committed
Move `DebugRequestError` to `._exceptions`
goodboy
committed
More `._addr` boxing refinements
goodboy
committed
UDS: translate file dne to connection-error
goodboy
committed
Mv `Actor._do_handshake()` to `Channel`, add `.aid`
goodboy
committed
Mv to `Channel._do_handshake()` in `open_portal()`
goodboy
committed
Change some low-hanging `.uid`s to `.aid`
goodboy
committed
Some more log message tweaks
goodboy
committed
Repair weird spawn test, start `test_root_runtime`
goodboy
committed
Add `Arbiter.is_registry()` in prep for proper `.discovery._registry`
goodboy
committed
s/`._addr.preferred_transport`/`_state._def_tpt_proto`
goodboy
committed
Unwrap `UDSAddress` as `tuple[str, str]`, i.e. sin pid
goodboy
committed
Improve `TransportClosed.__repr__()`, add `src_exc`
goodboy
committed
Skip the ringbuf test mod for now since data-gen is a bit "heavy/laggy" atm
goodboy
committed
Add API-modernize-todo on `experimental._pubsub.fan_out_to_ctxs`
goodboy
committed
Move concrete `Address`es to each tpt module
goodboy
committed
Factor actor-embedded IPC-tpt-server to `ipc` subsys
goodboy
committed
Add `TransportClosed.from_src_exc()`
goodboy
committed
Absorb `TransportClosed` in `Portal.cancel_actor()`
goodboy
committed
Another `tn` eg-loosify inside `ActorNursery.cancel()`..
goodboy
committed
Add `_state.current_ipc_protos()`
goodboy
committed
Use `current_ipc_protos()` as the `enable_transports`-default-when-`None`
goodboy
committed
Never hide non-[msgtype/tpt-closed] error tbs in `Channel.send()`
goodboy
committed
Passthrough `_pause()` kwargs from `_maybe_enter_pm()`
goodboy
committed
Mv `Actor._stream_handler()` to `.ipc._server` func
goodboy
committed
Move peer-tracking attrs from `Actor` -> `IPCServer`
goodboy
committed
Log listener bind status for TCP as for UDS
goodboy
committed
Decouple actor-state from low-level ipc-server
goodboy
committed

Commits on Jul 10, 2025