Home
last modified time | relevance | path

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

123

/packages/modules/Bluetooth/system/gd/rust/topshim/facade/src/
Dgatt_service.rs172 fn register_advertiser(&mut self, ctx: RpcContext<'_>, _req: Empty, sink: UnarySink<Empty>) { in register_advertiser()
176 sink.success(Empty::default()).await.unwrap(); in register_advertiser()
180 fn unregister_advertiser(&mut self, ctx: RpcContext<'_>, _req: Empty, sink: UnarySink<Empty>) { in unregister_advertiser()
184 sink.success(Empty::default()).await.unwrap(); in unregister_advertiser()
188 fn get_own_address(&mut self, ctx: RpcContext<'_>, _req: Empty, sink: UnarySink<Empty>) { in get_own_address()
192 sink.success(Empty::default()).await.unwrap(); in get_own_address()
196 fn set_parameters(&mut self, ctx: RpcContext<'_>, _req: Empty, sink: UnarySink<Empty>) { in set_parameters()
200 sink.success(Empty::default()).await.unwrap(); in set_parameters()
204 fn set_data(&mut self, ctx: RpcContext<'_>, _req: Empty, sink: UnarySink<Empty>) { in set_data()
208 sink.success(Empty::default()).await.unwrap(); in set_data()
[all …]
Dadapter_service.rs15 use futures::sink::SinkExt;
113 mut sink: ServerStreamingSink<FetchEventsResponse>, in fetch_events()
126 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
136 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
165 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
181 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
190 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
202 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
215 sink.send((rsp, WriteFlags::default())).await.unwrap(); in fetch_events()
227 sink: UnarySink<ToggleStackResponse>, in toggle_stack()
[all …]
Dhfp_service.rs11 use futures::sink::SinkExt;
65 fn start_slc(&mut self, ctx: RpcContext<'_>, req: StartSlcRequest, sink: UnarySink<Empty>) { in start_slc()
72 sink.success(Empty::default()).await.unwrap(); in start_slc()
74 sink.fail(RpcStatus::with_message( in start_slc()
84 fn stop_slc(&mut self, ctx: RpcContext<'_>, req: StopSlcRequest, sink: UnarySink<Empty>) { in stop_slc()
91 sink.success(Empty::default()).await.unwrap(); in stop_slc()
93 sink.fail(RpcStatus::with_message( in stop_slc()
107 sink: UnarySink<Empty>, in connect_audio()
116 sink.success(Empty::default()).await.unwrap(); in connect_audio()
118 sink.fail(RpcStatus::with_message( in connect_audio()
[all …]
Dhf_client_service.rs44 sink: UnarySink<StartSlcResponse>, in start_slc()
54 sink.success(resp).await.unwrap(); in start_slc()
56 sink.fail(RpcStatus::with_message( in start_slc()
70 sink: UnarySink<StopSlcResponse>, in stop_slc()
80 sink.success(resp).await.unwrap(); in stop_slc()
82 sink.fail(RpcStatus::with_message( in stop_slc()
96 sink: UnarySink<ConnectAudioResponse>, in connect_audio()
106 sink.success(resp).await.unwrap(); in connect_audio()
108 sink.fail(RpcStatus::with_message( in connect_audio()
122 sink: UnarySink<DisconnectAudioResponse>, in disconnect_audio()
[all …]
Dsecurity_service.rs33 fn remove_bond(&mut self, ctx: RpcContext<'_>, req: RemoveBondRequest, sink: UnarySink<Empty>) { in remove_bond()
37 sink.success(Empty::default()).await.unwrap(); in remove_bond()
45 sink: UnarySink<Empty>, in generate_local_oob_data()
49 sink.success(Empty::default()).await.unwrap(); in generate_local_oob_data()
57 sink: UnarySink<CreateBondResponse>, in create_bond()
67 sink.success(resp).await.unwrap(); in create_bond()
69 sink.fail(RpcStatus::with_message( in create_bond()
Dmedia_service.rs63 sink: UnarySink<StartA2dpResponse>, in start_a2dp()
67 sink.success(StartA2dpResponse::default()).await.unwrap(); in start_a2dp()
72 sink.success(StartA2dpResponse::default()).await.unwrap(); in start_a2dp()
81 sink: UnarySink<A2dpSourceConnectResponse>, in a2dp_source_connect()
88 sink.success(A2dpSourceConnectResponse::default()).await.unwrap(); in a2dp_source_connect()
90 sink.fail(RpcStatus::with_message( in a2dp_source_connect()
/packages/modules/Bluetooth/android/app/src/com/android/bluetooth/bass_client/
DBassClientService.java374 private void enqueueSourceGroupOp(BluetoothDevice sink, Integer msgId, Object obj) { in enqueueSourceGroupOp() argument
375 log("enqueueSourceGroupOp device: " + sink + ", msgId: " + msgId); in enqueueSourceGroupOp()
377 if (!mPendingGroupOp.containsKey(sink)) { in enqueueSourceGroupOp()
378 mPendingGroupOp.put(sink, new ArrayList()); in enqueueSourceGroupOp()
380 mPendingGroupOp.get(sink).add(new Pair<Integer, Object>(msgId, obj)); in enqueueSourceGroupOp()
398 private void checkForPendingGroupOpRequest(BluetoothDevice sink, int reason, int reqMsg, in checkForPendingGroupOpRequest() argument
400 log("checkForPendingGroupOpRequest device: " + sink + ", reason: " + reason in checkForPendingGroupOpRequest()
403 List<Pair<Integer, Object>> operations = mPendingGroupOp.get(sink); in checkForPendingGroupOpRequest()
422 setSourceGroupManaged(sink, sourceState.getSourceId(), true); in checkForPendingGroupOpRequest()
439 setSourceGroupManaged(sink, sourceId, false); in checkForPendingGroupOpRequest()
[all …]
/packages/modules/Bluetooth/system/gd/rust/stack/src/hal/
Dfacade.rs59 fn send_command(&mut self, ctx: RpcContext<'_>, mut data: Data, sink: UnarySink<Empty>) { in send_command()
63 sink.success(Empty::default()).await.unwrap(); in send_command()
67 fn send_acl(&mut self, ctx: RpcContext<'_>, mut data: Data, sink: UnarySink<Empty>) { in send_acl()
71 sink.success(Empty::default()).await.unwrap(); in send_acl()
75 fn send_sco(&mut self, ctx: RpcContext<'_>, mut data: Data, sink: UnarySink<Empty>) { in send_sco()
79 sink.success(Empty::default()).await.unwrap(); in send_sco()
83 fn send_iso(&mut self, ctx: RpcContext<'_>, mut data: Data, sink: UnarySink<Empty>) { in send_iso()
87 sink.success(Empty::default()).await.unwrap(); in send_iso()
91 fn stream_events(&mut self, ctx: RpcContext<'_>, _: Empty, sink: ServerStreamingSink<Data>) { in stream_events()
92 self.evt_rx.stream_grpc(ctx, sink); in stream_events()
[all …]
/packages/modules/Bluetooth/framework/java/android/bluetooth/
DBluetoothLeBroadcastAssistant.java177 void onSourceAdded(@NonNull BluetoothDevice sink, @Reason int sourceId, in onSourceAdded() argument
189 void onSourceAddFailed(@NonNull BluetoothDevice sink, in onSourceAddFailed() argument
211 void onSourceModified(@NonNull BluetoothDevice sink, int sourceId, @Reason int reason); in onSourceModified() argument
223 void onSourceModifyFailed(@NonNull BluetoothDevice sink, int sourceId, @Reason int reason); in onSourceModifyFailed() argument
244 void onSourceRemoved(@NonNull BluetoothDevice sink, int sourceId, @Reason int reason); in onSourceRemoved() argument
256 void onSourceRemoveFailed(@NonNull BluetoothDevice sink, int sourceId, @Reason int reason); in onSourceRemoveFailed() argument
268 void onReceiveStateChanged(@NonNull BluetoothDevice sink, int sourceId, in onReceiveStateChanged() argument
364 public int getConnectionState(@NonNull BluetoothDevice sink) { in getConnectionState() argument
365 log("getConnectionState(" + sink + ")"); in getConnectionState()
366 Objects.requireNonNull(sink, "sink cannot be null"); in getConnectionState()
[all …]
DBluetoothLeBroadcastAssistantCallback.java180 public void onSourceAdded(BluetoothDevice sink, int sourceId, int reason) { in onSourceAdded() argument
186 executor.execute(() -> cb.onSourceAdded(sink, sourceId, reason)); in onSourceAdded()
195 public void onSourceAddFailed(BluetoothDevice sink, BluetoothLeBroadcastMetadata source, in onSourceAddFailed() argument
202 executor.execute(() -> cb.onSourceAddFailed(sink, source, reason)); in onSourceAddFailed()
211 public void onSourceModified(BluetoothDevice sink, int sourceId, int reason) { in onSourceModified() argument
217 executor.execute(() -> cb.onSourceModified(sink, sourceId, reason)); in onSourceModified()
226 public void onSourceModifyFailed(BluetoothDevice sink, int sourceId, int reason) { in onSourceModifyFailed() argument
232 executor.execute(() -> cb.onSourceModifyFailed(sink, sourceId, reason)); in onSourceModifyFailed()
241 public void onSourceRemoved(BluetoothDevice sink, int sourceId, int reason) { in onSourceRemoved() argument
247 executor.execute(() -> cb.onSourceRemoved(sink, sourceId, reason)); in onSourceRemoved()
[all …]
/packages/modules/Bluetooth/system/gd/rust/stack/src/hci/
Dfacade.rs92 fn send_command(&mut self, ctx: RpcContext<'_>, mut data: Data, sink: UnarySink<Empty>) { in send_command()
97 sink.success(Empty::default()).await.unwrap(); in send_command()
103 fn request_event(&mut self, ctx: RpcContext<'_>, req: EventRequest, sink: UnarySink<Empty>) { in request_event()
107 sink.success(Empty::default()).await.unwrap(); in request_event()
115 sink: UnarySink<Empty>, in request_le_subevent()
120 sink.success(Empty::default()).await.unwrap(); in request_le_subevent()
124 fn send_acl(&mut self, ctx: RpcContext<'_>, mut packet: Data, sink: UnarySink<Empty>) { in send_acl()
128 sink.success(Empty::default()).await.unwrap(); in send_acl()
132 fn stream_events(&mut self, ctx: RpcContext<'_>, _req: Empty, sink: ServerStreamingSink<Data>) { in stream_events()
133 self.evt_rx.stream_grpc(ctx, sink); in stream_events()
[all …]
Dcontroller_facade.rs47 sink: UnarySink<BluetoothAddress>, in get_mac_address()
53 sink.success(address).await.unwrap(); in get_mac_address()
57 fn write_local_name(&mut self, ctx: RpcContext<'_>, req: NameMsg, sink: UnarySink<Empty>) { in write_local_name()
63 sink.success(Empty::default()).await.unwrap(); in write_local_name()
67 fn get_local_name(&mut self, ctx: RpcContext<'_>, _req: Empty, sink: UnarySink<NameMsg>) { in get_local_name()
76 sink.success(msg).await.unwrap(); in get_local_name()
84 sink: UnarySink<SupportedMsg>, in is_supported_command()
91 sink.success(supported_msg).await.unwrap(); in is_supported_command()
99 sink: UnarySink<SingleValueMsg>, in get_le_number_of_supported_advertising_sets()
105 sink.success(msg).await.unwrap(); in get_le_number_of_supported_advertising_sets()
[all …]
/packages/modules/Bluetooth/system/binder/android/bluetooth/
DIBluetoothLeBroadcastAssistantCallback.aidl34 void onSourceAdded(in BluetoothDevice sink, in int sourceId, in int reason); in onSourceAdded() argument
35 void onSourceAddFailed(in BluetoothDevice sink, in BluetoothLeBroadcastMetadata source, in onSourceAddFailed() argument
37 void onSourceModified(in BluetoothDevice sink, in int sourceId, in int reason); in onSourceModified() argument
38 void onSourceModifyFailed(in BluetoothDevice sink, in int sourceId, in int reason); in onSourceModifyFailed() argument
39 void onSourceRemoved(in BluetoothDevice sink, in int sourceId, in int reason); in onSourceRemoved() argument
40 void onSourceRemoveFailed(in BluetoothDevice sink, in int sourceId, in int reason); in onSourceRemoveFailed() argument
41 void onReceiveStateChanged(in BluetoothDevice sink, in int sourceId, in onReceiveStateChanged() argument
DIBluetoothLeBroadcastAssistant.aidl33 int getConnectionState(in BluetoothDevice sink); in getConnectionState() argument
53 …void addSource(in BluetoothDevice sink, in BluetoothLeBroadcastMetadata sourceMetadata, in boolean… in addSource() argument
55 …void modifySource(in BluetoothDevice sink, in int sourceId, in BluetoothLeBroadcastMetadata update… in modifySource() argument
57 void removeSource(in BluetoothDevice sink, in int sourceId); in removeSource() argument
59 List<BluetoothLeBroadcastReceiveState> getAllSources(in BluetoothDevice sink); in getAllSources() argument
60 int getMaximumSourceCapacity(in BluetoothDevice sink); in getMaximumSourceCapacity() argument
/packages/modules/Bluetooth/system/audio_hal_interface/fuzzer/
Dlibbt_audio_hal_le_audio_software_fuzzer.cpp84 LeAudioClientInterface::Sink* sink = in LLVMFuzzerTestOneInput() local
86 if (sink != nullptr) { in LLVMFuzzerTestOneInput()
87 sink->StartSession(); in LLVMFuzzerTestOneInput()
89 sink->SetRemoteDelay(delay); in LLVMFuzzerTestOneInput()
95 sink->SetPcmParameters(params); in LLVMFuzzerTestOneInput()
96 sink->StopSession(); in LLVMFuzzerTestOneInput()
97 sink->Cleanup(); in LLVMFuzzerTestOneInput()
99 interface->ReleaseSink(sink); in LLVMFuzzerTestOneInput()
/packages/modules/Bluetooth/android/pandora/mmi2grpc/mmi2grpc/
Da2dp.py41 sink: Optional[Sink] = None variable in A2DPProxy
83 self.sink = self.a2dp.WaitSink(connection=self.connection).sink
127 self.a2dp.Start(sink=self.sink)
155 self.a2dp.Close(sink=self.sink)
156 self.sink = None
Davrcp.py39 sink: Optional[Sink] = None variable in AVRCPProxy
72 self.sink = self.a2dp.WaitSink(connection=self.connection).sink
181 self.sink = self.a2dp.WaitSink(connection=self.connection).sink
937 self.sink = self.a2dp.WaitSink(connection=self.connection).sink
/packages/modules/Bluetooth/android/leaudio/app/src/main/java/com/android/bluetooth/leaudio/
DLeAudioViewModel.java124 public void connectBass(BluetoothDevice sink, boolean connect) { in connectBass() argument
125 bluetoothProxy.connectBass(sink, connect); in connectBass()
143 public boolean removeBroadcastSource(BluetoothDevice sink, int receiver_id) { in removeBroadcastSource() argument
146 return bluetoothProxy.removeBroadcastSource(sink, sourceId); in removeBroadcastSource()
149 public boolean setBroadcastCode(BluetoothDevice sink, int receiver_id, byte[] bcast_code) { in setBroadcastCode() argument
154 return bluetoothProxy.modifyBroadcastSource(sink, sourceId, metadata); in setBroadcastCode()
/packages/modules/Bluetooth/pandora/interfaces/pandora_experimental/
Da2dp.proto48 // The returned sink must be in the AVDTP_OPEN state (see [AVDTP] 9.1).
66 // The returned sink should be in the AVDTP_OPEN state (see [AVDTP] 9.1).
69 // If the peer has opened a sink prior to this call, the server will
70 // return it. The server must return the same sink only once.
78 // Close a stream, the source or sink tokens must not be reused afterwards.
140 Sink sink = 1; field
170 Sink sink = 1; field
178 Sink sink = 1; field
192 Sink sink = 1; field
204 Sink sink = 1; field
[all …]
/packages/modules/adb/daemon/
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),
/packages/modules/Bluetooth/system/audio_hal_interface/
Dle_audio_software.cc641 Sink* sink = is_broadcasting_session_type ? broadcast_sink_ : unicast_sink_; in GetSink() local
642 if (sink == nullptr) { in GetSink()
643 sink = new Sink(is_broadcasting_session_type); in GetSink()
669 delete sink; in GetSink()
670 sink = nullptr; in GetSink()
707 delete sink; in GetSink()
708 sink = nullptr; in GetSink()
728 delete sink; in GetSink()
729 sink = nullptr; in GetSink()
736 return sink; in GetSink()
[all …]
/packages/modules/Bluetooth/system/bta/le_audio/
Dstate_machine_test.cc320 return (ases.sink || ases.source); in ConfigureIsoManagerMock()
345 return (ases.sink || ases.source); in ConfigureIsoManagerMock()
377 return (ases.sink || ases.source); in ConfigureIsoManagerMock()
429 return (ases.sink || ases.source); in ConfigureIsoManagerMock()
1276 {.sink = types::AudioContexts(context_type), in TEST_F()
1322 {.sink = types::AudioContexts(context_type), in TEST_F()
1369 {.sink = types::AudioContexts(context_type), in TEST_F()
1418 {.sink = types::AudioContexts(context_type), in TEST_F()
1465 {.sink = types::AudioContexts(context_type), in TEST_F()
1517 {.sink = types::AudioContexts(context_type), in TEST_F()
[all …]
/packages/apps/Settings/src/com/android/settings/bluetooth/
DBluetoothFindBroadcastsFragment.java122 public void onSourceAdded(@NonNull BluetoothDevice sink, int sourceId, int reason) {
137 public void onSourceAddFailed(@NonNull BluetoothDevice sink,
144 public void onSourceModified(@NonNull BluetoothDevice sink, int sourceId,
149 public void onSourceModifyFailed(@NonNull BluetoothDevice sink, int sourceId,
154 public void onSourceRemoved(@NonNull BluetoothDevice sink, int sourceId,
161 public void onSourceRemoveFailed(@NonNull BluetoothDevice sink, int sourceId,
167 public void onReceiveStateChanged(@NonNull BluetoothDevice sink, int sourceId,
/packages/modules/Bluetooth/system/gd/rust/facade/src/
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()
/packages/modules/Bluetooth/system/gd/rust/facade/helpers/
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()

123