Home
last modified time | relevance | path

Searched refs:sink (Results 1 – 25 of 174) sorted by relevance

1234567

/aosp12/system/bt/gd/rust/hci/src/
H A Dfacade.rs87 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()
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()
128 self.evt_rx.stream_grpc(ctx, sink); in stream_events()
135 sink: ServerStreamingSink<Data>, in stream_le_subevents()
137 self.le_evt_rx.stream_grpc(ctx, sink); in stream_le_subevents()
[all …]
H A Dcontroller_facade.rs41 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()
/aosp12/system/bt/gd/rust/hal/src/
H A Dfacade.rs50 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()
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()
90 fn stream_iso(&mut self, ctx: RpcContext<'_>, _: Empty, sink: ServerStreamingSink<Data>) { in stream_iso()
[all …]
/aosp12/art/test/680-sink-regression/
H A DAndroid.bp3 // Build rules for ART run-test `680-sink-regression`.
16 name: "art-run-test-680-sink-regression",
21 ":art-run-test-680-sink-regression-expected-stdout",
22 ":art-run-test-680-sink-regression-expected-stderr",
28 name: "art-run-test-680-sink-regression-expected-stdout",
29 out: ["art-run-test-680-sink-regression-expected-stdout.txt"],
36 name: "art-run-test-680-sink-regression-expected-stderr",
37 out: ["art-run-test-680-sink-regression-expected-stderr.txt"],
/aosp12/frameworks/base/tests/AccessoryDisplay/
H A DREADME6 There are two applications with two distinct roles: a sink
11 The role of the sink is to emulate an external display that happens
15 The sink application uses the UsbDevice APIs to receive connections
16 from the source device over USB. The sink acts as a USB host
19 The sink application decodes encoded video from the source and
20 displays it in a SurfaceView. The sink also injects passes touch
31 to the sink device over USB. The source acts as a USB peripheral
32 in this arrangement and will receive power from the sink.
36 an encoder and streams the output to the sink over USB. Then
44 Remember that the sink device is functioning as the USB host
[all …]
/aosp12/bionic/benchmarks/
H A Datomic_benchmark.cpp44 static volatile unsigned sink; variable
61 sink = result; in BM_atomic_load_relaxed()
71 sink = result; in BM_atomic_load_acquire()
99 sink = result; in BM_atomic_fetch_add_relaxed()
109 sink = result; in BM_atomic_fetch_add_seq_cst()
123 sink = result; in BM_atomic_acquire_fence()
134 sink = result; in BM_atomic_seq_cst_fence()
148 sink = result; in BM_atomic_fetch_add_cs()
/aosp12/frameworks/base/location/lib/java/com/android/location/provider/
H A DActivityRecognitionProvider.java76 public void registerSink(Sink sink) { in registerSink() argument
77 Preconditions.checkNotNull(sink); in registerSink()
79 mSinkSet.add(sink); in registerSink()
85 public void unregisterSink(Sink sink) { in unregisterSink() argument
86 Preconditions.checkNotNull(sink); in unregisterSink()
88 mSinkSet.remove(sink); in unregisterSink()
128 for (Sink sink : sinks) { in onActivityChanged()
129 sink.onActivityChanged(gmsEvent); in onActivityChanged()
/aosp12/system/core/fs_mgr/libsnapshot/
H A Dcow_api_test.cpp105 StringSink sink; in TEST_F() local
167 StringSink sink; in TEST_F() local
208 StringSink sink; in TEST_F() local
227 sink.Reset(); in TEST_F()
269 StringSink sink; in TEST_F() local
379 StringSink sink; in TEST_F() local
391 sink.Reset(); in TEST_F()
443 StringSink sink; in TEST_F() local
566 sink.Reset(); in TEST_F()
575 sink.Reset(); in TEST_F()
[all …]
H A Dsnapshot_reader.cpp170 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()
/aosp12/packages/apps/Car/DebuggingRestrictionController/libs/
H A Dokio-1.15.0.jar ... ) throws java.io.EOFException okio.Buffer sink long byteCount public long readAll (okio.Sink) ...
/aosp12/frameworks/base/core/java/android/printservice/
H A DPrintDocument.java77 ParcelFileDescriptor sink = null; in getData() local
81 sink = fds[1]; in getData()
82 mPrintServiceClient.writePrintJobData(sink, mPrintJobId); in getData()
89 if (sink != null) { in getData()
91 sink.close(); in getData()
/aosp12/bootable/recovery/applypatch/
H A Dimgpatch.cpp55 const char* deflate_header, SinkFn sink) { in ApplyBSDiffPatchAndStreamOutput() argument
82 &ret, &sink](const uint8_t* data, size_t len) -> size_t { in ApplyBSDiffPatchAndStreamOutput()
103 if (sink(buffer.data(), have) != have) { in ApplyBSDiffPatchAndStreamOutput()
136 size_t patch_size, SinkFn sink) { in ApplyImagePatch() argument
139 return ApplyImagePatch(old_data, old_size, patch, sink, nullptr); in ApplyImagePatch()
142 int ApplyImagePatch(const unsigned char* old_data, size_t old_size, const Value& patch, SinkFn sink, in ApplyImagePatch() argument
184 if (ApplyBSDiffPatch(old_data + src_start, src_len, patch, patch_offset, sink) != 0) { in ApplyImagePatch()
204 if (sink(reinterpret_cast<const unsigned char*>(patch_header + pos), data_len) != data_len) { in ApplyImagePatch()
280 patch_offset, deflate_header, sink)) { in ApplyImagePatch()
/aosp12/system/core/fastboot/device/
H A Dusb_client.cpp45 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),
/aosp12/hardware/interfaces/media/c2/1.0/
H A DIInputSurface.hal54 * Connects the input surface to an input sink.
57 * IComponent::connectToInputSurface(), where @p sink is a thin wrapper of
60 * @param sink Input sink. See `IInputSink` for more information.
63 * - `BAD_VALUE` - @p sink is invalid.
69 IInputSink sink
/aosp12/packages/modules/adb/daemon/
H A Dusb_ffs.cpp50 struct usb_endpoint_descriptor_no_audio sink; member
57 struct usb_endpoint_descriptor_no_audio sink; member
132 .sink = {
133 .bLength = sizeof(fs_descriptors.sink),
159 .sink = {
160 .bLength = sizeof(hs_descriptors.sink),
191 .sink = {
192 .bLength = sizeof(ss_descriptors.sink),
/aosp12/frameworks/base/core/java/android/hardware/location/
H A DActivityRecognitionHardware.java105 public boolean registerSink(IActivityRecognitionHardwareSink sink) { in registerSink() argument
107 return mSinks.register(sink); in registerSink()
111 public boolean unregisterSink(IActivityRecognitionHardwareSink sink) { in unregisterSink() argument
113 return mSinks.unregister(sink); in unregisterSink()
180 IActivityRecognitionHardwareSink sink = mSinks.getBroadcastItem(i); in onActivityChanged() local
182 sink.onActivityChanged(activityChangedEvent); in onActivityChanged()
/aosp12/frameworks/av/media/mtp/
H A DMtpDescriptors.cpp121 .sink = fs_sink,
128 .sink = hs_sink,
135 .sink = ss_sink,
145 .sink = fs_sink,
152 .sink = hs_sink,
159 .sink = ss_sink,
/aosp12/hardware/google/graphics/common/libv4l2/
H A Dexynos_mc.c318 struct media_pad *sink, in exynos_media_setup_link() argument
436 struct media_pad *sink; in exynos_media_parse_link() local
448 sink = exynos_media_parse_pad(media, p, &end); in exynos_media_parse_link()
449 if (sink == NULL) in exynos_media_parse_link()
457 if (link->source == source && link->sink == sink) in exynos_media_parse_link()
/aosp12/frameworks/av/media/libstagefright/webm/
H A DWebmFrameThread.h102 WebmFrameSourceThread(int type, LinkedBlockingQueue<const sp<WebmFrame> >& sink);
115 WebmFrameEmptySourceThread(int type, LinkedBlockingQueue<const sp<WebmFrame> >& sink) in WebmFrameEmptySourceThread() argument
116 : WebmFrameSourceThread(type, sink) { in WebmFrameEmptySourceThread()
129 LinkedBlockingQueue<const sp<WebmFrame> >& sink,
/aosp12/hardware/libhardware/modules/audio_remote_submix/
H A Daudio_hw.cpp510 if (sink != NULL) { in audio_config_compare()
741 sp<MonoPipe> sink = in audio_config_compare() local
744 if (sink == NULL) { in audio_config_compare()
750 sink->shutdown(true); in audio_config_compare()
804 if (sink != NULL) { in audio_config_compare()
806 sink.clear(); in audio_config_compare()
869 sink.clear(); in audio_config_compare()
882 sink.clear(); in audio_config_compare()
1668 if (sink != NULL) { in audio_config_compare()
1732 if (sink != NULL) { in audio_config_compare()
[all …]
/aosp12/system/bt/gd/rust/facade/helpers/
H A Dlib.rs5 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()
/aosp12/frameworks/av/media/codec2/hidl/1.0/utils/
H A DInputSurface.cpp130 const sp<IInputSink>& sink, in connect() argument
134 if (!sink) { in connect()
138 std::shared_ptr<C2Component> comp = Component::findLocalComponent(sink); in connect()
142 connection = new InputSurfaceConnection(mSource, sink, mParameterCache); in connect()
/aosp12/frameworks/base/cmds/uiautomator/library/core-src/com/android/uiautomator/core/
H A DTracer.java150 for (TracerSink sink : mSinks) { in closeSinks()
151 sink.close(); in closeSinks()
180 for (TracerSink sink : mSinks) { in log()
181 sink.log(message); in log()
/aosp12/system/bt/gd/rust/facade/src/
H A Dlib.rs43 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()
/aosp12/system/media/tests/
H A Dsystemaudio_tests.cpp52 const audio_port_config sink = { in TEST() local
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()
115 audio_port_config sink_hw_av_sync = sink; in TEST()
[all …]

1234567