Struct ManagerSynchronousProxy

pub struct ManagerSynchronousProxy { /* private fields */ }

Implementations

impl ManagerSynchronousProxy

pub fn new(channel: Channel) -> Self

pub fn into_channel(self) -> Channel

pub fn wait_for_event( &self, deadline: MonotonicInstant, ) -> Result<ManagerEvent, Error>

Waits until an event arrives and returns it. It is safe for other threads to make concurrent requests while waiting for an event.

pub fn suspend_container( &self, payload: ManagerSuspendContainerRequest, ___deadline: MonotonicInstant, ) -> Result<ManagerSuspendContainerResult, Error>

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, ___deadline: MonotonicInstant, ) -> Result<(), Error>

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 Debug for ManagerSynchronousProxy

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

Formats the value using the given formatter.

impl From<Channel> for ManagerSynchronousProxy

fn from(value: Channel) -> Self

Converts to this type from the input type.

impl From<ManagerSynchronousProxy> for Handle

fn from(value: ManagerSynchronousProxy) -> Self

Converts to this type from the input type.

impl SynchronousProxy for ManagerSynchronousProxy

type Proxy = ManagerProxy

The async proxy for the same protocol.

type Protocol = ManagerMarker

The protocol which this Proxy controls.

fn from_channel(inner: Channel) -> Self

Create a proxy over the given channel.

fn into_channel(self) -> Channel

Convert the proxy back into a channel.

fn as_channel(&self) -> &Channel

Get a reference to the proxy’s underlying channel.

fn is_closed(&self) -> Result<bool, Status>

Returns true if the proxy has received the PEER_CLOSED signal.