Struct ConnectorProxy

pub struct ConnectorProxy { /* private fields */ }

Implementations

impl ConnectorProxy

pub fn new(channel: AsyncChannel) -> Self

Create a new Proxy for fuchsia.vsock/Connector.

pub fn take_event_stream(&self) -> ConnectorEventStream

Get a Stream of events from the remote end of the protocol.

Panics

Panics if the event stream was already taken.

pub fn connect( &self, remote_cid: u32, remote_port: u32, con: ConnectionTransport, ) -> QueryResponseFut<ConnectorConnectResult, DefaultFuchsiaResourceDialect>

Attempt to establish a connection to the specified remote cid/port pair. No local port is specified as an ephemeral one will automatically be allocated.

pub fn listen( &self, local_port: u32, acceptor: ClientEnd<AcceptorMarker>, ) -> QueryResponseFut<ConnectorListenResult, DefaultFuchsiaResourceDialect>

Registers a listener for a local port. There can only be one listener for a single port at a time.

pub fn bind( &self, remote_cid: u32, local_port: u32, listener: ServerEnd<ListenerMarker>, ) -> QueryResponseFut<ConnectorBindResult, DefaultFuchsiaResourceDialect>

Registers a listener for a local port. There can only be one listener for a single port at a time.

pub fn get_cid(&self) -> QueryResponseFut<u32, DefaultFuchsiaResourceDialect>

Query the current context id of the system. The local CID is should not necessary in interactions with the same device; instead you may pass VMADDR_CID_LOCAL, which will alias to local CID this returns. The cid returned by this method is useful for debugging or if you have some other communication channel to a different host and you would like to send them your CID to then establish a vsock connection on.

Trait Implementations

impl Clone for ConnectorProxy

fn clone(&self) -> ConnectorProxy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl ConnectorProxyInterface for ConnectorProxy

type ConnectResponseFut = QueryResponseFut<Result<u32, i32>>

type ListenResponseFut = QueryResponseFut<Result<(), i32>>

type BindResponseFut = QueryResponseFut<Result<(), i32>>

type GetCidResponseFut = QueryResponseFut<u32>

fn connect( &self, remote_cid: u32, remote_port: u32, con: ConnectionTransport, ) -> Self::ConnectResponseFut

fn listen( &self, local_port: u32, acceptor: ClientEnd<AcceptorMarker>, ) -> Self::ListenResponseFut

fn bind( &self, remote_cid: u32, local_port: u32, listener: ServerEnd<ListenerMarker>, ) -> Self::BindResponseFut

fn get_cid(&self) -> Self::GetCidResponseFut

impl Debug for ConnectorProxy

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

Formats the value using the given formatter.

impl Proxy for ConnectorProxy

type Protocol = ConnectorMarker

The protocol which this Proxy controls.

fn from_channel(inner: AsyncChannel) -> Self

Create a proxy over the given channel.

fn into_channel(self) -> Result<AsyncChannel, Self>

Attempt to convert the proxy back into a channel.

fn as_channel(&self) -> &AsyncChannel

Get a reference to the proxy’s underlying channel.

fn into_client_end(self) -> Result<ClientEnd<Self::Protocol>, Self>

Attempt to convert the proxy back into a client end.

fn is_closed(&self) -> bool

Returns true if the proxy has received the PEER_CLOSED signal.

fn on_closed(&self) -> OnSignals<'_, Unowned<'_, Handle>>

Returns a future that completes when the proxy receives the PEER_CLOSED signal.