Home
last modified time | relevance | path

Searched refs:dispatcher_ (Results 1 - 25 of 60) sorted by relevance

123

/foundation/communication/bluetooth_service/services/bluetooth/service/src/util/
H A 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_service/services/bluetooth/service/src/classic/
H A Dclassic_battery_observer.cpp25 ClassicBatteryObserverHf::ClassicBatteryObserverHf(utility::Dispatcher &dispatcher) : dispatcher_(&dispatcher) in ClassicBatteryObserverHf()
38 dispatcher_->PostTask(std::bind(&ClassicBatteryObserverHf::SetBatteryLevel, this, device, batteryLevel)); in OnBatteryLevelChanged()
50 ClassicBatteryObserverAg::ClassicBatteryObserverAg(utility::Dispatcher &dispatcher) : dispatcher_(&dispatcher) in ClassicBatteryObserverAg()
63 dispatcher_->PostTask(std::bind(&ClassicBatteryObserverAg::SetBatteryLevel, this, device, indValue)); in OnHfBatteryLevelChanged()
H A Dclassic_battery_observer.h49 utility::Dispatcher *dispatcher_ = nullptr; member in OHOS::bluetooth::ClassicBatteryObserverHf
61 utility::Dispatcher *dispatcher_ = nullptr; member in OHOS::bluetooth::ClassicBatteryObserverAg
/foundation/CastEngine/castengine_wifi_display/tests/unittest/impl/screen_capture/mock/
H A Dmock_screen_capture_consumer.h36 dispatcher_ = std::make_shared<BufferDispatcher>(); in Initialize()
43 dispatcher_ = nullptr; in DeInitialize()
48 std::shared_ptr<BufferDispatcher> dispatcher_; member in OHOS::Sharing::MockScreenCaptureConsumer
/foundation/communication/bluetooth_service/services/bluetooth/service/src/common/
H A Dadapter_manager.cpp81 std::unique_ptr<utility::Dispatcher> dispatcher_ = nullptr; member
122 dispatcher_ = std::make_unique<utility::Dispatcher>("AdapterManager"); in impl()
123 dispatcher_->Initialize(); in impl()
131 if (dispatcher_ != nullptr) { in ~impl()
132 dispatcher_->Uninitialize(); in ~impl()
150 dispatcher_->PostTask(std::bind(&AdapterManager::impl::ProcessMessage, this, transport, msg)); in OnEnable()
167 dispatcher_->PostTask(std::bind(&AdapterManager::impl::ProcessMessage, this, transport, msg)); in OnDisable()
227 ProfileServiceManager::Initialize(*pimpl->dispatcher_); in Start()
229 IPowerManager::Initialize(*pimpl->dispatcher_); in Start()
236 pimpl->dispatcher_ in Start()
[all...]
H A Dpower_manager.cpp69 explicit impl(utility::Dispatcher &dispatcher) : dispatcher_(dispatcher) in impl()
79 utility::Dispatcher &dispatcher_; member
143 pimpl->dispatcher_.PostTask( in StatusUpdate()
176 powerDevices_[rawAddr] = std::make_shared<PowerDevice>(rawAddr, dispatcher_); in UpdatePowerDevicesInfo()
207 powerDevices_[rawAddr] = std::make_shared<PowerDevice>(rawAddr, dispatcher_); in ModeChangeCallBackProcess()
217 ->pimpl->dispatcher_.PostTask(std::bind(&PowerManager::impl::ModeChangeCallBackProcess, in ModeChangeCallBack()
239 ->pimpl->dispatcher_.PostTask(std::bind( in SsrCompleteCallBack()
251 powerDevices_[rawAddr] = std::make_shared<PowerDevice>(rawAddr, dispatcher_); in ConnectionCompleteCallBackProcess()
261 ->pimpl->dispatcher_.PostTask(std::bind(&PowerManager::impl::ConnectionCompleteCallBackProcess, in ConnectionCompleteCallBack()
289 ->pimpl->dispatcher_ in DisconnectionCompleteCallBack()
[all...]
/foundation/CastEngine/castengine_wifi_display/tests/unittest/impl/screen_capture/
H A Dwfd_screen_capture_test.cpp51 ASSERT_TRUE(consumer_->dispatcher_ != nullptr); in HWTEST_F()
54 consumer_->HandleSpsFrame(consumer_->dispatcher_, frame); in HWTEST_F()
60 ASSERT_TRUE(consumer_->dispatcher_ != nullptr); in HWTEST_F()
63 consumer_->HandleSpsFrame(consumer_->dispatcher_, frame); in HWTEST_F()
69 ASSERT_TRUE(consumer_->dispatcher_ != nullptr); in HWTEST_F()
72 consumer_->HandlePpsFrame(consumer_->dispatcher_, frame); in HWTEST_F()
78 ASSERT_TRUE(consumer_->dispatcher_ != nullptr); in HWTEST_F()
81 consumer_->HandlePpsFrame(consumer_->dispatcher_, frame); in HWTEST_F()
/foundation/arkui/ace_engine/frameworks/core/common/
H A Dplatform_bridge.h42 dispatcher_ = dispatcher; in SetJsMessageDispatcher()
49 WeakPtr<JsMessageDispatcher> dispatcher_; member in OHOS::Ace::PlatformBridge
/foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/
H A Dobex_socket_transport.cpp88 : 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()
465 mainTran_.dispatcher_ in OnConnectIncoming()
[all...]
/foundation/communication/bluetooth_service/services/bluetooth/service/src/gavdp/
H A Da2dp_codec_thread.cpp35 dispatcher_ = std::make_unique<Dispatcher>(name); in A2dpCodecThread()
45 dispatcher_ = nullptr; in ~A2dpCodecThread()
53 dispatcher_->PostTask( in PostMessage()
73 dispatcher_->Initialize(); in StartA2dpCodecThread()
81 dispatcher_->Uninitialize(); in StopA2dpCodecThread()
H A Da2dp_codec_thread.h99 return dispatcher_.get(); in GetDispatcher()
166 std::unique_ptr<Dispatcher> dispatcher_ {};
/foundation/communication/bluetooth_service/services/bluetooth/service/src/ble/
H A Dble_advertiser_impl.cpp47 dispatcher_(&dispatch), in BleAdvertiserImpl()
81 if ((bleAdvertiser != nullptr) && (bleAdvertiser->dispatcher_ != nullptr)) { in AdvSetParamResult()
82 bleAdvertiser->dispatcher_->PostTask(std::bind( in AdvSetParamResult()
92 if ((bleAdvertiser != nullptr) && (bleAdvertiser->dispatcher_ != nullptr)) { in AdvReadTxPower()
93 bleAdvertiser->dispatcher_->PostTask(std::bind( in AdvReadTxPower()
103 if ((bleAdvertiser != nullptr) && (bleAdvertiser->dispatcher_ != nullptr)) { in AdvSetDataResult()
104 bleAdvertiser->dispatcher_->PostTask( in AdvSetDataResult()
114 if ((bleAdvertiser != nullptr) && (bleAdvertiser->dispatcher_ != nullptr)) { in AdvSetScanRspDataResult()
115 bleAdvertiser->dispatcher_->PostTask(std::bind( in AdvSetScanRspDataResult()
125 if ((bleAdvertiser != nullptr) && (bleAdvertiser->dispatcher_ ! in AdvSetEnableResult()
[all...]
H A Dble_security.cpp40 dispatcher_(&dispatch), in BleSecurity()
103 bleSecurity->dispatcher_->PostTask( in EncryptionComplete()
121 bleSecurity->dispatcher_->PostTask(std::bind( in LeLocalEncryptionKeyReqEvent()
137 bleSecurity->dispatcher_->PostTask(std::bind( in LeRemoteEncryptionKeyReqEvent()
156 bleSecurity->dispatcher_->PostTask(std::bind( in LeSignCounterChangeNotification()
173 bleSecurity->dispatcher_->PostTask( in LePairFeatureReq()
190 bleSecurity->dispatcher_->PostTask( in LePairFeatureInd()
207 bleSecurity->dispatcher_->PostTask( in LePairMethodNotify()
224 bleSecurity->dispatcher_->PostTask( in LePairKeyPressNotification()
240 bleSecurity->dispatcher_ in LePairPassKeyReq()
[all...]
H A Dble_central_manager_impl.cpp169 dispatcher_(&dispatch), in BleCentralManagerImpl()
246 if ((centralManager != nullptr) && (centralManager->dispatcher_ != nullptr)) { in AdvertisingReport()
269 centralManager->dispatcher_->PostTask(std::bind( in AdvertisingReport()
280 if ((pCentralManager != nullptr) && (pCentralManager->dispatcher_)) { in ExAdvertisingReport()
316 pCentralManager->dispatcher_->PostTask(std::bind(&BleCentralManagerImpl::ExAdvertisingReportTask, in ExAdvertisingReport()
501 if ((centralManager != nullptr) && (centralManager->dispatcher_ != nullptr)) { in AddBleScanFilterResult()
502 centralManager->dispatcher_->PostTask(std::bind( in AddBleScanFilterResult()
511 if ((centralManager != nullptr) && (centralManager->dispatcher_ != nullptr)) { in DeleteBleScanFilterResult()
512 centralManager->dispatcher_->PostTask(std::bind( in DeleteBleScanFilterResult()
521 if ((centralManager != nullptr) && (centralManager->dispatcher_ ! in StartBleScanFilterResult()
[all...]
/foundation/ability/ability_runtime/frameworks/native/appkit/app_startup/
H A Dstartup_task_manager.cpp72 dispatcher_ = std::make_shared<StartupTaskDispatcher>(tasks_, startupSortResult); in Prepare()
79 if (dispatcher_ == nullptr) { in Run()
100 int32_t result = dispatcher_->Run(completedCallback, mainThreadAwaitCallback); in Run()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/gatt/gatts/
H A Dgeneric_attribute_service.cpp34 : serverService_(service), dispatcher_(dispatcher), in GenericAttributeService()
50 service_.dispatcher_.PostTask(std::bind(&GenericAttributeService::ConnectIncoming, &service_, device));
52 service_.dispatcher_.PostTask(std::bind(&GenericAttributeService::Disconnected, &service_, device));
59 service_.dispatcher_.PostTask(
67 service_.dispatcher_.PostTask(std::bind(&GenericAttributeService::ComfirmNotify, &service_, device));
/foundation/CastEngine/castengine_wifi_display/tests/unittest/mediaplayer/
H A Dmediacontroller_unit_test.cpp87 BufferDispatcher::Ptr dispatcher_ = nullptr; member in OHOS::Sharing::MediaControllerTestBaseImpl
120 return dispatcher_; in GetBufferDispatcher()
160 if (dispatcher_ != nullptr) { in BufferDispatcherReset()
161 dispatcher_->StopDispatch(); in BufferDispatcherReset()
162 dispatcher_->FlushBuffer(); in BufferDispatcherReset()
163 dispatcher_->ReleaseAllReceiver(); in BufferDispatcherReset()
195 dispatcher_->SetSpsNalu(sps); in SpsDataSetup()
204 dispatcher_->SetPpsNalu(pps); in PpsDataSetup()
232 dispatcher_->InputData(mediaData); in MediaDataSetup()
243 auto spsOld = dispatcher_ in VideoDataPlayOnce()
[all...]
H A Dvideoplaycontroller_unit_test.cpp63 BufferDispatcher::Ptr dispatcher_ = nullptr; member in OHOS::Sharing::VideoPlayControllerTestBaseImpl
97 return dispatcher_; in GetBufferDispatcher()
137 if (dispatcher_ != nullptr) { in BufferDispatcherReset()
138 dispatcher_->StopDispatch(); in BufferDispatcherReset()
139 dispatcher_->FlushBuffer(); in BufferDispatcherReset()
140 dispatcher_->ReleaseAllReceiver(); in BufferDispatcherReset()
172 dispatcher_->SetSpsNalu(sps); in SpsDataSetup()
181 dispatcher_->SetPpsNalu(pps); in PpsDataSetup()
209 dispatcher_->InputData(mediaData); in MediaDataSetup()
220 auto spsOld = dispatcher_ in VideoDataPlayOnce()
[all...]
H A Daudioplaycontroller_unit_test.cpp52 BufferDispatcher::Ptr dispatcher_ = nullptr; member in OHOS::Sharing::AudioPlayControllerTestBaseImpl
59 dispatcher_ = std::make_shared<BufferDispatcher>(maxBufferCapacity, maxBufferCapacityIncrement); in AudioPlayControllerTestBaseImpl()
60 EXPECT_NE(nullptr, dispatcher_); in AudioPlayControllerTestBaseImpl()
105 if (dispatcher_ != nullptr) { in BufferDispatcherReset()
106 dispatcher_->StopDispatch(); in BufferDispatcherReset()
107 dispatcher_->FlushBuffer(); in BufferDispatcherReset()
108 dispatcher_->ReleaseAllReceiver(); in BufferDispatcherReset()
114 return dispatcher_; in GetBufferDispatcher()
142 dispatcher_->InputData( in AudioPlayerPlaybackStart()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/transport/
H A Dtransport_l2cap.cpp31 dispatcher_(createInfo.dispatcher) in L2capTransport()
180 L2capTransportInfo createInfo = {&addr, lpsm_, rpsm_, localMtu_, observer_, dispatcher_}; in AddTransportInternal()
268 transport->dispatcher_.PostTask( in TransportL2cConnectReqCallback()
285 transport->dispatcher_.PostTask(std::bind(&L2capTransport::TransportRecvConnectionReqCallbackNative, in TransportRecvConnectionReqCallback()
307 transport->dispatcher_.PostTask(std::bind(&L2capTransport::TransportRecvConnectionRspCallbackNative, in TransportRecvConnectionRspCallback()
329 transport->dispatcher_.PostTask(std::bind( in TransportRecvConfigReqCallback()
346 transport->dispatcher_.PostTask(std::bind( in TransportRecvConfigRspCallback()
365 transport->dispatcher_.PostTask( in TransportRecvDisconnectionReqCallback()
384 transport->dispatcher_.PostTask( in TransportRecvDisconnectionRspCallback()
403 transport->dispatcher_ in TransportDisconnectAbnormalCallback()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/mediachannel/
H A Dmedia_channel.cpp48 dispatcher_ = std::make_shared<BufferDispatcher>(maxBufferCapacity, bufferCapacityIncrement); in MediaChannel()
59 if (dispatcher_ != nullptr) { in ~MediaChannel()
60 dispatcher_->StopDispatch(); in ~MediaChannel()
61 dispatcher_->FlushBuffer(); in ~MediaChannel()
62 dispatcher_->ReleaseAllReceiver(); in ~MediaChannel()
63 dispatcher_.reset(); in ~MediaChannel()
233 if (dispatcher_) { in CreateConsumer()
234 dispatcher_->SetBufferDispatcherListener(shared_from_this()); in CreateConsumer()
803 dispatcher_->AttachReceiver(producer); in HandleStartProducer()
838 dispatcher_ in HandleStopProducer()
[all...]
H A Dmedia_channel.h61 return dispatcher_;
109 BufferDispatcher::Ptr dispatcher_ = nullptr; member in OHOS::Sharing::MediaChannel
/foundation/ability/ability_runtime/interfaces/kits/native/appkit/app_startup/
H A Dstartup_task_manager.h49 std::shared_ptr<StartupTaskDispatcher> dispatcher_; member in OHOS::AbilityRuntime::StartupTaskManager
/foundation/communication/bluetooth_service/services/bluetooth/service/src/gatt/gas/
H A Dgeneric_access_service.cpp106 service_.dispatcher_.PostTask(std::bind(&GenericAccessService::OnDeviceNameChanged, &service_, deviceName)); in OnDeviceNameChanged()
112 service_.dispatcher_.PostTask(std::bind(&GenericAccessService::OnAdvertisingStateChanged, &service_, state)); in OnAdvertisingStateChanged()
136 service_.dispatcher_.PostTask(std::bind(&GenericAccessService::OnScanModeChanged, &service_, mode)); in OnScanModeChanged()
141 service_.dispatcher_.PostTask(std::bind(&GenericAccessService::OnDeviceNameChanged, &service_, deviceName)); in OnDeviceNameChanged()
155 dispatcher_(dispatcher) in GenericAccessService()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/hid_host/
H A Dhid_host_hogp.cpp27 dispatcher_ = std::make_unique<Dispatcher>(address_); in HidHostHogp()
33 dispatcher_->Uninitialize(); in ~HidHostHogp()
34 dispatcher_ = nullptr; in ~HidHostHogp()
127 dispatcher_->Initialize(); in SendData()
128 dispatcher_->PostTask(std::bind(&HidHostHogp::SendData_, this, msg)); in SendData()
679 dispatcher_->Initialize(); in ProcessEvent()
680 dispatcher_->PostTask(std::bind(&HidHostHogp::OnServicesDiscoveredTask, this, event.arg1_)); in ProcessEvent()
683 dispatcher_->Uninitialize(); in ProcessEvent()

Completed in 18 milliseconds

123