Home
last modified time | relevance | path

Searched refs:statusMsg (Results 1 - 25 of 48) sorted by relevance

12

/foundation/CastEngine/castengine_wifi_display/services/agent/
H A Dagent.cpp69 auto statusMsg = std::make_shared<SessionStatusMsg>(); in HandleEvent() local
70 RETURN_INVALID_IF_NULL(statusMsg); in HandleEvent()
71 statusMsg->msg = std::make_shared<EventMsg>(); in HandleEvent()
72 RETURN_INVALID_IF_NULL(statusMsg->msg); 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()
80 statusMsg->status = SESSION_INTERRUPT; in HandleEvent()
81 session_->UpdateOperation(statusMsg); in HandleEvent()
94 statusMsg in HandleEvent()
205 HandleProsumerError(SessionStatusMsg::Ptr &statusMsg) HandleProsumerError() argument
240 HandleProsumerState(SessionStatusMsg::Ptr &statusMsg) HandleProsumerState() argument
283 PushNextStep(SessionStatusMsg::Ptr &statusMsg) PushNextStep() argument
323 OnSessionNotify(SessionStatusMsg::Ptr &statusMsg) OnSessionNotify() argument
343 HandleSessionError(SessionStatusMsg::Ptr &statusMsg) HandleSessionError() argument
368 UpdateSessionStatus(SessionStatusMsg::Ptr &statusMsg) UpdateSessionStatus() argument
378 NotifyPrivateEvent(SessionStatusMsg::Ptr &statusMsg) NotifyPrivateEvent() argument
425 SendInteractionEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType) SendInteractionEvent() argument
452 SendChannelEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType) SendChannelEvent() argument
480 SendChannelAppendSurfaceEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType) SendChannelAppendSurfaceEvent() argument
510 SendChannelRemoveSurfaceEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType) SendChannelRemoveSurfaceEvent() argument
539 SendChannelSceneTypeEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType) SendChannelSceneTypeEvent() argument
569 SendChannelKeyRedirectEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType) SendChannelKeyRedirectEvent() argument
599 SendChannelSetVolumeEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType) SendChannelSetVolumeEvent() argument
628 SendContextEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType) SendContextEvent() argument
[all...]
H A Dagent.h33 virtual void OnAgentNotify(AgentStatusMsg::Ptr &statusMsg) = 0;
80 void PushNextStep(SessionStatusMsg::Ptr &statusMsg);
81 void HandleSessionError(SessionStatusMsg::Ptr &statusMsg);
82 void UpdateSessionStatus(SessionStatusMsg::Ptr &statusMsg);
84 void OnSessionNotify(SessionStatusMsg::Ptr &statusMsg) override;
92 uint32_t NotifyPrivateEvent(SessionStatusMsg::Ptr &statusMsg);
94 void HandleProsumerState(SessionStatusMsg::Ptr &statusMsg);
95 void HandleProsumerError(SessionStatusMsg::Ptr &statusMsg);
97 void SendContextEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType);
98 void SendChannelEvent(SessionStatusMsg::Ptr &statusMsg, EventTyp
[all...]
/foundation/CastEngine/castengine_wifi_display/services/mediachannel/
H A Dmedia_channel.cpp73 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); in OnWriteTimeout() local
74 statusMsg->eventMsg = msg; in OnWriteTimeout()
75 statusMsg->errorCode = ERR_INTAKE_TIMEOUT; in OnWriteTimeout()
76 statusMsg->agentId = GetSinkAgentId(); in OnWriteTimeout()
77 statusMsg->prosumerId = consumer_ ? consumer_->GetId() : INVALID_ID; in OnWriteTimeout()
79 SendAgentEvent(statusMsg, EVENT_AGENT_STATE_WRITE_WARNING); in OnWriteTimeout()
372 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); in HandleAppendSurface() local
373 statusMsg->eventMsg = channelMsg; in HandleAppendSurface()
376 statusMsg->errorCode = ERR_OK; in HandleAppendSurface()
377 statusMsg in HandleAppendSurface()
416 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandleRemoveSurface() local
494 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandleStartPlay() local
520 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandleStopPlay() local
545 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandleCreateConsumer() local
576 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandleDestroyConsumer() local
612 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandleStartConsumer() local
639 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandleStopConsumer() local
673 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandlePauseConsumer() local
696 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandleResumeConsumer() local
719 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandleCreateProducer() local
748 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandleDestroyProducer() local
795 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandleStartProducer() local
832 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandleStopProducer() local
866 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandlePauseProducer() local
896 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HandleResumeProducer() local
[all...]
H A Dbase_consumer.cpp80 void BaseConsumer::Notify(ProsumerStatusMsg::Ptr &statusMsg) in Notify() argument
83 RETURN_IF_NULL(statusMsg); in Notify()
84 statusMsg->prosumerId = GetId(); in Notify()
85 statusMsg->agentId = GetSinkAgentId(); in Notify()
89 listener->OnConsumerNotify(statusMsg); in Notify()
H A Dbase_producer.cpp56 void BaseProducer::Notify(ProsumerStatusMsg::Ptr &statusMsg) in Notify() argument
59 RETURN_IF_NULL(statusMsg); in Notify()
60 statusMsg->prosumerId = GetId(); in Notify()
61 statusMsg->agentId = GetSrcAgentId(); in Notify()
65 listener->OnProducerNotify(statusMsg); in Notify()
/foundation/CastEngine/castengine_wifi_display/services/impl/screen_capture/
H A Dscreen_capture_session.cpp66 auto statusMsg = std::make_shared<SessionStatusMsg>(); in HandleRtspPlay() local
88 statusMsg->msg = std::move(eventMsg); in HandleRtspPlay()
89 statusMsg->status = NOTIFY_SESSION_PRIVATE_EVENT; in HandleRtspPlay()
91 NotifyAgentSessionStatus(statusMsg); in HandleRtspPlay()
119 auto statusMsg = std::make_shared<SessionStatusMsg>(); in HandleProsumerInitState() local
120 statusMsg->msg = std::make_shared<EventMsg>(); in HandleProsumerInitState()
121 statusMsg->status = STATE_SESSION_ERROR; in HandleProsumerInitState()
122 statusMsg->msg->errorCode = ERR_SESSION_START; in HandleProsumerInitState()
125 statusMsg->msg->requestId = inputMsg->requestId; in HandleProsumerInitState()
128 statusMsg in HandleProsumerInitState()
141 UpdateOperation(SessionStatusMsg::Ptr &statusMsg) UpdateOperation() argument
173 NotifyProsumerInit(SessionStatusMsg::Ptr &statusMsg) NotifyProsumerInit() argument
203 UpdateMediaStatus(SessionStatusMsg::Ptr &statusMsg) UpdateMediaStatus() argument
227 NotifyAgentSessionStatus(SessionStatusMsg::Ptr &statusMsg) NotifyAgentSessionStatus() argument
[all...]
H A Dscreen_capture_session.h30 void UpdateOperation(SessionStatusMsg::Ptr &statusMsg) override;
31 void UpdateMediaStatus(SessionStatusMsg::Ptr &statusMsg) override;
34 void NotifyProsumerInit(SessionStatusMsg::Ptr &statusMsg);
35 void NotifyAgentSessionStatus(SessionStatusMsg::Ptr &statusMsg);
H A Dscreen_capture_consumer.cpp214 void ScreenCaptureConsumer::UpdateOperation(ProsumerStatusMsg::Ptr &statusMsg) in UpdateOperation() argument
217 RETURN_IF_NULL(statusMsg); in UpdateOperation()
220 std::string(magic_enum::enum_name(static_cast<ProsumerOptRunningStatus>(statusMsg->status))).c_str(), in UpdateOperation()
222 switch (statusMsg->status) { in UpdateOperation()
224 statusMsg->status = PROSUMER_NOTIFY_INIT_SUCCESS; in UpdateOperation()
228 statusMsg->status = PROSUMER_NOTIFY_START_SUCCESS; in UpdateOperation()
233 statusMsg->status = PROSUMER_NOTIFY_PAUSE_SUCCESS; in UpdateOperation()
238 statusMsg->status = PROSUMER_NOTIFY_RESUME_SUCCESS; in UpdateOperation()
243 statusMsg->status = PROSUMER_NOTIFY_STOP_SUCCESS; in UpdateOperation()
245 statusMsg in UpdateOperation()
448 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); OnInitVideoCaptureError() local
[all...]
/foundation/CastEngine/castengine_wifi_display/services/agent/sinkagent/
H A Dsink_agent.cpp35 void SinkAgent::OnSessionNotify(SessionStatusMsg::Ptr &statusMsg) in OnSessionNotify() argument
38 RETURN_IF_NULL(statusMsg); in OnSessionNotify()
40 std::string(magic_enum::enum_name((SessionNotifyStatus)statusMsg->status)).c_str(), GetId()); in OnSessionNotify()
41 statusMsg->prosumerId = prosumerId_; in OnSessionNotify()
42 switch (statusMsg->status) { in OnSessionNotify()
44 NotifyConsumer(statusMsg, EventType::EVENT_MEDIA_CONSUMER_CREATE); in OnSessionNotify()
47 NotifyConsumer(statusMsg, EventType::EVENT_MEDIA_CONSUMER_START); in OnSessionNotify()
50 NotifyConsumer(statusMsg, EventType::EVENT_MEDIA_CONSUMER_STOP); in OnSessionNotify()
53 NotifyConsumer(statusMsg, EventType::EVENT_MEDIA_CONSUMER_PAUSE); in OnSessionNotify()
56 NotifyConsumer(statusMsg, EventTyp in OnSessionNotify()
70 NotifyConsumer(SessionStatusMsg::Ptr &statusMsg, EventType type) NotifyConsumer() argument
[all...]
/foundation/CastEngine/castengine_wifi_display/services/agent/srcagent/
H A Dsrc_agent.cpp34 void SrcAgent::OnSessionNotify(SessionStatusMsg::Ptr &statusMsg) in OnSessionNotify() argument
37 RETURN_IF_NULL(statusMsg); in OnSessionNotify()
39 std::string(magic_enum::enum_name((SessionNotifyStatus)statusMsg->status)).c_str(), GetId()); in OnSessionNotify()
40 statusMsg->prosumerId = prosumerId_; in OnSessionNotify()
41 switch (statusMsg->status) { in OnSessionNotify()
43 NotifyProducer(statusMsg, EventType::EVENT_MEDIA_PRODUCER_CREATE); in OnSessionNotify()
46 NotifyProducer(statusMsg, EventType::EVENT_MEDIA_PRODUCER_START); in OnSessionNotify()
49 NotifyProducer(statusMsg, EventType::EVENT_MEDIA_PRODUCER_STOP); in OnSessionNotify()
52 NotifyProducer(statusMsg, EventType::EVENT_MEDIA_PRODUCER_PAUSE); in OnSessionNotify()
55 NotifyProducer(statusMsg, EventTyp in OnSessionNotify()
69 NotifyProducer(SessionStatusMsg::Ptr &statusMsg, EventType type) NotifyProducer() argument
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/
H A Djs_util.cpp165 JSUtil::StatusMsg statusMsg = napi_get_array_length(env, in, &length); in GetValue() local
166 ASSERT(statusMsg.status == napi_ok, "get_array length failed!", napi_invalid_arg); in GetValue()
172 statusMsg.status = napi_get_element(env, in, i, &item); in GetValue()
173 ASSERT((item != nullptr) && (statusMsg.status == napi_ok), "no element", napi_invalid_arg); in GetValue()
175 statusMsg = GetValue(env, item, value); in GetValue()
176 ASSERT(statusMsg.status == napi_ok, "not a string", napi_invalid_arg); in GetValue()
179 return statusMsg; in GetValue()
279 JSUtil::StatusMsg statusMsg = napi_typeof(env, in, &type); in GetValue() local
280 ASSERT((statusMsg.status == napi_ok), "invalid type", statusMsg); in GetValue()
349 JSUtil::StatusMsg statusMsg = napi_typeof(env, in, &type); GetValue() local
410 JSUtil::StatusMsg statusMsg = napi_get_typedarray_info(env, in, &type, &length, &data, &buffer, &offset); GetValue() local
425 JSUtil::StatusMsg statusMsg = napi_create_arraybuffer(env, in.size(), &data, &buffer); SetValue() local
699 JSUtil::StatusMsg statusMsg = napi_get_named_property(env, in, "key", &propKey); GetValue() local
738 JSUtil::StatusMsg statusMsg = napi_create_object(env, &out); SetValue() local
777 JSUtil::StatusMsg statusMsg = napi_get_array_length(env, in, &length); GetValue() local
837 JSUtil::StatusMsg statusMsg = napi_get_array_length(env, keys, &arrLen); GetValue() local
864 JSUtil::StatusMsg statusMsg = napi_get_array_length(env, in, &length); GetValue() local
928 JSUtil::StatusMsg statusMsg = napi_get_array_length(env, in, &length); GetValue() local
948 JSUtil::StatusMsg statusMsg = napi_create_array_with_length(env, in.size(), &out); SetValue() local
974 JSUtil::StatusMsg statusMsg = napi_create_object(env, &out); SetValue() local
1007 JSUtil::StatusMsg statusMsg = napi_invalid_arg; GetValue() local
1199 JSUtil::StatusMsg statusMsg = napi_typeof(env, in, &type); GetValue() local
1265 JSUtil::StatusMsg statusMsg = GetNamedProperty(env, in, "stageMode", isStageMode); GetValue() local
[all...]
H A Djs_device_kv_store.cpp138 JSUtil::StatusMsg statusMsg = napi_typeof(env, argv[pos], &type); in GetVariantArgs() local
139 if (statusMsg != napi_ok || (type != napi_string && type != napi_object)) { in GetVariantArgs()
141 return statusMsg != napi_ok ? statusMsg.status : napi_invalid_arg; in GetVariantArgs()
145 statusMsg = JSUtil::GetValue(env, argv[pos], keyPrefix); in GetVariantArgs()
153 statusMsg = napi_instanceof(env, argv[pos], JsQuery::Constructor(env), &result); in GetVariantArgs()
154 if ((statusMsg.status == napi_ok) && (result != false)) { in GetVariantArgs()
156 statusMsg = JSUtil::Unwrap(env, argv[pos], reinterpret_cast<void **>(&jsQuery), JsQuery::Constructor(env)); in GetVariantArgs()
163 statusMsg = JSUtil::GetValue(env, argv[pos], va.dataQuery); in GetVariantArgs()
164 ZLOGD("kvStoreDataShare->GetResultSet return %{public}d", statusMsg in GetVariantArgs()
[all...]
/foundation/CastEngine/castengine_wifi_display/tests/unittest/impl/rtp/
H A Dwfd_rtp_consumer_test.cpp119 ProsumerStatusMsg::Ptr statusMsg = std::make_shared<ProsumerStatusMsg>(); in HWTEST_F() local
120 statusMsg->status = PROSUMER_INIT; in HWTEST_F()
121 consumer_->UpdateOperation(statusMsg); in HWTEST_F()
131 ProsumerStatusMsg::Ptr statusMsg = std::make_shared<ProsumerStatusMsg>(); in HWTEST_F() local
132 statusMsg->status = PROSUMER_START; in HWTEST_F()
133 consumer_->UpdateOperation(statusMsg); in HWTEST_F()
143 ProsumerStatusMsg::Ptr statusMsg = std::make_shared<ProsumerStatusMsg>(); in HWTEST_F() local
144 statusMsg->status = PROSUMER_PAUSE; in HWTEST_F()
145 consumer_->UpdateOperation(statusMsg); in HWTEST_F()
155 ProsumerStatusMsg::Ptr statusMsg in HWTEST_F() local
170 ProsumerStatusMsg::Ptr statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
185 ProsumerStatusMsg::Ptr statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
199 ProsumerStatusMsg::Ptr statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
217 ProsumerStatusMsg::Ptr statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
235 ProsumerStatusMsg::Ptr statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
253 ProsumerStatusMsg::Ptr statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
[all...]
H A Dwfd_rtp_producer_test.cpp135 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); in HWTEST_F() local
136 statusMsg->status = PROSUMER_INIT; in HWTEST_F()
137 producer_->UpdateOperation(statusMsg); in HWTEST_F()
147 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); in HWTEST_F() local
148 statusMsg->status = PROSUMER_START; in HWTEST_F()
150 producer_->UpdateOperation(statusMsg); in HWTEST_F()
160 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); in HWTEST_F() local
161 statusMsg->status = PROSUMER_PAUSE; in HWTEST_F()
162 producer_->UpdateOperation(statusMsg); in HWTEST_F()
172 auto statusMsg in HWTEST_F() local
184 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
196 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
[all...]
/foundation/CastEngine/castengine_wifi_display/services/impl/wfd/wfd_source/
H A Dwfd_source_session.cpp86 auto statusMsg = std::make_shared<SessionStatusMsg>(); in OnSessionClose() local
87 statusMsg->msg = std::make_shared<EventMsg>(); in OnSessionClose()
88 statusMsg->status = STATE_SESSION_ERROR; in OnSessionClose()
89 statusMsg->msg->errorCode = ERR_NETWORK_ERROR; in OnSessionClose()
90 server->NotifyAgentSessionStatus(statusMsg); in OnSessionClose()
99 auto statusMsg = std::make_shared<SessionStatusMsg>(); in OnSessionException() local
100 statusMsg->msg = std::make_shared<EventMsg>(); in OnSessionException()
101 statusMsg->status = STATE_SESSION_ERROR; in OnSessionException()
102 statusMsg->msg->errorCode = ERR_NETWORK_ERROR; in OnSessionException()
103 server->NotifyAgentSessionStatus(statusMsg); in OnSessionException()
137 auto statusMsg = std::make_shared<SessionStatusMsg>(); NotifyServiceError() local
146 UpdateOperation(SessionStatusMsg::Ptr &statusMsg) UpdateOperation() argument
185 UpdateMediaStatus(SessionStatusMsg::Ptr &statusMsg) UpdateMediaStatus() argument
211 NotifyProsumerInit(SessionStatusMsg::Ptr &statusMsg) NotifyProsumerInit() argument
258 NotifyAgentSessionStatus(SessionStatusMsg::Ptr &statusMsg) NotifyAgentSessionStatus() argument
321 auto statusMsg = std::make_shared<SessionStatusMsg>(); HandleProsumerInitState() local
480 auto statusMsg = std::make_shared<SessionStatusMsg>(); HandlePlayRequest() local
510 auto statusMsg = std::make_shared<SessionStatusMsg>(); HandlePauseRequest() local
523 auto statusMsg = std::make_shared<SessionStatusMsg>(); HandleTeardownRequest() local
653 SessionStatusMsg::Ptr statusMsg = std::make_shared<SessionStatusMsg>(); HandleM4Response() local
718 auto statusMsg = std::make_shared<SessionStatusMsg>(); HandleM8Response() local
[all...]
H A Dwfd_rtp_producer.cpp118 void WfdRtpProducer::UpdateOperation(ProsumerStatusMsg::Ptr &statusMsg) in UpdateOperation() argument
121 RETURN_IF_NULL(statusMsg); in UpdateOperation()
123 std::string(magic_enum::enum_name(static_cast<ProsumerOptRunningStatus>(statusMsg->status))).c_str(), in UpdateOperation()
125 switch (statusMsg->status) { in UpdateOperation()
127 statusMsg->status = PROSUMER_NOTIFY_INIT_SUCCESS; in UpdateOperation()
132 statusMsg->status = PROSUMER_NOTIFY_START_SUCCESS; in UpdateOperation()
134 statusMsg->status = PROSUMER_NOTIFY_ERROR; in UpdateOperation()
135 statusMsg->errorCode = ERR_PROSUMER_START; in UpdateOperation()
141 statusMsg->status = PROSUMER_NOTIFY_PAUSE_SUCCESS; in UpdateOperation()
147 statusMsg in UpdateOperation()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/impl/wfd/wfd_sink/
H A Dwfd_sink_session.cpp122 auto statusMsg = std::make_shared<SessionStatusMsg>(); in HandleProsumerInitState() local
123 statusMsg->msg = std::make_shared<EventMsg>(); in HandleProsumerInitState()
124 statusMsg->status = STATE_SESSION_ERROR; in HandleProsumerInitState()
125 statusMsg->msg->errorCode = ERR_SESSION_START; in HandleProsumerInitState()
128 statusMsg->msg->requestId = inputMsg->requestId; in HandleProsumerInitState()
130 statusMsg->status = STATE_SESSION_STARTED; in HandleProsumerInitState()
131 statusMsg->msg->errorCode = ERR_OK; in HandleProsumerInitState()
139 NotifyAgentSessionStatus(statusMsg); in HandleProsumerInitState()
142 void WfdSinkSession::UpdateOperation(SessionStatusMsg::Ptr &statusMsg) in UpdateOperation() argument
145 RETURN_IF_NULL(statusMsg); in UpdateOperation()
206 UpdateMediaStatus(SessionStatusMsg::Ptr &statusMsg) UpdateMediaStatus() argument
243 NotifyProsumerInit(SessionStatusMsg::Ptr &statusMsg) NotifyProsumerInit() argument
263 NotifyAgentSessionStatus(SessionStatusMsg::Ptr &statusMsg) NotifyAgentSessionStatus() argument
500 SessionStatusMsg::Ptr statusMsg = std::make_shared<SessionStatusMsg>(); HandleSetParamRequest() local
597 auto statusMsg = std::make_shared<SessionStatusMsg>(); HandleM8Response() local
932 auto statusMsg = std::make_shared<SessionStatusMsg>(); NotifyServiceError() local
944 auto statusMsg = std::make_shared<SessionStatusMsg>(); NotifySessionInterrupted() local
[all...]
H A Dwfd_rtp_consumer.cpp92 void WfdRtpConsumer::UpdateOperation(ProsumerStatusMsg::Ptr &statusMsg) in UpdateOperation() argument
95 RETURN_IF_NULL(statusMsg); in UpdateOperation()
98 std::string(magic_enum::enum_name(static_cast<ProsumerOptRunningStatus>(statusMsg->status))).c_str(), in UpdateOperation()
100 switch (statusMsg->status) { in UpdateOperation()
103 statusMsg->status = PROSUMER_NOTIFY_INIT_SUCCESS; in UpdateOperation()
105 statusMsg->status = PROSUMER_NOTIFY_INIT_SUCCESS; in UpdateOperation()
106 statusMsg->errorCode = ERR_PROSUMER_CREATE; in UpdateOperation()
111 statusMsg->status = PROSUMER_NOTIFY_START_SUCCESS; in UpdateOperation()
113 statusMsg->status = PROSUMER_NOTIFY_ERROR; in UpdateOperation()
114 statusMsg in UpdateOperation()
[all...]
/foundation/CastEngine/castengine_wifi_display/services/mediaplayer/src/
H A Dvideo_play_controller.cpp300 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); in OnError() local
301 statusMsg->eventMsg = msg; in OnError()
302 statusMsg->errorCode = ERR_OK; in OnError()
304 statusMsg->surfaceId = surface_->GetUniqueId(); in OnError()
310 statusMsg->status = CONNTROLLER_NOTIFY_DECODER_DIED; in OnError()
311 statusMsg->errorCode = ERR_SURFACE_FAILURE; in OnError()
317 mediaController->OnPlayControllerNotify(statusMsg); in OnError()
390 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); in OnAccelerationDoneNotify() local
391 statusMsg->eventMsg = msg; in OnAccelerationDoneNotify()
392 statusMsg in OnAccelerationDoneNotify()
409 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); OnKeyModeNotify() local
[all...]
/foundation/CastEngine/castengine_wifi_display/tests/unittest/mediachannel/channel/
H A Dmedia_channel_unit_test.cpp229 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); in HWTEST_F() local
230 statusMsg->errorCode = ERR_PROSUMER_VIDEO_CAPTURE; in HWTEST_F()
231 mediaChannel->SendAgentEvent(statusMsg, EVENT_MEDIA_CONSUMER_CREATE); in HWTEST_F()
1102 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); in HWTEST_F() local
1103 EXPECT_NE(statusMsg, nullptr); in HWTEST_F()
1104 statusMsg->eventMsg = std::make_shared<ChannelEventMsg>(); in HWTEST_F()
1105 EXPECT_NE(statusMsg->eventMsg, nullptr); in HWTEST_F()
1106 statusMsg->errorCode = ERR_PROSUMER_VIDEO_CAPTURE; in HWTEST_F()
1107 statusMsg->status = CONNTROLLER_NOTIFY_ACCELERATION; in HWTEST_F()
1108 mediaChannel->OnMediaControllerNotify(statusMsg); in HWTEST_F()
1115 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1128 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1141 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1154 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1167 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1178 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1191 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1204 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1217 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1230 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1243 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1256 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1269 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1282 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1295 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1306 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1319 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1335 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1348 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1361 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1374 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1387 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1400 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1413 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1426 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
1437 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
[all...]
/foundation/CastEngine/castengine_wifi_display/tests/unittest/impl/session/
H A Dwfd_sink_session_test.cpp212 auto statusMsg = std::make_shared<SessionStatusMsg>(); in HWTEST_F() local
214 statusMsg->msg = msg; in HWTEST_F()
215 statusMsg->status = SESSION_INTERRUPT; in HWTEST_F()
217 session_->UpdateOperation(statusMsg); in HWTEST_F()
227 auto statusMsg = std::make_shared<SessionStatusMsg>(); in HWTEST_F() local
229 statusMsg->msg = msg; in HWTEST_F()
230 statusMsg->status = SESSION_PAUSE; in HWTEST_F()
233 session_->UpdateOperation(statusMsg); in HWTEST_F()
243 auto statusMsg = std::make_shared<SessionStatusMsg>(); in HWTEST_F() local
245 statusMsg in HWTEST_F()
256 auto statusMsg = std::make_shared<SessionStatusMsg>(); HWTEST_F() local
274 auto statusMsg = std::make_shared<SessionStatusMsg>(); HWTEST_F() local
293 auto statusMsg = std::make_shared<SessionStatusMsg>(); HWTEST_F() local
309 auto statusMsg = std::make_shared<SessionStatusMsg>(); HWTEST_F() local
324 auto statusMsg = std::make_shared<SessionStatusMsg>(); HWTEST_F() local
338 auto statusMsg = std::make_shared<SessionStatusMsg>(); HWTEST_F() local
352 auto statusMsg = std::make_shared<SessionStatusMsg>(); HWTEST_F() local
366 auto statusMsg = std::make_shared<SessionStatusMsg>(); HWTEST_F() local
383 auto statusMsg = std::make_shared<SessionStatusMsg>(); HWTEST_F() local
[all...]
/foundation/CastEngine/castengine_wifi_display/tests/unittest/impl/screen_capture/
H A Dwfd_screen_capture_test.cpp170 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); in HWTEST_F() local
171 statusMsg->status = ProsumerOptRunningStatus::PROSUMER_INIT; in HWTEST_F()
172 consumer_->UpdateOperation(statusMsg); in HWTEST_F()
182 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); in HWTEST_F() local
183 statusMsg->status = ProsumerOptRunningStatus::PROSUMER_START; in HWTEST_F()
184 consumer_->UpdateOperation(statusMsg); in HWTEST_F()
194 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); in HWTEST_F() local
195 statusMsg->status = ProsumerOptRunningStatus::PROSUMER_PAUSE; in HWTEST_F()
196 consumer_->UpdateOperation(statusMsg); in HWTEST_F()
206 auto statusMsg in HWTEST_F() local
218 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
229 auto statusMsg = std::make_shared<ProsumerStatusMsg>(); HWTEST_F() local
[all...]
/foundation/CastEngine/castengine_wifi_display/services/agent/session/
H A Dbase_session.h53 virtual void UpdateOperation(SessionStatusMsg::Ptr &statusMsg) = 0;
54 virtual void UpdateMediaStatus(SessionStatusMsg::Ptr &statusMsg) = 0;
57 void Notify(SessionStatusMsg::Ptr &statusMsg) in Notify() argument
62 listener->OnSessionNotify(statusMsg); in Notify()
/foundation/CastEngine/castengine_wifi_display/tests/unittest/mediachannel/dispatcher/
H A Dmedia_dispatcher_unit_test.h38 void UpdateOperation(ProsumerStatusMsg::Ptr &statusMsg) in UpdateOperation() argument
40 (void)statusMsg; in UpdateOperation()
58 void UpdateOperation(ProsumerStatusMsg::Ptr &statusMsg) in UpdateOperation() argument
60 (void)statusMsg; in UpdateOperation()
/foundation/CastEngine/castengine_wifi_display/services/context/
H A Dcontext.cpp210 void Context::OnAgentNotify(AgentStatusMsg::Ptr &statusMsg) in OnAgentNotify() argument
213 RETURN_IF_NULL(statusMsg); in OnAgentNotify()
214 RETURN_IF_NULL(statusMsg->msg); in OnAgentNotify()
216 GetId(), statusMsg->agentId, statusMsg->msg->toMgr, statusMsg->msg->dstId, in OnAgentNotify()
217 std::string(magic_enum::enum_name(statusMsg->msg->type)).c_str()); in OnAgentNotify()
219 if (statusMsg->msg) { in OnAgentNotify()
220 if (statusMsg->msg->toMgr == ModuleType::MODULE_INTERACTION) { in OnAgentNotify()
221 statusMsg in OnAgentNotify()
[all...]

Completed in 17 milliseconds

12