Struct PacketStreamControlProxy 

pub struct PacketStreamControlProxy { /* private fields */ }

Implementations

impl PacketStreamControlProxy

pub fn new(channel: AsyncChannel) -> Self

Create a new Proxy for fuchsia.hardware.audio/PacketStreamControl.

pub fn take_event_stream(&self) -> PacketStreamControlEventStream

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

Panics

Panics if the event stream was already taken.

pub fn get_properties( &self, ) -> QueryResponseFut<PacketStreamProperties, DefaultFuchsiaResourceDialect>

Accessor for top level static properties.

pub fn allocate_vmos( &self, payload: &AllocateVmosConfig, ) -> QueryResponseFut<PacketStreamControlAllocateVmosResult, DefaultFuchsiaResourceDialect>

Request the driver to allocate VMOs for data transfer. Returns the allocated VMOs and their assigned IDs.

The returned VMO handle must include ZX_RIGHT_TRANSFER, ZX_RIGHT_READ and ZX_RIGHT_MAP. If the packet stream is an output stream, then the handle must also include ZX_RIGHT_WRITE.

Returns ZX_ERR_INVALID_ARGS if min_vmo_size is zero or vmo_count is zero. Returns ZX_ERR_NO_MEMORY if the driver cannot allocate the requested VMOs. Returns ZX_ERR_BAD_STATE if VMOs are already allocated or registered, or if the stream is already started. Call DeallocateVmos or UnregisterVmos first to reconfigure.

pub fn deallocate_vmos( &self, ) -> QueryResponseFut<PacketStreamControlDeallocateVmosResult, DefaultFuchsiaResourceDialect>

Releases all VMOs previously allocated via AllocateVmos. This also occurs automatically when the PacketStreamControl channel is closed.

Returns ZX_ERR_BAD_STATE if VMOs are not currently allocated, or if the stream is not stopped.

pub fn register_vmos( &self, payload: RegisterVmosConfig, ) -> QueryResponseFut<PacketStreamControlRegisterVmosResult, DefaultFuchsiaResourceDialect>

Registers client-allocated VMOs with the driver.

The registered VMO handle must include ZX_RIGHT_TRANSFER, ZX_RIGHT_READ and ZX_RIGHT_MAP. If the packet stream is an input stream, then the handle must also include ZX_RIGHT_WRITE.

Returns ZX_ERR_INVALID_ARGS if vmo_infos is empty, or if any VMO handle is invalid, or if duplicate vmo_ids are found. Returns ZX_ERR_ACCESS_DENIED if any VMO does not have the required rights. Returns ZX_ERR_BAD_STATE if VMOs are already registered or allocated, or if the stream is already started. Call UnregisterVmos or DeallocateVmos first to reconfigure.

pub fn unregister_vmos( &self, ) -> QueryResponseFut<PacketStreamControlUnregisterVmosResult, DefaultFuchsiaResourceDialect>

Unregisters all VMOs previously registered via RegisterVmos. This also occurs automatically when the PacketStreamControl channel is closed.

Returns ZX_ERR_BAD_STATE if VMOs are not currently registered, or if the stream is not stopped.

pub fn get_packet_stream_sink( &self, ) -> QueryResponseFut<PacketStreamControlGetPacketStreamSinkResult, DefaultFuchsiaResourceDialect>

Connects to the data sink implemented by the driver. This is used for audio Output where the driver consumes data.

Flow:

1. App writes audio data to a registered VMO.
2. App flushes the cache for the written region (if needs_cache_flush_or_invalidate is true).
3. App calls PacketStreamSink.PutPacket with the location of the data.
4. Driver consumes the data.

If this method is called multiple times, the previous PacketStreamSink channel is closed, and any pending requests on that channel are discarded. The new channel replaces the old one.

Returns ZX_ERR_NOT_SUPPORTED if the stream is an input stream, or if the driver does not support this method.

pub fn set_packet_stream_sink( &self, payload: PacketStreamControlSetPacketStreamSinkRequest, ) -> QueryResponseFut<PacketStreamControlSetPacketStreamSinkResult, DefaultFuchsiaResourceDialect>

Provides a data sink to the driver. This is used for audio Input where the driver produces data.

Flow:

1. Driver writes audio data to a registered VMO.
2. Driver calls PacketStreamSink.PutPacket with the location of the data.
3. App receives PutPacket.
4. App invalidates the cache for the region (if needs_cache_flush_or_invalidate is true).
5. App reads the data.

If this method is called multiple times, the driver closes the previous PacketStreamSink channel. The new channel replaces the old one.

Returns ZX_ERR_NOT_SUPPORTED if the stream is an output stream, or if the driver does not support this method.

pub fn start( &self, ) -> QueryResponseFut<PacketStreamControlStartResult, DefaultFuchsiaResourceDialect>

Start the packet-stream.

Returns ZX_ERR_BAD_STATE if:

• Buffers have not been allocated (if DRIVER_OWNED was specified) and/or registered (if CLIENT_OWNED was specified). This is not applicable if INLINE is supported.
• The stream is already started.

pub fn stop( &self, ) -> QueryResponseFut<PacketStreamControlStopResult, DefaultFuchsiaResourceDialect>

Stop the packet-stream.

Once the response is received, the stream is halted.

Behavior depends on the stream direction:

• Output: The driver stops consuming packets. Any pending PacketStreamSink.PutPacket requests will remain pending until Start is called again. Clients may call PacketStreamSink.FlushPackets after Stop to discard these pending packets.
• Input: The driver stops producing packets. No further PacketStreamSink.PutPacket calls will be made by the driver until Start is called again.

Note that since PacketStreamSink uses a separate channel, there is no strict ordering guarantee between Stop and PacketStreamSink.PutPacket:

• For Output, some in-flight PacketStreamSink.PutPacket calls may complete successfully after Stop has returned.
• For Input, some in-flight PacketStreamSink.PutPacket calls may arrive at the client after Stop has returned.

Returns ZX_ERR_BAD_STATE if the stream is not started.

Trait Implementations

impl Clone for PacketStreamControlProxy

fn clone(&self) -> PacketStreamControlProxy

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PacketStreamControlProxy

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

Formats the value using the given formatter.

impl PacketStreamControlProxyInterface for PacketStreamControlProxy

type GetPropertiesResponseFut = QueryResponseFut<PacketStreamProperties>

type AllocateVmosResponseFut = QueryResponseFut<Result<Vec<VmoInfo>, i32>>

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

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

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

type GetPacketStreamSinkResponseFut = QueryResponseFut<Result<PacketStreamControlGetPacketStreamSinkResponse, i32>>

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

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

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

fn get_properties(&self) -> Self::GetPropertiesResponseFut

fn allocate_vmos( &self, payload: &AllocateVmosConfig, ) -> Self::AllocateVmosResponseFut

fn deallocate_vmos(&self) -> Self::DeallocateVmosResponseFut

fn register_vmos( &self, payload: RegisterVmosConfig, ) -> Self::RegisterVmosResponseFut

fn unregister_vmos(&self) -> Self::UnregisterVmosResponseFut

fn get_packet_stream_sink(&self) -> Self::GetPacketStreamSinkResponseFut

fn set_packet_stream_sink( &self, payload: PacketStreamControlSetPacketStreamSinkRequest, ) -> Self::SetPacketStreamSinkResponseFut

fn start(&self) -> Self::StartResponseFut

fn stop(&self) -> Self::StopResponseFut

impl Proxy for PacketStreamControlProxy

type Protocol = PacketStreamControlMarker

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<'_, NullableHandle>>

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