Struct ControllerProxy

pub struct ControllerProxy { /* private fields */ }

Implementations

impl ControllerProxy

pub fn new(channel: AsyncChannel) -> Self

Create a new Proxy for fuchsia.blackout.test/Controller.

pub fn take_event_stream(&self) -> ControllerEventStream

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

Panics

Panics if the event stream was already taken.

pub fn setup( &self, device_label: &str, device_path: Option<&str>, seed: u64, ) -> QueryResponseFut<ControllerSetupResult, DefaultFuchsiaResourceDialect>

Run the setup step for this test. Often, this involves formatting the filesystem of choice onto the block device, and perhaps setting up a base of files to work with.

pub fn test( &self, device_label: &str, device_path: Option<&str>, seed: u64, duration: u64, ) -> QueryResponseFut<ControllerTestResult, DefaultFuchsiaResourceDialect>

Run the test step for this test. This kicks off the load generation algorithm for this test, which will run indefinitely. It’s expected that this load will be interrupted by a power cycle. If the provided duration is non-zero, this protocol will return after approximately that amount of time, but the load will continue to run. If the duration provided is zero, then the test will return when it’s done, which for a lot of normal blackout tests might be never.

pub fn verify( &self, device_label: &str, device_path: Option<&str>, seed: u64, ) -> QueryResponseFut<ControllerVerifyResult, DefaultFuchsiaResourceDialect>

Run the verify step for this test. Most of the time it involves running fsck on the block device and returning the result.

Trait Implementations

impl Clone for ControllerProxy

fn clone(&self) -> ControllerProxy

Returns a copy of the value.

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

Performs copy-assignment from source.

impl ControllerProxyInterface for ControllerProxy

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

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

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

fn setup( &self, device_label: &str, device_path: Option<&str>, seed: u64, ) -> Self::SetupResponseFut

fn test( &self, device_label: &str, device_path: Option<&str>, seed: u64, duration: u64, ) -> Self::TestResponseFut

fn verify( &self, device_label: &str, device_path: Option<&str>, seed: u64, ) -> Self::VerifyResponseFut

impl Debug for ControllerProxy

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

Formats the value using the given formatter.

impl Proxy for ControllerProxy

type Protocol = ControllerMarker

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.