Struct TcpBackend 

pub struct TcpBackend(pub ActorHandle<TcpManagerActor>);

Wrapper around ActorHandle<TcpManagerActor> that moves the TCP data-plane (chunked reads/writes) off the actor loop while keeping buffer resolution serialized through actor messages.

Because submit logic now runs outside the actor loop, same-process messages no longer deadlock — the actor loop is free to handle WriteChunk/ReadChunk messages.

Tuple Fields

0: ActorHandle<TcpManagerActor>

Methods from Deref<Target = ActorHandle<TcpManagerActor>>

pub fn actor_id(&self) -> &ActorId

The [ActorId] of the actor represented by this handle.

pub fn drain_and_stop(&self, reason: &str) -> Result<(), ActorError>

Signal the actor to drain its current messages and then stop.

pub fn status(&self) -> Receiver<ActorStatus>

A watch that observes the lifecycle state of the actor.

pub fn send<M>( &self, cx: &impl Actor, message: M, ) -> Result<(), MailboxSenderError>

where M: Message, A: Handler<M>,

Send a message to the actor. Messages sent through the handle are always queued in process, and do not require serialization.

pub fn port<M>(&self) -> PortHandle<M>

where M: Message, A: Handler<M>,

Return a port for the provided message type handled by the actor.

pub fn bind<R>(&self) -> ActorRef<R>

where R: Binds<A>,

TEMPORARY: bind… TODO: we shoudl also have a default binding(?)

Trait Implementations

impl Clone for TcpBackend

fn clone(&self) -> TcpBackend

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for TcpBackend

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Deref for TcpBackend

type Target = ActorHandle<TcpManagerActor>

The resulting type after dereferencing.

fn deref(&self) -> &Self::Target

Dereferences the value.

impl RdmaBackend for TcpBackend

fn submit<'life0, 'life1, 'async_trait>( &'life0 mut self, cx: &'life1 (impl 'async_trait + Actor + Send + Sync), ops: Vec<RdmaOp>, timeout: Duration, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Submit a batch of RDMA operations over TCP.

Each operation’s remote buffer is resolved to its TCP backend context, then executed directly — sending chunked write/read messages to the remote TcpManagerActor.

type TransportInfo = ()

Backend-specific transport details (e.g., a cffi struct with raw ibverbs handles for GPU-initiated RDMA).

fn transport_level(&self) -> RdmaTransportLevel

The transport level provided by this backend.

fn transport_info(&self) -> Option<Self::TransportInfo>

Low-level backend-specific transport details for direct control over RDMA operations (e.g., from a GPU kernel).