Home
last modified time | relevance | path

Searched refs:eventMsg (Results 1 - 25 of 57) sorted by relevance

123

/foundation/CastEngine/castengine_wifi_display/services/event/
H A Devent_base.cpp100 void EventChecker::CheckEvent(EventMsg::Ptr eventMsg) in CheckEvent() argument
102 RETURN_IF_NULL(eventMsg); in CheckEvent()
105 if (EVENT_CONTEXT_BASE < eventMsg->type && eventMsg->type < EVENT_MEDIA_BASE) { in CheckEvent()
106 if (eventMsg->toMgr != MODULE_CONTEXT) { in CheckEvent()
107 SHARING_LOGE("set to context type: %{public}d to: %{public}d.", eventMsg->type, eventMsg->toMgr); in CheckEvent()
108 eventMsg->toMgr = MODULE_CONTEXT; in CheckEvent()
110 } else if (EVENT_MEDIA_BASE < eventMsg->type && eventMsg in CheckEvent()
[all...]
H A Devent_manager.cpp105 RETURN_INVALID_IF_NULL(event.eventMsg); in PushEvent()
106 SHARING_LOGI("push a async event, type: %{public}u %{public}s.", event.eventMsg->type, in PushEvent()
107 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in PushEvent()
117 RETURN_INVALID_IF_NULL(event.eventMsg); in PushSyncEvent()
118 SHARING_LOGI("push a sync event, type: %{public}u %{public}s.", event.eventMsg->type, in PushSyncEvent()
119 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in PushSyncEvent()
123 SHARING_LOGD("find Listener type %{public}d %{public}s.", event.eventMsg->type, in PushSyncEvent()
124 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in PushSyncEvent()
131 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in PushSyncEvent()
135 std::string(magic_enum::enum_name(event.eventMsg in PushSyncEvent()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/mediachannel/
H A Dchannel_manager.cpp42 auto eventMsg = ConvertEventMsg<ChannelEventMsg>(event); in HandleMediaChannelCreate() local
43 if (eventMsg == nullptr) { in HandleMediaChannelCreate()
48 channel->SetContextId(eventMsg->srcId); in HandleMediaChannelCreate()
49 eventMsg->srcId = channel->GetId(); in HandleMediaChannelCreate()
61 auto eventMsg = ConvertEventMsg<ChannelEventMsg>(event); in HandleMediaChannelDestroy() local
62 if (eventMsg == nullptr) { in HandleMediaChannelDestroy()
68 auto channel = mediaChannels_.find(eventMsg->dstId); in HandleMediaChannelDestroy()
78 contextMsg->srcId = eventMsg->dstId; in HandleMediaChannelDestroy()
79 contextMsg->dstId = eventMsg->srcId; in HandleMediaChannelDestroy()
80 contextMsg->agentId = eventMsg in HandleMediaChannelDestroy()
[all...]
H A Dmedia_channel.cpp74 statusMsg->eventMsg = msg; in OnWriteTimeout()
95 RETURN_IF_NULL(msg->eventMsg); in OnProducerNotify()
130 agentEvent.eventMsg = msg->eventMsg; in OnProducerNotify()
143 RETURN_IF_NULL(msg->eventMsg); in OnConsumerNotify()
173 agentEvent.eventMsg = msg->eventMsg; in OnConsumerNotify()
186 RETURN_IF_NULL(msg->eventMsg); in OnMediaControllerNotify()
248 RETURN_INVALID_IF_NULL(event.eventMsg); in HandleEvent()
251 event.eventMsg in HandleEvent()
[all...]
H A Dbase_consumer.cpp93 void BaseConsumer::NotifyPrivateEvent(EventMsg::Ptr eventMsg) in NotifyPrivateEvent() argument
96 RETURN_IF_NULL(eventMsg); in NotifyPrivateEvent()
101 pMsg->eventMsg = std::move(eventMsg); in NotifyPrivateEvent()
H A Dbase_producer.cpp69 void BaseProducer::NotifyPrivateEvent(EventMsg::Ptr eventMsg) in NotifyPrivateEvent() argument
72 RETURN_IF_NULL(eventMsg); in NotifyPrivateEvent()
77 pMsg->eventMsg = std::move(eventMsg); in NotifyPrivateEvent()
/foundation/CastEngine/castengine_wifi_display/services/context/
H A Dcontext.cpp50 RETURN_INVALID_IF_NULL(event.eventMsg); in HandleEvent()
54 GetId(), event.eventMsg->fromMgr, event.eventMsg->srcId, event.eventMsg->toMgr, event.eventMsg->dstId, in HandleEvent()
55 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in HandleEvent()
61 switch (event.eventMsg->type) { in HandleEvent()
63 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); in HandleEvent() local
64 if (eventMsg) { in HandleEvent()
65 interactionId_ = eventMsg in HandleEvent()
88 auto eventMsg = ConvertEventMsg<AgentEventMsg>(event); HandleAgentDestroy() local
127 auto eventMsg = ConvertEventMsg<AgentEventMsg>(event); DistributeEvent() local
181 SendInteractionEvent(EventType eventType, ContextEventMsg::Ptr &eventMsg) SendInteractionEvent() argument
330 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HandleStateDestroyAgent() local
[all...]
H A Dcontext_manager.cpp80 RETURN_INVALID_IF_NULL(event.eventMsg); in HandleEvent()
82 event.eventMsg->fromMgr, event.eventMsg->srcId, event.eventMsg->toMgr, event.eventMsg->dstId, in HandleEvent()
83 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in HandleEvent()
84 switch (event.eventMsg->type) { in HandleEvent()
89 event.eventMsg->dstId = HandleContextCreate(); in HandleEvent()
108 auto eventMsg = ConvertEventMsg<ConfigEventMsg>(event); in HandleConfiguration() local
109 if (eventMsg in HandleConfiguration()
[all...]
/foundation/CastEngine/castengine_wifi_display/tests/unittest/scheduler/
H A Dscheduler_unit_test.cpp39 event.eventMsg = std::make_shared<ContextEventMsg>(); in HWTEST_F()
41 event.eventMsg->toMgr = MODULE_CONTEXT; in HWTEST_F()
42 event.eventMsg->type = EVENT_CONTEXT_AGENT_CREATE; in HWTEST_F()
56 event.eventMsg = std::make_shared<ContextEventMsg>(); in HWTEST_F()
58 event.eventMsg->toMgr = MODULE_CONTEXT; in HWTEST_F()
60 event.eventMsg->type = EVENT_CONTEXTMGR_CREATE; in HWTEST_F()
73 event.eventMsg = std::make_shared<ContextEventMsg>(); in HWTEST_F()
75 event.eventMsg->toMgr = MODULE_CONTEXT; in HWTEST_F()
76 event.eventMsg->type = EVENT_CONTEXTMGR_AGENT_CREATE; in HWTEST_F()
90 event.eventMsg in HWTEST_F()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/impl/screen_capture/
H A Dscreen_capture_session.cpp39 RETURN_INVALID_IF_NULL(event.eventMsg); in HandleEvent()
42 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str(), GetId()); in HandleEvent()
43 switch (event.eventMsg->type) { in HandleEvent()
67 auto eventMsg = std::make_shared<ScreenCaptureConsumerEventMsg>(); in HandleRtspPlay() local
68 eventMsg->type = EventType::EVENT_WFD_NOTIFY_RTSP_PLAYED; in HandleRtspPlay()
69 eventMsg->toMgr = ModuleType::MODULE_MEDIACHANNEL; in HandleRtspPlay()
70 eventMsg->screenId = screenId_; in HandleRtspPlay()
73 Common::SetVideoTrack(eventMsg->videoTrack, videoFormat_); in HandleRtspPlay()
74 Common::SetAudioTrack(eventMsg->audioTrack, inputMsg->codecId, inputMsg->audioFormat); in HandleRtspPlay()
77 Common::SetVideoTrack(eventMsg in HandleRtspPlay()
176 auto eventMsg = std::make_shared<ScreenCaptureConsumerEventMsg>(); NotifyProsumerInit() local
[all...]
/foundation/CastEngine/castengine_wifi_display/tests/unittest/mediachannel/channel/
H A Dmedia_channel_unit_test.cpp47 event.eventMsg = std::make_shared<ChannelEventMsg>(); in HWTEST_F()
49 event.eventMsg->type = EventType::EVENT_MEDIA_CHANNEL_CREATE; in HWTEST_F()
53 auto srcID = event.eventMsg->srcId; in HWTEST_F()
64 event.eventMsg = std::make_shared<ChannelEventMsg>(); in HWTEST_F()
66 event.eventMsg->type = EventType::EVENT_MEDIA_CHANNEL_CREATE; in HWTEST_F()
70 auto srcID = event.eventMsg->srcId; in HWTEST_F()
82 event.eventMsg = std::make_shared<ChannelEventMsg>(); in HWTEST_F()
84 event.eventMsg->type = EventType::EVENT_MEDIA_CHANNEL_CREATE; in HWTEST_F()
88 auto srcID = event.eventMsg->srcId; in HWTEST_F()
101 event.eventMsg in HWTEST_F()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/interaction/
H A Dinteraction_manager.cpp58 RETURN_INVALID_IF_NULL(event.eventMsg); in HandleEvent()
60 event.eventMsg->fromMgr, event.eventMsg->srcId, event.eventMsg->toMgr, event.eventMsg->dstId, in HandleEvent()
61 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in HandleEvent()
62 switch (event.eventMsg->type) { in HandleEvent()
66 auto eventMsg = std::static_pointer_cast<InteractionEventMsg>(event.eventMsg); in HandleEvent() local
67 if (eventMsg) { in HandleEvent()
75 auto eventMsg = std::static_pointer_cast<InteractionEventMsg>(event.eventMsg); HandleEvent() local
84 auto eventMsg = std::static_pointer_cast<InteractionEventMsg>(event.eventMsg); HandleEvent() local
[all...]
H A Dinteraction.cpp71 event.eventMsg = std::move(interactionMsg); in ReleaseScene()
72 event.eventMsg->fromMgr = ModuleType::MODULE_INTERACTION; in ReleaseScene()
73 event.eventMsg->dstId = GetId(); in ReleaseScene()
85 event.eventMsg = std::move(interactionMsg); in OnSceneNotifyDestroyed()
86 event.eventMsg->fromMgr = ModuleType::MODULE_INTERACTION; in OnSceneNotifyDestroyed()
87 event.eventMsg->dstId = GetId(); in OnSceneNotifyDestroyed()
102 RETURN_INVALID_IF_NULL(event.eventMsg); in HandleEvent()
104 event.eventMsg->fromMgr, event.eventMsg->srcId, event.eventMsg in HandleEvent()
146 NotifyEvent(EventMsg::Ptr eventMsg) NotifyEvent() argument
[all...]
/foundation/CastEngine/castengine_wifi_display/services/scheduler/
H A Dscheduler.cpp37 RETURN_INVALID_IF_NULL(event.eventMsg); in HandleEvent()
39 switch (event.eventMsg->toMgr) { in HandleEvent()
42 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in HandleEvent()
45 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in HandleEvent()
49 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in HandleEvent()
52 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in HandleEvent()
56 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in HandleEvent()
59 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in HandleEvent()
/foundation/CastEngine/castengine_wifi_display/tests/unittest/context/
H A Dcontext_unit_test.cpp81 event.eventMsg = contextEventMsgSptr; in HWTEST_F()
83 event.eventMsg->type = EVENT_CONTEXT_AGENT_CREATE; in HWTEST_F()
105 event.eventMsg = contextEventMsgSptr; in HWTEST_F()
107 event.eventMsg->type = EVENT_CONTEXT_STATE_AGENT_DESTROY; in HWTEST_F()
129 event.eventMsg = contextEventMsgSptr; in HWTEST_F()
131 event.eventMsg->type = EVENT_CONTEXT_STATE_AGENT_DESTROY; in HWTEST_F()
157 event.eventMsg = contextEventMsgSptr; in HWTEST_F()
159 event.eventMsg->type = EVENT_CONTEXT_AGENT_CREATE; in HWTEST_F()
188 event.eventMsg = contextEventMsgSptr; in HWTEST_F()
195 event.eventMsg in HWTEST_F()
301 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
319 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
337 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
355 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
373 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
391 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
409 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
427 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
445 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
463 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
481 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
499 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
518 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
615 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
633 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
652 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
672 auto eventMsg = ConvertEventMsg<ContextEventMsg>(event); HWTEST_F() local
[all...]
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/platform/ohos/
H A Drs_event_manager.cpp153 detectorPtr->AddEventReportCallback([this](const RSSysEventMsg& eventMsg) { in AddEvent()
154 this->EventReport(eventMsg); in AddEvent()
178 void RSEventManager::EventReport(const RSSysEventMsg& eventMsg) in EventReport() argument
181 if (eventStateList_.count(eventMsg.stringId) == 0) { in EventReport()
182 RS_LOGD("RSEventManager::EventReport %{public}s failed ", eventMsg.stringId.c_str()); in EventReport()
185 RSEventState& state = eventStateList_[eventMsg.stringId]; in EventReport()
189 if (eventMsg.pid != -1) { in EventReport()
192 eventMsg.stringId, in EventReport()
193 eventMsg.eventType, in EventReport()
194 "PID", eventMsg in EventReport()
[all...]
/foundation/CastEngine/castengine_wifi_display/tests/unittest/event/
H A Devent_unit_test.cpp52 event.eventMsg = contextEventMsgSptr; in HWTEST_F()
70 event.eventMsg = contextEventMsgSptr; in HWTEST_F()
88 event.eventMsg = contextEventMsgSptr; in HWTEST_F()
106 event.eventMsg = contextEventMsgSptr; in HWTEST_F()
124 event.eventMsg = contextEventMsgSptr; in HWTEST_F()
142 event.eventMsg = contextEventMsgSptr; in HWTEST_F()
176 event.eventMsg = std::make_shared<EventMsg>(); in HWTEST_F()
201 event.eventMsg = contextEventMsgSptr; in HWTEST_F()
223 event.eventMsg = contextEventMsgSptr; in HWTEST_F()
246 event.eventMsg in HWTEST_F()
348 EventMsg::Ptr eventMsg = std::make_shared<EventMsg>(); HWTEST_F() local
359 EventMsg::Ptr eventMsg = std::make_shared<EventMsg>(); HWTEST_F() local
370 EventMsg::Ptr eventMsg = std::make_shared<EventMsg>(); HWTEST_F() local
381 EventMsg::Ptr eventMsg = std::make_shared<EventMsg>(); HWTEST_F() local
392 EventMsg::Ptr eventMsg = std::make_shared<EventMsg>(); HWTEST_F() local
403 EventMsg::Ptr eventMsg = std::make_shared<EventMsg>(); HWTEST_F() local
[all...]
/foundation/ability/form_fwk/services/src/
H A Dform_serial_queue.cpp55 void FormSerialQueue::ScheduleDelayTask(const std::pair<int64_t, int64_t> &eventMsg, in ScheduleDelayTask() argument
65 taskMap_[eventMsg] = std::move(task_handle); in ScheduleDelayTask()
69 void FormSerialQueue::CancelDelayTask(const std::pair<int64_t, int64_t> &eventMsg) in CancelDelayTask() argument
73 auto item = taskMap_.find(eventMsg); in CancelDelayTask()
84 taskMap_.erase(eventMsg); in CancelDelayTask()
/foundation/CastEngine/castengine_wifi_display/tests/unittest/agent/
H A Dsrc_agent_unit_test.cpp95 auto eventMsg = std::make_shared<ContextEventMsg>(); in HWTEST_F() local
96 ASSERT_TRUE(eventMsg != nullptr); in HWTEST_F()
97 event.eventMsg = std::move(eventMsg); in HWTEST_F()
98 event.eventMsg->type = EVENT_AGENT_DESTROY; in HWTEST_F()
99 event.eventMsg->dstId = 0; in HWTEST_F()
109 event.eventMsg = std::make_shared<ContextEventMsg>(); in HWTEST_F()
110 ASSERT_TRUE(event.eventMsg != nullptr); in HWTEST_F()
111 event.eventMsg->type = EVENT_MEDIA_CHANNEL_DESTROY; in HWTEST_F()
112 event.eventMsg in HWTEST_F()
[all...]
H A Dsink_agent_unit_test.cpp95 event.eventMsg = std::make_shared<ContextEventMsg>(); in HWTEST_F()
96 ASSERT_TRUE(event.eventMsg != nullptr); in HWTEST_F()
97 event.eventMsg->type = EVENT_AGENT_DESTROY; in HWTEST_F()
98 event.eventMsg->dstId = 0; in HWTEST_F()
108 event.eventMsg = std::make_shared<ContextEventMsg>(); in HWTEST_F()
109 ASSERT_TRUE(event.eventMsg != nullptr); in HWTEST_F()
110 event.eventMsg->type = EVENT_MEDIA_CHANNEL_DESTROY; in HWTEST_F()
111 event.eventMsg->dstId = 0; in HWTEST_F()
121 event.eventMsg = std::make_shared<ContextEventMsg>(); in HWTEST_F()
122 ASSERT_TRUE(event.eventMsg ! in HWTEST_F()
[all...]
/foundation/CastEngine/castengine_wifi_display/tests/unittest/interaction/scene/
H A Dscene_unit_test.cpp108 event.eventMsg = std::make_shared<EventMsg>(); in HWTEST_F()
110 event.eventMsg->type = EVENT_CONFIGURE_INTERACT; in HWTEST_F()
124 event.eventMsg = std::make_shared<EventMsg>(); in HWTEST_F()
126 event.eventMsg->type = EVENT_INTERACTIONMGR_DESTROY_INTERACTION; in HWTEST_F()
140 event.eventMsg = std::make_shared<EventMsg>(); in HWTEST_F()
142 event.eventMsg->type = EVENT_INTERACTIONMGR_REMOVE_INTERACTION; in HWTEST_F()
156 event.eventMsg = std::make_shared<EventMsg>(); in HWTEST_F()
158 event.eventMsg->type = EVENT_INTERACTION_DECODER_DIED; in HWTEST_F()
333 event.eventMsg = std::make_shared<InteractionEventMsg>(); in HWTEST_F()
334 ASSERT_TRUE(event.eventMsg ! in HWTEST_F()
781 auto eventMsg = std::make_shared<EventMsg>(); HWTEST_F() local
[all...]
/foundation/multimedia/player_framework/services/engine/histreamer/player/
H A Ddfx_agent.cpp93 void DfxAgent::ReportLagEvent(int64_t lagDuration, const std::string& eventMsg) in ReportLagEvent() argument
96 dfxTask_->SubmitJobOnce([this, lagDuration, eventMsg] { in ReportLagEvent()
98 std::string msg = eventMsg; in ReportLagEvent()
104 lagDuration, eventMsg.c_str()); in ReportLagEvent()
/foundation/CastEngine/castengine_wifi_display/services/common/
H A Devent_comm.h239 EventMsg::Ptr eventMsg; member
247 if (event.eventMsg == nullptr) { in ConvertEventMsg()
251 auto eventMsg = std::static_pointer_cast<T>(event.eventMsg); in ConvertEventMsg() local
252 if (eventMsg == nullptr) { in ConvertEventMsg()
257 return eventMsg; in ConvertEventMsg()
/foundation/ability/form_fwk/services/include/
H A Dform_serial_queue.h32 void ScheduleDelayTask(const std::pair<int64_t, int64_t> &eventMsg, uint32_t ms, std::function<void()> func);
33 void CancelDelayTask(const std::pair<int64_t, int64_t> &eventMsg);
/foundation/CastEngine/castengine_wifi_display/services/agent/
H A Dagent.cpp51 RETURN_INVALID_IF_NULL(event.eventMsg); in HandleEvent()
54 event.eventMsg->dstId, GetId(), mediaChannelId_, event.eventMsg->fromMgr, event.eventMsg->srcId, in HandleEvent()
55 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str()); in HandleEvent()
57 if (EventType::EVENT_AGENT_PROSUMER_ERROR == event.eventMsg->type) { in HandleEvent()
73 statusMsg->msg->type = event.eventMsg->type; in HandleEvent()
74 statusMsg->msg->requestId = event.eventMsg->requestId; in HandleEvent()
75 statusMsg->msg->errorCode = event.eventMsg->errorCode; in HandleEvent()
92 switch (event.eventMsg in HandleEvent()
[all...]

Completed in 16 milliseconds

123