Struct DataSink 

pub struct DataSink;

The type corresponding to the DataSink protocol. Protocol for reading and writing boot partitions.

A note on DataSink.Flush() (and BootManager.Flush() coming after):

Some platforms may implement the Flush() fidl interface of DataSink/BootManager. For these platforms, the update of some system images and A/B configuration is not persisted to storage immediately and only buffered internally when the write fidl interfaces return. The data is guaranteed to be persisted only after the Flush() interfaces are called.

If not implemented, Flush() is no-op and system images and A/B configuration will be persisted to storage immediately after the write fidl interfaces return.

For all platforms, it is guaranteed that if DataSink.Flush() is implemented, BootManager.Flush() is implemented as well. Therefore, in the context of system update, both of the following update sequences are safe in the sense that, new A/B configuration will not be persisted to storage before new system images. DataSink.Write… –> DataSink.Flush() –> BootManager.Set… –> BootManager.Flush() DataSink.Write… –> BootManager.Set… –> DataSink.Flush() –> BootManager.Flush()

Trait Implementations

impl Debug for DataSink

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

Formats the value using the given formatter.

impl<___H, ___T> DispatchClientMessage<___H, ___T> for DataSink

where ___H: DataSinkClientHandler<___T> + Send, ___T: Transport,

async fn on_event( handler: &mut ___H, message: Message<___T>, ) -> Result<(), ProtocolError<___T::Error>>

Handles a received client event with the given handler.

impl<___H, ___T> DispatchLocalClientMessage<___H, ___T> for DataSink

where ___H: DataSinkLocalClientHandler<___T>, ___T: Transport,

async fn on_event( handler: &mut ___H, message: Message<___T>, ) -> Result<(), ProtocolError<___T::Error>>

Handles a received client event with the given handler.

impl<___H, ___T> DispatchLocalServerMessage<___H, ___T> for DataSink

where ___H: DataSinkLocalServerHandler<___T>, ___T: Transport, for<'de> DataSinkReadAssetRequest: Decode<<<___T as Transport>::RecvBuffer as AsDecoder<'de>>::Decoder, Constraint = ()>, for<'de> DataSinkWriteAssetRequest: Decode<<<___T as Transport>::RecvBuffer as AsDecoder<'de>>::Decoder, Constraint = ()>, for<'de> DataSinkWriteFirmwareRequest<'de>: Decode<<<___T as Transport>::RecvBuffer as AsDecoder<'de>>::Decoder, Constraint = ()>, for<'de> DataSinkReadFirmwareRequest<'de>: Decode<<<___T as Transport>::RecvBuffer as AsDecoder<'de>>::Decoder, Constraint = ()>, for<'de> DataSinkWriteOpaqueVolumeRequest: Decode<<<___T as Transport>::RecvBuffer as AsDecoder<'de>>::Decoder, Constraint = ()>, for<'de> DataSinkWriteSparseVolumeRequest: Decode<<<___T as Transport>::RecvBuffer as AsDecoder<'de>>::Decoder, Constraint = ()>,

async fn on_one_way( handler: &mut ___H, message: Message<___T>, ) -> Result<(), ProtocolError<<___T as Transport>::Error>>

Handles a received server one-way message with the given handler.

async fn on_two_way( handler: &mut ___H, message: Message<___T>, responder: Responder<___T>, ) -> Result<(), ProtocolError<<___T as Transport>::Error>>

Handles a received server two-way message with the given handler.

impl<___H, ___T> DispatchServerMessage<___H, ___T> for DataSink

where ___H: DataSinkServerHandler<___T> + Send, ___T: Transport, for<'de> DataSinkReadAssetRequest: Decode<<<___T as Transport>::RecvBuffer as AsDecoder<'de>>::Decoder, Constraint = ()>, for<'de> DataSinkWriteAssetRequest: Decode<<<___T as Transport>::RecvBuffer as AsDecoder<'de>>::Decoder, Constraint = ()>, for<'de> DataSinkWriteFirmwareRequest<'de>: Decode<<<___T as Transport>::RecvBuffer as AsDecoder<'de>>::Decoder, Constraint = ()>, for<'de> DataSinkReadFirmwareRequest<'de>: Decode<<<___T as Transport>::RecvBuffer as AsDecoder<'de>>::Decoder, Constraint = ()>, for<'de> DataSinkWriteOpaqueVolumeRequest: Decode<<<___T as Transport>::RecvBuffer as AsDecoder<'de>>::Decoder, Constraint = ()>, for<'de> DataSinkWriteSparseVolumeRequest: Decode<<<___T as Transport>::RecvBuffer as AsDecoder<'de>>::Decoder, Constraint = ()>,

async fn on_one_way( handler: &mut ___H, message: Message<___T>, ) -> Result<(), ProtocolError<<___T as Transport>::Error>>

Handles a received server one-way message with the given handler.

async fn on_two_way( handler: &mut ___H, message: Message<___T>, responder: Responder<___T>, ) -> Result<(), ProtocolError<<___T as Transport>::Error>>

Handles a received server two-way message with the given handler.

impl<___T> HasConnectionHandles<___T> for DataSink

where ___T: Transport,

type Client = DataSinkClient<___T>

The client for the protocol. It must be a #[repr(transparent)] wrapper around Client<T>.

type Server = DataSinkServer<___T>

The server for the protocol. It must be a #[repr(transparent)] wrapper around Server<T>.

impl HasTransport for DataSink

Available on Fuchsia only.

type Transport = Channel

The default transport type for this protocol.

impl PartialEq for DataSink

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl StructuralPartialEq for DataSink