Home
last modified time | relevance | path

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

123

/foundation/communication/bluetooth/services/bluetooth_standard/service/src/util/
Dcontext.h63 : name_(name), version_(version), dispatcher_(std::make_unique<Dispatcher>(name)) in Context()
123 dispatcher_->Initialize(); in Initialize()
133 dispatcher_->Uninitialize(); in Uninitialize()
144 return dispatcher_.get(); in GetDispatcher()
184 std::unique_ptr<Dispatcher> dispatcher_ {};
/foundation/communication/bluetooth/services/bluetooth_standard/service/src/classic/
Dclassic_battery_observer.cpp24 ClassicBatteryObserverHf::ClassicBatteryObserverHf(utility::Dispatcher &dispatcher) : dispatcher_(&… in ClassicBatteryObserverHf()
40dispatcher_->PostTask(std::bind(&ClassicBatteryObserverHf::SetBatteryLevel, this, device, batteryL… in OnBatteryLevelChanged()
50 ClassicBatteryObserverAg::ClassicBatteryObserverAg(utility::Dispatcher &dispatcher) : dispatcher_(&… in ClassicBatteryObserverAg()
66dispatcher_->PostTask(std::bind(&ClassicBatteryObserverAg::SetBatteryLevel, this, device, indValue… in OnHfBatteryLevelChanged()
Dclassic_battery_observer.h48 utility::Dispatcher *dispatcher_ = nullptr;
60 utility::Dispatcher *dispatcher_ = nullptr;
/foundation/communication/bluetooth/services/bluetooth_standard/service/src/common/
Dadapter_manager.cpp73 std::unique_ptr<utility::Dispatcher> dispatcher_ = nullptr; member
113 dispatcher_ = std::make_unique<utility::Dispatcher>("AdapterManager"); in impl()
114 dispatcher_->Initialize(); in impl()
122 if (dispatcher_ != nullptr) { in ~impl()
123 dispatcher_->Uninitialize(); in ~impl()
141 dispatcher_->PostTask(std::bind(&AdapterManager::impl::ProcessMessage, this, transport, msg)); in OnEnable()
158 dispatcher_->PostTask(std::bind(&AdapterManager::impl::ProcessMessage, this, transport, msg)); in OnDisable()
219 ProfileServiceManager::Initialize(*pimpl->dispatcher_); in Start()
221 IPowerManager::Initialize(*pimpl->dispatcher_); in Start()
228 …pimpl->dispatcher_->PostTask(std::bind(&utility::StateMachine::ProcessMessage, &(pimpl->sysStateMa… in Start()
[all …]
Dpower_manager.cpp68 explicit impl(utility::Dispatcher &dispatcher) : dispatcher_(dispatcher) in impl()
78 utility::Dispatcher &dispatcher_; member
145 pimpl->dispatcher_.PostTask( in StatusUpdate()
179 powerDevices_[rawAddr] = std::make_shared<PowerDevice>(rawAddr, dispatcher_); in UpdatePowerDevicesInfo()
210 powerDevices_[rawAddr] = std::make_shared<PowerDevice>(rawAddr, dispatcher_); in ModeChangeCallBackProcess()
220 ->pimpl->dispatcher_.PostTask(std::bind(&PowerManager::impl::ModeChangeCallBackProcess, in ModeChangeCallBack()
242 ->pimpl->dispatcher_.PostTask(std::bind( in SsrCompleteCallBack()
255 powerDevices_[rawAddr] = std::make_shared<PowerDevice>(rawAddr, dispatcher_); in ConnectionCompleteCallBackProcess()
265 … ->pimpl->dispatcher_.PostTask(std::bind(&PowerManager::impl::ConnectionCompleteCallBackProcess, in ConnectionCompleteCallBack()
294 … ->pimpl->dispatcher_.PostTask(std::bind(&PowerManager::impl::DisconnectionCompleteCallBackProcess, in DisconnectionCompleteCallBack()
/foundation/ace/ace_engine/frameworks/bridge/declarative_frontend/engine/quickjs/
Dqjs_declarative_engine_instance.h34 : context_(nullptr), frontendDelegate_(delegate), dispatcher_(nullptr) in QJSDeclarativeEngineInstance()
90 dispatcher_ = dispatcher; in SetJsMessageDispatcher()
102 auto dispatcher = dispatcher_.Upgrade(); in CallPlatformFunction()
114 auto dispatcher = dispatcher_.Upgrade(); in CallCurlFunction()
139 auto dispatcher = dispatcher_.Upgrade(); in PluginErrorCallback()
223 WeakPtr<JsMessageDispatcher> dispatcher_; variable
/foundation/communication/bluetooth/services/bluetooth_standard/service/src/gavdp/
Da2dp_codec_thread.cpp30 dispatcher_ = std::make_unique<Dispatcher>(name); in A2dpCodecThread()
37 dispatcher_ = nullptr; in ~A2dpCodecThread()
45 dispatcher_->PostTask( in PostMessage()
63 dispatcher_->Initialize(); in StartA2dpCodecThread()
71 dispatcher_->Uninitialize(); in StopA2dpCodecThread()
Da2dp_codec_thread.h100 return dispatcher_.get(); in GetDispatcher()
145 std::unique_ptr<Dispatcher> dispatcher_ {};
/foundation/ace/ace_engine/frameworks/core/common/
Dplatform_bridge.h42 dispatcher_ = dispatcher; in SetJsMessageDispatcher()
49 WeakPtr<JsMessageDispatcher> dispatcher_;
Dplatform_bridge.cpp43 auto dispatcher = dispatcher_.Upgrade(); in SendMessage()
/foundation/communication/bluetooth/services/bluetooth_standard/service/src/obex/
Dobex_socket_transport.cpp87 : ObexClientTransport(observer), dispatcher_(dispatcher), in ObexClientSocketTransport()
190 obexTran_.dispatcher_.PostTask(std::bind( in OnConnected()
198 obexTran_.dispatcher_.PostTask( in OnDisconnected()
206 obexTran_.dispatcher_.PostTask( in OnDisconnectSuccess()
214 obexTran_.dispatcher_.PostTask( in OnDataAvailable()
222 obexTran_.dispatcher_.PostTask( in OnDataAvailable()
230 obexTran_.dispatcher_.PostTask( in OnDataBusy()
238 obexTran_.dispatcher_.PostTask( in OnTransportError()
357 : ObexServerTransport(observer), dispatcher_(dispatcher) in ObexServerSocketTransport()
464 mainTran_.dispatcher_.PostTask( in OnConnectIncoming()
[all …]
/foundation/ace/ace_engine/frameworks/bridge/js_frontend/engine/quickjs/
Dqjs_engine.h106 dispatcher_ = dispatcher; in SetJsMessageDispatcher()
116 auto dispatcher = dispatcher_.Upgrade(); in CallPlatformFunction()
129 auto dispatcher = dispatcher_.Upgrade(); in CallPlatformFunctionSync()
142 auto dispatcher = dispatcher_.Upgrade(); in CallCurlFunction()
155 auto dispatcher = dispatcher_.Upgrade(); in PluginErrorCallback()
200 WeakPtr<JsMessageDispatcher> dispatcher_; variable
/foundation/communication/bluetooth/services/bluetooth_standard/service/src/ble/
Dble_advertiser_impl.cpp49 dispatcher_(&dispatch), in BleAdvertiserImpl()
80 if ((bleAdvertiser != nullptr) && (bleAdvertiser->dispatcher_ != nullptr)) { in AdvSetParamResult()
81 bleAdvertiser->dispatcher_->PostTask(std::bind( in AdvSetParamResult()
91 if ((bleAdvertiser != nullptr) && (bleAdvertiser->dispatcher_ != nullptr)) { in AdvReadTxPower()
92 bleAdvertiser->dispatcher_->PostTask(std::bind( in AdvReadTxPower()
102 if ((bleAdvertiser != nullptr) && (bleAdvertiser->dispatcher_ != nullptr)) { in AdvSetDataResult()
103 bleAdvertiser->dispatcher_->PostTask( in AdvSetDataResult()
113 if ((bleAdvertiser != nullptr) && (bleAdvertiser->dispatcher_ != nullptr)) { in AdvSetScanRspDataResult()
114 bleAdvertiser->dispatcher_->PostTask(std::bind( in AdvSetScanRspDataResult()
124 if ((bleAdvertiser != nullptr) && (bleAdvertiser->dispatcher_ != nullptr)) { in AdvSetEnableResult()
[all …]
Dble_security.cpp39 dispatcher_(&dispatch), in BleSecurity()
102 bleSecurity->dispatcher_->PostTask( in EncryptionComplete()
120 bleSecurity->dispatcher_->PostTask(std::bind( in LeLocalEncryptionKeyReqEvent()
136 bleSecurity->dispatcher_->PostTask(std::bind( in LeRemoteEncryptionKeyReqEvent()
155 bleSecurity->dispatcher_->PostTask(std::bind( in LeSignCounterChangeNotification()
172 bleSecurity->dispatcher_->PostTask( in LePairFeatureReq()
189 bleSecurity->dispatcher_->PostTask( in LePairFeatureInd()
206 bleSecurity->dispatcher_->PostTask( in LePairMethodNotify()
223 bleSecurity->dispatcher_->PostTask( in LePairKeyPressNotification()
239 bleSecurity->dispatcher_->PostTask( in LePairPassKeyReq()
[all …]
Dble_central_manager_impl.cpp155 dispatcher_(&dispatch), in BleCentralManagerImpl()
222 if ((centralManager != nullptr) && (centralManager->dispatcher_ != nullptr)) { in AdvertisingReport()
245 centralManager->dispatcher_->PostTask(std::bind( in AdvertisingReport()
256 if ((pCentralManager != nullptr) && (pCentralManager->dispatcher_)) { in ExAdvertisingReport()
292 … pCentralManager->dispatcher_->PostTask(std::bind(&BleCentralManagerImpl::ExAdvertisingReportTask, in ExAdvertisingReport()
482 if ((centralManager != nullptr) && (centralManager->dispatcher_ != nullptr)) { in ScanSetParamResult()
483 centralManager->dispatcher_->PostTask(std::bind( in ScanSetParamResult()
493 if ((centralManager != nullptr) && (centralManager->dispatcher_ != nullptr)) { in ScanExSetParamResult()
494 … centralManager->dispatcher_->PostTask(std::bind(&BleCentralManagerImpl::HandleGapExScanEvent, in ScanExSetParamResult()
506 if ((centralManager != nullptr) && (centralManager->dispatcher_ != nullptr)) { in ScanSetEnableResult()
[all …]
/foundation/communication/bluetooth/services/bluetooth_standard/service/src/transport/
Dtransport_l2cap.cpp29 dispatcher_(createInfo.dispatcher) in L2capTransport()
178 L2capTransportInfo createInfo = {&addr, lpsm_, rpsm_, localMtu_, observer_, dispatcher_}; in AddTransportInternal()
269 transport->dispatcher_.PostTask( in TransportL2cConnectReqCallback()
286 …transport->dispatcher_.PostTask(std::bind(&L2capTransport::TransportRecvConnectionReqCallbackNativ… in TransportRecvConnectionReqCallback()
308 …transport->dispatcher_.PostTask(std::bind(&L2capTransport::TransportRecvConnectionRspCallbackNativ… in TransportRecvConnectionRspCallback()
330 transport->dispatcher_.PostTask(std::bind( in TransportRecvConfigReqCallback()
347 transport->dispatcher_.PostTask(std::bind( in TransportRecvConfigRspCallback()
366 transport->dispatcher_.PostTask( in TransportRecvDisconnectionReqCallback()
385 transport->dispatcher_.PostTask( in TransportRecvDisconnectionRspCallback()
404 transport->dispatcher_.PostTask( in TransportDisconnectAbnormalCallback()
[all …]
/foundation/communication/bluetooth/services/bluetooth_standard/service/src/gatt/gatts/
Dgeneric_attribute_service.cpp33 : serverService_(service), dispatcher_(dispatcher), in GenericAttributeService()
49 …service_.dispatcher_.PostTask(std::bind(&GenericAttributeService::ConnectIncoming, &service_, devi… in OnConnectionStateChanged()
51 …service_.dispatcher_.PostTask(std::bind(&GenericAttributeService::Disconnected, &service_, device)… in OnConnectionStateChanged()
58 service_.dispatcher_.PostTask( in OnServiceChanged()
66 …service_.dispatcher_.PostTask(std::bind(&GenericAttributeService::ComfirmNotify, &service_, device… in OnNotifyConfirm()
Dgeneric_attribute_service.h57 utility::Dispatcher &dispatcher_; variable
/foundation/ace/ace_engine/frameworks/bridge/js_frontend/engine/v8/
Dv8_engine.h121 dispatcher_ = dispatcher; in SetJsMessageDispatcher()
122 isolate_->SetData(DISPATCHER, static_cast<void*>(&dispatcher_)); in SetJsMessageDispatcher()
127 return dispatcher_; in GetJsMessageDispatcher()
170 WeakPtr<JsMessageDispatcher> dispatcher_; variable
/foundation/ace/ace_engine/adapter/ohos/entrance/pa_engine/engine/quickjs/
Dqjs_pa_engine.h68 dispatcher_ = dispatcher; in SetJsMessageDispatcher()
78 auto dispatcher = dispatcher_.Upgrade(); in CallPlatformFunction()
90 auto dispatcher = dispatcher_.Upgrade(); in PluginErrorCallback()
108 WeakPtr<JsMessageDispatcher> dispatcher_; variable
/foundation/ace/ace_engine/frameworks/bridge/declarative_frontend/engine/v8/
Dv8_declarative_engine.h181 dispatcher_ = dispatcher; in SetJsMessageDispatcher()
182 isolate_->SetData(DISPATCHER, static_cast<void*>(&dispatcher_)); in SetJsMessageDispatcher()
197 return static_cast<void*>(&dispatcher_); in GetJsMessageDispatcherForV8Data()
208 isolate->SetData(DISPATCHER, static_cast<void*>(&dispatcher_)); in SetDispatcher()
239 WeakPtr<JsMessageDispatcher> dispatcher_; variable
/foundation/communication/bluetooth/services/bluetooth_standard/service/src/gatt/gas/
Dgeneric_access_service.cpp104 …service_.dispatcher_.PostTask(std::bind(&GenericAccessService::OnDeviceNameChanged, &service_, dev… in OnDeviceNameChanged()
110 …service_.dispatcher_.PostTask(std::bind(&GenericAccessService::OnAdvertisingStateChanged, &service… in OnAdvertisingStateChanged()
133 …service_.dispatcher_.PostTask(std::bind(&GenericAccessService::OnScanModeChanged, &service_, mode)… in OnScanModeChanged()
138 …service_.dispatcher_.PostTask(std::bind(&GenericAccessService::OnDeviceNameChanged, &service_, dev… in OnDeviceNameChanged()
152 dispatcher_(dispatcher) in GenericAccessService()
Dgeneric_access_service.h71 utility::Dispatcher &dispatcher_; variable
/foundation/ace/ace_engine/frameworks/bridge/declarative_frontend/engine/jsi/
Djsi_declarative_engine.h73 return dispatcher_; in GetJsMessageDispatcher()
107 dispatcher_ = dispatcher; in SetJsMessageDispatcher()
164 WeakPtr<JsMessageDispatcher> dispatcher_; variable
/foundation/communication/bluetooth/services/bluetooth_standard/service/src/gatt/
Dgatt_server_profile.cpp31 dispatcher_(dispatcher), in impl()
41 utility::Dispatcher *dispatcher_ = nullptr; member
316 …object->dispatcher_->PostTask(std::bind(&impl::ReceiveResponseResultPostTask, object, connectHandl… in ReceiveResponseResult()
374 dispatcher_->PostTask( in DiscoverAllPrimaryServiceResponsePostTask()
438 dispatcher_->PostTask( in DiscoverPrimaryServiceByUuidResponsePostTask()
496dispatcher_->PostTask(std::bind(&impl::FindIncludedServiceResponse, this, connectHandle, startHand… in FindIncludedServiceResponsePostTask()
553 dispatcher_->PostTask( in DiscoverCharacteristicResponsePostTask()
611 dispatcher_->PostTask( in DiscoverAllCharacteristicDescriptorResponsePostTask()
671 dispatcher_->PostTask(std::bind(&impl::ReadValueResponse, this, connectHandle, attHandle)); in ReadValueResponsePostTask()
736 dispatcher_->PostTask(std::bind( in ReadUsingCharacteristicByUuidResponsePostTask()
[all …]

123