Home
last modified time | relevance | path

Searched refs:dispatcher (Results 1 - 25 of 89) sorted by relevance

1234

/foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/unittest/pipeline/
H A Drs_task_dispatcher_test.cpp44 RSTaskDispatcher& dispatcher = RSTaskDispatcher::GetInstance(); in HWTEST_F() local
45 dispatcher.RegisterTaskDispatchFunc(1, [](RSTaskDispatcher::RSTask task, bool isSyncTask) {}); in HWTEST_F()
46 EXPECT_TRUE(dispatcher.HasRegisteredTask(1)); in HWTEST_F()
57 RSTaskDispatcher& dispatcher = RSTaskDispatcher::GetInstance(); in HWTEST_F() local
58 dispatcher.RegisterTaskDispatchFunc(1, [](RSTaskDispatcher::RSTask task, bool isSyncTask) {}); in HWTEST_F()
59 dispatcher.PostTask(1, []() {}); in HWTEST_F()
60 dispatcher.PostTask(0, []() {}); in HWTEST_F()
71 RSTaskDispatcher& dispatcher = RSTaskDispatcher::GetInstance(); in HWTEST_F() local
72 dispatcher.RegisterTaskDispatchFunc(1, [](RSTaskDispatcher::RSTask task, bool isSyncTask) {}); in HWTEST_F()
74 EXPECT_TRUE(dispatcher in HWTEST_F()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/mediaplayer/src/
H A Dmedia_controller.cpp76 auto dispatcher = mediaChannel->GetDispatcher(); in Start() local
77 RETURN_IF_NULL(dispatcher); in Start()
81 if (audioPlayController_->Start(dispatcher)) { in Start()
90 if (item.second->Start(dispatcher)) { in Start()
105 auto dispatcher = mediaChannel->GetDispatcher(); in Stop() local
106 RETURN_IF_NULL(dispatcher); in Stop()
110 audioPlayController_->Stop(dispatcher); in Stop()
118 item.second->Stop(dispatcher); in Stop()
174 auto dispatcher = mediaChannel->GetDispatcher(); in AppendSurface() local
175 videoPlayController->Start(dispatcher); in AppendSurface()
193 auto dispatcher = mediaChannel->GetDispatcher(); RemoveSurface() local
[all...]
H A Daudio_play_controller.cpp58 bool AudioPlayController::Start(BufferDispatcher::Ptr &dispatcher) in Start() argument
61 RETURN_FALSE_IF_NULL(dispatcher); in Start()
74 dispatcher->AttachReceiver(bufferReceiver_); in Start()
83 void AudioPlayController::Stop(BufferDispatcher::Ptr &dispatcher) in Stop() argument
86 if (dispatcher && bufferReceiver_) { in Stop()
87 dispatcher->DetachReceiver(bufferReceiver_); in Stop()
H A Dvideo_play_controller.cpp122 bool VideoPlayController::Start(BufferDispatcher::Ptr &dispatcher) in Start() argument
133 dispatcher->AttachReceiver(bufferReceiver_); in Start()
143 void VideoPlayController::Stop(BufferDispatcher::Ptr &dispatcher) in Stop() argument
146 RETURN_IF_NULL(dispatcher); in Stop()
149 dispatcher->DetachReceiver(bufferReceiver_); in Stop()
229 MEDIA_LOGD("get sps from dispatcher."); in VideoPlayThread()
234 MEDIA_LOGD("get pps from dispatcher."); in VideoPlayThread()
/foundation/CastEngine/castengine_wifi_display/services/impl/screen_capture/
H A Dscreen_capture_consumer.cpp30 auto dispatcher = listener->GetDispatcher(); in OnFrame() local
31 if (dispatcher) { in OnFrame()
32 auto mediaData = dispatcher->RequestDataBuffer(MEDIA_TYPE_AUDIO, frame->Size()); in OnFrame()
38 MEDIA_LOGD("recv audio encode data: codec:%{public}d size: %{public}d & put into dispatcher: %{public}u.", in OnFrame()
39 mediaData->codecId, frame->Size(), dispatcher->GetDispatcherId()); in OnFrame()
41 dispatcher->InputData(mediaData); in OnFrame()
51 void ScreenCaptureConsumer::HandleSpsFrame(BufferDispatcher::Ptr dispatcher, const Frame::Ptr &frame) in HandleSpsFrame() argument
53 RETURN_IF_NULL(dispatcher); in HandleSpsFrame()
54 auto spsOld = dispatcher->GetSPS(); in HandleSpsFrame()
62 dispatcher in HandleSpsFrame()
65 HandlePpsFrame(BufferDispatcher::Ptr dispatcher, const Frame::Ptr &frame) HandlePpsFrame() argument
92 BufferDispatcher::Ptr dispatcher = listener->GetDispatcher(); OnFrame() local
[all...]
H A Dscreen_capture_consumer.h73 void HandleSpsFrame(BufferDispatcher::Ptr dispatcher, const Frame::Ptr &frame);
74 void HandlePpsFrame(BufferDispatcher::Ptr dispatcher, const Frame::Ptr &frame);
/foundation/communication/bluetooth_service/services/bluetooth/service/src/classic/
H A Dclassic_battery_observer.cpp25 ClassicBatteryObserverHf::ClassicBatteryObserverHf(utility::Dispatcher &dispatcher) : dispatcher_(&dispatcher) in ClassicBatteryObserverHf() argument
50 ClassicBatteryObserverAg::ClassicBatteryObserverAg(utility::Dispatcher &dispatcher) : dispatcher_(&dispatcher) in ClassicBatteryObserverAg() argument
H A Dclassic_battery_observer.h35 #include "dispatcher.h"
43 explicit ClassicBatteryObserverHf(utility::Dispatcher &dispatcher);
55 explicit ClassicBatteryObserverAg(utility::Dispatcher &dispatcher);
/foundation/CastEngine/castengine_wifi_display/services/impl/wfd/wfd_sink/
H A Dwfd_rtp_consumer.cpp224 auto dispatcher = listener->GetDispatcher(); in OnRtpUnpackCallback() local
225 RETURN_IF_NULL(dispatcher); in OnRtpUnpackCallback()
239 MEDIA_LOGD("audio & put it into dispatcher: %{public}u, consumerId: %{public}u.", dispatcher->GetDispatcherId(), in OnRtpUnpackCallback()
242 dispatcher->InputData(mediaData); in OnRtpUnpackCallback()
258 dispatcher->InputData(mediaData); in OnRtpUnpackCallback()
268 auto spsOld = dispatcher->GetSPS(); in OnRtpUnpackCallback()
279 dispatcher->SetSpsNalu(sps); in OnRtpUnpackCallback()
283 auto ppsOld = dispatcher->GetPPS(); in OnRtpUnpackCallback()
294 dispatcher in OnRtpUnpackCallback()
[all...]
/foundation/arkui/ace_engine/frameworks/core/common/
H A Dplatform_bridge.cpp42 auto dispatcher = dispatcher_.Upgrade(); in SendMessage() local
43 CHECK_NULL_VOID(dispatcher); in SendMessage()
44 dispatcher->Dispatch(INTERNAL_MODULE_GROUP, std::move(dataBuf), callbackId, true); in SendMessage()
H A Dplatform_bridge.h40 void SetJsMessageDispatcher(const RefPtr<JsMessageDispatcher>& dispatcher) in SetJsMessageDispatcher() argument
42 dispatcher_ = dispatcher; in SetJsMessageDispatcher()
/foundation/communication/bluetooth_service/services/bluetooth/service/src/common/
H A Dpower_manager.h20 #include "dispatcher.h"
65 * @param dispatcher dispatcher.
68 static void Initialize(utility::Dispatcher &dispatcher);
80 * @param dispatcher dispatcher.
130 explicit PowerManager(utility::Dispatcher &dispatcher);
150 * @param dispatcher dispatcher.
153 static void Initialize(utility::Dispatcher &dispatcher);
[all...]
H A Dpower_manager.cpp37 void IPowerManager::Initialize(utility::Dispatcher &dispatcher) in Initialize() argument
39 g_powerManager->Initialize(dispatcher); in Initialize()
52 void PowerManager::Initialize(utility::Dispatcher &dispatcher) in Initialize() argument
56 g_powerManager = std::make_unique<PowerManager>(dispatcher); in Initialize()
69 explicit impl(utility::Dispatcher &dispatcher) : dispatcher_(dispatcher) in impl()
102 PowerManager::PowerManager(utility::Dispatcher &dispatcher) : pimpl(std::make_unique<PowerManager::impl>(dispatcher)) in PowerManager() argument
/foundation/communication/bluetooth_service/services/bluetooth/service/src/gatt/
H A Dgatt_based_services_manager.cpp24 GattBasedServicesManager::GattBasedServicesManager(GattServerService &server, utility::Dispatcher &dispatcher) in GattBasedServicesManager() argument
25 : gas_(std::make_unique<GenericAccessService>(server, dispatcher)), in GattBasedServicesManager()
27 gatts_(std::make_unique<GenericAttributeService>(server, dispatcher)) in GattBasedServicesManager()
H A Dgatt_based_services_manager.h22 #include "dispatcher.h"
30 GattBasedServicesManager(GattServerService &server, utility::Dispatcher &dispatcher);
/foundation/CastEngine/castengine_wifi_display/tests/unittest/impl/rtp/
H A Dwfd_rtp_consumer_test.cpp195 auto dispatcher = std::make_shared<BufferDispatcher>(); in HWTEST_F() local
196 EXPECT_CALL(*listener_, GetDispatcher()).WillOnce(Return(dispatcher)); in HWTEST_F()
213 auto dispatcher = std::make_shared<BufferDispatcher>(); in HWTEST_F() local
214 EXPECT_CALL(*listener_, GetDispatcher()).WillOnce(Return(dispatcher)); in HWTEST_F()
231 auto dispatcher = std::make_shared<BufferDispatcher>(); in HWTEST_F() local
232 EXPECT_CALL(*listener_, GetDispatcher()).WillOnce(Return(dispatcher)); in HWTEST_F()
249 auto dispatcher = std::make_shared<BufferDispatcher>(); in HWTEST_F() local
250 EXPECT_CALL(*listener_, GetDispatcher()).WillOnce(Return(dispatcher)); in HWTEST_F()
/foundation/communication/dsoftbus/adapter/common/bus_center/driver/
H A Dlnn_hdf_driver_request.c67 if (softbusService->dispatcher == NULL || in LnnSendCmdToDriver()
68 softbusService->dispatcher->Dispatch == NULL) { in LnnSendCmdToDriver()
69 LNN_LOGE(LNN_STATE, "dispatcher is null, bind hdf softbus fail for module=%{public}d", moduleId); in LnnSendCmdToDriver()
84 rc = softbusService->dispatcher->Dispatch(&softbusService->object, moduleId, reqData, rspData); in LnnSendCmdToDriver()
/foundation/CastEngine/castengine_wifi_display/services/mediaplayer/include/
H A Daudio_play_controller.h35 void Stop(BufferDispatcher::Ptr &dispatcher);
37 bool Start(BufferDispatcher::Ptr &dispatcher);
H A Dvideo_play_controller.h62 void Stop(BufferDispatcher::Ptr &dispatcher);
65 bool Start(BufferDispatcher::Ptr &dispatcher);
/foundation/communication/bluetooth_service/services/bluetooth/service/src/transport/
H A Dtransport_factory.cpp24 const RawAddress *addr, uint8_t scn, uint16_t mtu, DataTransportObserver &observer, utility::Dispatcher &dispatcher) in CreateRfcommTransport()
27 return std::make_unique<RfcommTransport>(addr, scn, mtu, observer, dispatcher); in CreateRfcommTransport()
23 CreateRfcommTransport( const RawAddress *addr, uint8_t scn, uint16_t mtu, DataTransportObserver &observer, utility::Dispatcher &dispatcher) CreateRfcommTransport() argument
H A Dtransport_factory.h20 #include "dispatcher.h"
41 DataTransportObserver &observer, utility::Dispatcher &dispatcher);
/foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/
H A Dobex_mp_server.h26 const ObexPrivateServerConfig &config, ObexServerObserver &observer, utility::Dispatcher &dispatcher);
41 utility::Dispatcher &dispatcher);
H A Dobex_mp_server.cpp24 ObexServerObserver &observer, utility::Dispatcher &dispatcher) in ObexMpServer()
35 rfcommServer_ = std::make_unique<ObexPrivateMpServer>(option, observer, dispatcher); in ObexMpServer()
44 l2capServer_ = std::make_unique<ObexPrivateMpServer>(option, observer, dispatcher); in ObexMpServer()
49 const ObexPrivateServerConfig &config, ObexServerObserver &observer, utility::Dispatcher &dispatcher) in ObexPrivateMpServer()
50 : ObexPrivateServer(config, observer, dispatcher) in ObexPrivateMpServer()
23 ObexMpServer(const std::string &serviceName, const ObexServerConfig &config, ObexServerObserver &observer, utility::Dispatcher &dispatcher) ObexMpServer() argument
48 ObexPrivateMpServer( const ObexPrivateServerConfig &config, ObexServerObserver &observer, utility::Dispatcher &dispatcher) ObexPrivateMpServer() argument
H A Dobex_server.cpp19 #include "dispatcher.h"
26 utility::Dispatcher &dispatcher) in ObexServer()
37 rfcommServer_ = std::make_unique<ObexPrivateServer>(option, observer, dispatcher); in ObexServer()
46 l2capServer_ = std::make_unique<ObexPrivateServer>(option, observer, dispatcher); in ObexServer()
306 const ObexPrivateServerConfig &config, ObexServerObserver &observer, utility::Dispatcher &dispatcher) in ObexPrivateServer()
307 : observer_(observer), dispatcher_(dispatcher) in ObexPrivateServer()
318 serverTransport_ = std::make_unique<ObexServerSocketTransport>(option, *transportObserver_, dispatcher); in ObexPrivateServer()
25 ObexServer(const std::string &serviceName, const ObexServerConfig &config, ObexServerObserver &observer, utility::Dispatcher &dispatcher) ObexServer() argument
305 ObexPrivateServer( const ObexPrivateServerConfig &config, ObexServerObserver &observer, utility::Dispatcher &dispatcher) ObexPrivateServer() argument
/foundation/CastEngine/castengine_wifi_display/services/mediachannel/
H A Dbuffer_dispatcher.cpp70 SHARING_LOGE("BufferReceiver read failed null dispatcher."); in RequestRead()
291 void DataNotifier::SetListenDispatcher(IBufferReader::Ptr dispatcher) in SetListenDispatcher() argument
294 dispatcher_ = dispatcher; in SetListenDispatcher()
322 auto dispatcher = dispatcher_.lock(); in DataAvailable() local
323 if (dispatcher == nullptr) { in DataAvailable()
324 SHARING_LOGE("target dispatcher NOT exist."); in DataAvailable()
330 (audioIndex < dispatcher->GetLatestAudioIndex() || !dispatcher->IsRead(GetReceiverId(), audioIndex + 1)); in DataAvailable()
333 (videoIndex < dispatcher->GetLatestVideoIndex() || !dispatcher in DataAvailable()
[all...]

Completed in 11 milliseconds

1234