| /system/bt/gd/rust/hal/src/ |
| D | facade.rs | 50 fn send_command(&mut self, ctx: RpcContext<'_>, mut data: Data, sink: UnarySink<Empty>) { in send_command()
54 sink.success(Empty::default()).await.unwrap(); in send_command()
58 fn send_acl(&mut self, ctx: RpcContext<'_>, mut data: Data, sink: UnarySink<Empty>) { in send_acl()
62 sink.success(Empty::default()).await.unwrap(); in send_acl()
70 fn send_iso(&mut self, ctx: RpcContext<'_>, mut data: Data, sink: UnarySink<Empty>) { in send_iso()
74 sink.success(Empty::default()).await.unwrap(); in send_iso()
78 fn stream_events(&mut self, ctx: RpcContext<'_>, _: Empty, sink: ServerStreamingSink<Data>) { in stream_events()
79 self.evt_rx.stream_grpc(ctx, sink); in stream_events()
82 fn stream_acl(&mut self, ctx: RpcContext<'_>, _: Empty, sink: ServerStreamingSink<Data>) { in stream_acl()
83 self.acl_rx.stream_grpc(ctx, sink); in stream_acl()
[all …]
|
| /system/bt/gd/rust/hci/src/ |
| D | facade.rs | 87 fn send_command(&mut self, ctx: RpcContext<'_>, mut data: Data, sink: UnarySink<Empty>) { in send_command()
92 sink.success(Empty::default()).await.unwrap(); in send_command()
98 fn request_event(&mut self, ctx: RpcContext<'_>, req: EventRequest, sink: UnarySink<Empty>) { in request_event()
102 sink.success(Empty::default()).await.unwrap(); in request_event()
110 sink: UnarySink<Empty>, in request_le_subevent()
115 sink.success(Empty::default()).await.unwrap(); in request_le_subevent()
119 fn send_acl(&mut self, ctx: RpcContext<'_>, mut packet: Data, sink: UnarySink<Empty>) { in send_acl()
123 sink.success(Empty::default()).await.unwrap(); in send_acl()
127 fn stream_events(&mut self, ctx: RpcContext<'_>, _req: Empty, sink: ServerStreamingSink<Data>) { in stream_events()
128 self.evt_rx.stream_grpc(ctx, sink); in stream_events()
[all …]
|
| D | controller_facade.rs | 41 fn get_mac_address(&mut self, ctx: RpcContext<'_>, _req: Empty, sink: UnarySink<AddressMsg>) { in get_mac_address()
46 sink.success(address).await.unwrap(); in get_mac_address()
50 fn write_local_name(&mut self, ctx: RpcContext<'_>, req: NameMsg, sink: UnarySink<Empty>) { in write_local_name()
56 sink.success(Empty::default()).await.unwrap(); in write_local_name()
60 fn get_local_name(&mut self, ctx: RpcContext<'_>, _req: Empty, sink: UnarySink<NameMsg>) { in get_local_name()
69 sink.success(msg).await.unwrap(); in get_local_name()
|
| /system/core/fs_mgr/libsnapshot/ |
| D | snapshot_reader.cpp | 170 MemoryByteSink sink(buf, count); in Read() local
172 size_t initial_bytes = std::min(block_size_ - start_offset, sink.remaining()); in Read()
173 ssize_t rv = ReadBlock(start_chunk, &sink, start_offset, initial_bytes); in Read()
180 ssize_t rv = ReadBlock(chunk, &sink, 0); in Read()
187 if (sink.remaining()) { in Read()
188 ssize_t rv = ReadBlock(end_chunk, &sink, 0, {sink.remaining()}); in Read()
197 DCHECK(sink.pos() - sink.buf() == count); in Read()
227 ssize_t CompressedSnapshotReader::ReadBlock(uint64_t chunk, IByteSink* sink, size_t start_offset, in ReadBlock() argument
244 void* buffer = sink->GetBuffer(bytes_to_read, &actual); in ReadBlock()
|
| D | cow_api_test.cpp | 105 StringSink sink; in TEST_F() local
115 ASSERT_TRUE(reader.ReadData(*op, &sink)); in TEST_F()
116 ASSERT_EQ(sink.stream(), data); in TEST_F()
167 StringSink sink; in TEST_F() local
173 ASSERT_TRUE(reader.ReadData(*op, &sink)); in TEST_F()
174 ASSERT_EQ(sink.stream(), data); in TEST_F()
208 StringSink sink; in TEST_F() local
214 ASSERT_TRUE(reader.ReadData(*op, &sink)); in TEST_F()
215 ASSERT_EQ(sink.stream(), data); in TEST_F()
227 sink.Reset(); in TEST_F()
[all …]
|
| D | cow_decompress.h | 49 void set_sink(IByteSink* sink) { sink_ = sink; } in set_sink() argument
|
| D | inspect_cow.cpp | 118 StringSink sink; in Inspect() local
126 if (!reader.ReadData(op, &sink)) { in Inspect()
131 sink.Reset(); in Inspect()
|
| D | snapshot_reader.h | 68 ssize_t ReadBlock(uint64_t chunk, IByteSink* sink, size_t start_offset,
|
| D | cow_reader.cpp | 540 bool CowReader::ReadData(const CowOperation& op, IByteSink* sink) { in ReadData() argument
559 decompressor->set_sink(sink); in ReadData()
|
| /system/core/fastboot/device/ |
| D | usb_client.cpp | 45 struct usb_endpoint_descriptor_no_audio sink; member
52 struct usb_endpoint_descriptor_no_audio sink; member
87 .sink =
89 .bLength = sizeof(fs_descriptors.sink),
107 .sink =
109 .bLength = sizeof(hs_descriptors.sink),
133 .sink =
135 .bLength = sizeof(ss_descriptors.sink),
|
| /system/bt/gd/rust/facade/helpers/ |
| D | lib.rs | 5 use futures::sink::SinkExt;
37 pub fn stream_grpc(&mut self, ctx: RpcContext<'_>, mut sink: ServerStreamingSink<Data>) { in stream_grpc()
46 if let Err(e) = sink.send((data, WriteFlags::default())).await { in stream_grpc()
|
| /system/bt/gd/rust/facade/src/ |
| D | lib.rs | 43 sink: UnarySink<StartStackResponse>, in start_stack()
46 sink.success(StartStackResponse::default()); in start_stack()
53 sink: UnarySink<StopStackResponse>, in stop_stack()
56 sink.success(StopStackResponse::default()); in stop_stack()
|
| /system/media/tests/ |
| D | systemaudio_tests.cpp | 52 const audio_port_config sink = { in TEST() local
54 ASSERT_TRUE(audio_patch_is_valid((PatchBuilder{}).addSource(src).addSink(sink).patch())); in TEST()
56 (PatchBuilder{}).addSource(src).addSource(src).addSink(sink).patch())); in TEST()
58 (PatchBuilder{}).addSource(src).addSink(sink).addSink(sink).patch())); in TEST()
61 addSink(sink).addSink(sink).patch())); in TEST()
104 const audio_port_config sink = { in TEST() local
108 (PatchBuilder{}).addSource(src).addSink(sink).patch())); in TEST()
110 (PatchBuilder{}).addSource(src).addSink(sink).patch(), in TEST()
111 (PatchBuilder{}).addSource(src).addSink(sink).patch())); in TEST()
113 (PatchBuilder{}).addSource(src).addSink(sink).patch(), in TEST()
[all …]
|
| /system/core/fs_mgr/libsnapshot/include/libsnapshot/ |
| D | cow_reader.h | 83 virtual bool ReadData(const CowOperation& op, IByteSink* sink) = 0;
140 bool ReadData(const CowOperation& op, IByteSink* sink) override;
|
| /system/bt/audio_hal_interface/ |
| D | le_audio_software.h | 87 bool ReleaseSink(Sink* sink);
|
| D | le_audio_software.cc | 491 bool LeAudioClientInterface::ReleaseSink(LeAudioClientInterface::Sink* sink) { in ReleaseSink() argument
492 if (sink != sink_) { in ReleaseSink()
497 if (le_audio_sink_hal_clientinterface && le_audio_sink) sink->Cleanup(); in ReleaseSink()
|
| D | client_interface.cc | 422 IBluetoothSinkTransportInstance* sink, in BluetoothAudioSinkClientInterface() argument
426 sink}, in BluetoothAudioSinkClientInterface()
427 sink_(sink) {
|
| /system/bt/gd/docs/architecture/ |
| D | style_guide.md | 90 * Source and sink, server and client profiles should live in two sub folders
92 source and sink must have separate modules
151 * sink/: A2DP sink module (e.g. headset)
|
| /system/sepolicy/prebuilts/api/26.0/private/ |
| D | audioserver.te | 22 # used for TEE sink - pcm capture for debug.
|
| /system/sepolicy/prebuilts/api/27.0/private/ |
| D | audioserver.te | 22 # used for TEE sink - pcm capture for debug.
|
| /system/sepolicy/prebuilts/api/28.0/private/ |
| D | audioserver.te | 22 # used for TEE sink - pcm capture for debug.
|
| /system/sepolicy/prebuilts/api/29.0/private/ |
| D | audioserver.te | 23 # used for TEE sink - pcm capture for debug.
|
| /system/sepolicy/prebuilts/api/30.0/private/ |
| D | audioserver.te | 23 # used for TEE sink - pcm capture for debug.
|
| /system/sepolicy/prebuilts/api/31.0/private/ |
| D | audioserver.te | 23 # used for TEE sink - pcm capture for debug.
|
| /system/sepolicy/private/ |
| D | audioserver.te | 23 # used for TEE sink - pcm capture for debug.
|