Home
last modified time | relevance | path

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

/packages/modules/Bluetooth/offload/leaudio/hci/
Dproxy.rs17 use crate::arbiter::Arbiter;
41 arbiter: Option<Arc<Arbiter>>, field
153 pub(crate) fn arbiter(&self) -> Option<Arc<Arbiter>> { in arbiter() method
155 state.arbiter.clone() in arbiter()
244 state.arbiter = Some(Arc::new(Arbiter::new( in in_evt()
249 Service::reset(Arc::downgrade(state.arbiter.as_ref().unwrap())); in in_evt()
326 let arbiter = state.arbiter.as_ref().unwrap(); in in_evt() localVariable
327 arbiter.add_connection(e.connection_handle); in in_evt()
334 let arbiter = state.arbiter.as_ref().unwrap(); in in_evt() localVariable
335 arbiter.remove_connection(e.connection_handle); in in_evt()
[all …]
Dservice.rs17 use crate::arbiter::Arbiter;
41 arbiter: Weak<Arbiter>, field
51 pub(crate) fn reset(arbiter: Weak<Arbiter>) { in reset()
53 *state = State { arbiter, ..Default::default() } in reset()
106 if let Some(arbiter) = state.arbiter.upgrade() { in sendPacket()
108 data.len() <= arbiter.max_buf_len(), in sendPacket()
111 arbiter.push_audio(&IsoData::new(handle, seqnum, data)); in sendPacket()
Dtests.rs663 m.arbiter().unwrap().push_audio(&IsoData::new(0x123, 1, &[0x44])); in merge()
664 m.arbiter().unwrap().push_audio(&IsoData::new(0x123, 2, &[0x55, 0x66])); in merge()
737 m.arbiter().unwrap().push_audio(&IsoData::new(0x123, 3, &[0x33])); in merge()
738 m.arbiter().unwrap().push_audio(&IsoData::new(0x123, 4, &[0x44, 0x55])); in merge()
908 m.arbiter().unwrap().push_audio(&IsoData::new(0x456, 6, &[0x66, 0x77])); in merge()
Dlib.rs35 mod arbiter; module
/packages/modules/Bluetooth/system/rust/src/gatt/
Darbiter.rs23 let arbiter = Arc::new(Mutex::new(IsolationManager::new())); in initialize_arbiter() localVariable
26 *lock = Some(arbiter.clone()); in initialize_arbiter()
37 arbiter in initialize_arbiter()
83 let is_isolated = with_arbiter(|arbiter| arbiter.is_advertiser_isolated(advertiser)); in on_le_connect()
103 let was_isolated = with_arbiter(|arbiter| arbiter.is_connection_isolated(tcb_idx)); in on_le_disconnect()
124 with_arbiter(|arbiter| try_parse_att_server_packet(arbiter, tcb_idx, &packet)) in intercept_packet()
141 if with_arbiter(|arbiter| arbiter.is_connection_isolated(tcb_idx)) { in on_mtu_event()
Dffi.rs16 use super::arbiter::with_arbiter;
402 with_arbiter(|arbiter| arbiter.is_connection_isolated(ConnectionId(conn_id).get_tcb_idx())) in is_connection_isolated()
/packages/modules/Bluetooth/system/rust/src/
Dlib.rs130 let arbiter = gatt::arbiter::initialize_arbiter(); in run() localVariable
137 let gatt_module = &mut gatt::server::GattModule::new(att_transport.clone(), arbiter); in run()
161 gatt::arbiter::clean_arbiter(); in run()
Dgatt.rs4 pub mod arbiter; module
/packages/modules/Bluetooth/system/test/mock/
Dmock_stack_arbiter_acl_arbiter.cc21 namespace arbiter { namespace
/packages/modules/Bluetooth/system/stack/arbiter/
Dacl_arbiter.h31 namespace arbiter {
Dacl_arbiter.cc32 namespace arbiter { namespace
/packages/modules/Bluetooth/system/stack/gatt/
Dgatt_main.cc498 bluetooth::shim::arbiter::GetArbiter().OnLeDisconnect(p_tcb->tcb_idx); in gatt_le_connect_cback()
544 bluetooth::shim::arbiter::GetArbiter().OnLeConnect(p_tcb->tcb_idx, advertising_set.value()); in gatt_le_connect_cback()
730 bluetooth::shim::arbiter::GetArbiter().InterceptAttPacket(p_tcb->tcb_idx, p_buf); in gatt_le_data_ind()
732 if (decision == bluetooth::shim::arbiter::InterceptAction::DROP) { in gatt_le_data_ind()
Dgatt_cl.cc1121 bluetooth::shim::arbiter::GetArbiter().OnIncomingMtuResp(tcb.tcb_idx, tcb.payload_size); in gatt_process_mtu_rsp()
Dgatt_api.cc735 bluetooth::shim::arbiter::GetArbiter().OnOutgoingMtuReq(tcb_idx); in GATTC_ConfigureMTU()
Dgatt_sr.cc895 bluetooth::shim::arbiter::GetArbiter().OnIncomingMtuReq(tcb.tcb_idx, tcb.payload_size); in gatts_process_mtu_req()
/packages/modules/Bluetooth/system/rust/tests/
Dgatt_server_test.rs52 let arbiter = IsolationManager::new(); in start_gatt_module() localVariable
53 let gatt = GattModule::new(Rc::new(transport), Arc::new(Mutex::new(arbiter))); in start_gatt_module()
/packages/modules/Bluetooth/system/stack/
DBUILD.gn67 "arbiter/acl_arbiter.cc",
DAndroid.bp102 "arbiter/acl_arbiter.cc",
1973 "arbiter/acl_arbiter.cc",
/packages/inputmethods/LatinIME/dictionaries/
Den_GB_wordlist.combined.gz1dictionary=main:en_gb,locale=en_GB,description=English (UK),date ...
Den_US_wordlist.combined.gz1dictionary=main:en_us,locale=en_US,description=English (US),date ...
Den_wordlist.combined.gz1dictionary=main:en,locale=en,description=English,date=1414726273, ...
Dnl_wordlist.combined.gz1dictionary=main:nl,locale=nl,description=Nederlands,date=1414726258, ...
Dpl_wordlist.combined.gz1dictionary=main:pl,locale=pl,description=Polski,date=1414726264, ...
Dfi_wordlist.combined.gz1dictionary=main:fi,locale=fi,description=Suomi,date=1393228135, ...
Dro_wordlist.combined.gz1dictionary=main:ro,locale=ro,description=Română,date=1412325511, ...