Struct ManagerProxy

pub struct ManagerProxy { /* private fields */ }

Implementations

impl ManagerProxy

pub fn new(channel: AsyncChannel) -> Self

Create a new Proxy for fuchsia.starnix.runner/Manager.

pub fn take_event_stream(&self) -> ManagerEventStream

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

Panics

Panics if the event stream was already taken.

pub fn suspend_container( &self, payload: ManagerSuspendContainerRequest, ) -> QueryResponseFut<ManagerSuspendContainerResult, DefaultFuchsiaResourceDialect>

Suspends the container running in job.

The call will return successfully when wake_event has been signaled. Returns an error if wake_locks is signaled at the end of suspension, or an error is encountered when suspending the container’s processes.

pub fn proxy_wake_channel( &self, payload: ManagerProxyWakeChannelRequest, ) -> Result<(), Error>

Creates a pass-through proxy that forwards messages between the container_channel and the remote_channel.

If any messages arrive on remote_channel while the container is suspended via SuspendContainer, the container will be resumed and counter will be incremented.

Once that message is handled by the container, and it’s ok to suspend the container again (relative to that message), the counter is expected to be decremented.

pub fn register_wake_watcher( &self, payload: ManagerRegisterWakeWatcherRequest, ) -> QueryResponseFut<(), DefaultFuchsiaResourceDialect>

Registers an eventpair that will be signaled when the container is suspended or resumed. The signals are ASLEEP(USER_1) and AWAKE(USER_0).

The kernel returns AWAKE upon initial registration of the eventpair.

Trait Implementations

impl Clone for ManagerProxy

fn clone(&self) -> ManagerProxy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ManagerProxy

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

Formats the value using the given formatter.

impl ManagerProxyInterface for ManagerProxy

type SuspendContainerResponseFut = QueryResponseFut<Result<ManagerSuspendContainerResponse, SuspendError>>

type RegisterWakeWatcherResponseFut = QueryResponseFut<()>

fn suspend_container( &self, payload: ManagerSuspendContainerRequest, ) -> Self::SuspendContainerResponseFut

fn proxy_wake_channel( &self, payload: ManagerProxyWakeChannelRequest, ) -> Result<(), Error>

fn register_wake_watcher( &self, payload: ManagerRegisterWakeWatcherRequest, ) -> Self::RegisterWakeWatcherResponseFut

impl Proxy for ManagerProxy

type Protocol = ManagerMarker

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.