Lines Matching defs:statusMsg
69 auto statusMsg = std::make_shared<SessionStatusMsg>();
70 RETURN_INVALID_IF_NULL(statusMsg);
71 statusMsg->msg = std::make_shared<EventMsg>();
72 RETURN_INVALID_IF_NULL(statusMsg->msg);
73 statusMsg->msg->type = event.eventMsg->type;
74 statusMsg->msg->requestId = event.eventMsg->requestId;
75 statusMsg->msg->errorCode = event.eventMsg->errorCode;
80 statusMsg->status = SESSION_INTERRUPT;
81 session_->UpdateOperation(statusMsg);
94 statusMsg->status = SESSION_START;
95 UpdateSessionStatus(statusMsg);
98 statusMsg->status = SESSION_STOP;
99 UpdateSessionStatus(statusMsg);
102 statusMsg->status = SESSION_PAUSE;
103 statusMsg->mediaType = inputMsg->mediaType;
104 UpdateSessionStatus(statusMsg);
107 statusMsg->status = SESSION_RESUME;
108 statusMsg->mediaType = inputMsg->mediaType;
109 UpdateSessionStatus(statusMsg);
113 statusMsg->prosumerId = prosumerId_;
114 HandleProsumerState(statusMsg);
122 statusMsg->prosumerId = inputMsg->prosumerId;
123 HandleProsumerState(statusMsg);
126 statusMsg->prosumerId = inputMsg->prosumerId;
127 HandleProsumerError(statusMsg);
130 SendChannelEvent(statusMsg, EVENT_MEDIA_PLAY_START);
133 SendChannelEvent(statusMsg, EVENT_MEDIA_PLAY_STOP);
136 if (statusMsg->msg->errorCode == ERR_OK) {
137 PushNextStep(statusMsg);
144 if (statusMsg->msg->errorCode == ERR_OK) {
145 PushNextStep(statusMsg);
152 statusMsg->surface = inputMsg->surface;
153 statusMsg->sceneType = inputMsg->sceneType;
154 SendChannelAppendSurfaceEvent(statusMsg, EVENT_MEDIA_CHANNEL_APPENDSURFACE);
157 statusMsg->surfaceId = inputMsg->surfaceId;
158 SendChannelRemoveSurfaceEvent(statusMsg, EVENT_MEDIA_CHANNEL_REMOVESURFACE);
161 if (statusMsg->msg->errorCode == ERR_OK) {
162 PushNextStep(statusMsg);
169 PushNextStep(statusMsg);
170 statusMsg->surfaceId = inputMsg->surfaceId;
171 SendInteractionEvent(statusMsg, EVENT_INTERACTION_STATE_REMOVE_SURFACE);
174 statusMsg->surfaceId = inputMsg->surfaceId;
175 statusMsg->sceneType = inputMsg->sceneType;
176 SendChannelSceneTypeEvent(statusMsg, EVENT_MEDIA_CHANNEL_SETSCENETYPE);
179 statusMsg->volume = inputMsg->volume;
180 SendChannelSetVolumeEvent(statusMsg, EVENT_MEDIA_CHANNEL_SETVOLUME);
183 statusMsg->surfaceId = inputMsg->surfaceId;
184 statusMsg->keyRedirect = inputMsg->keyRedirect;
185 SendChannelKeyRedirectEvent(statusMsg, EVENT_MEDIA_CHANNEL_KEY_REDIRECT);
188 statusMsg->surfaceId = inputMsg->surfaceId;
189 SendInteractionEvent(statusMsg, EVENT_INTERACTION_ACCELERATION_DONE);
192 statusMsg->surfaceId = inputMsg->surfaceId;
193 SendInteractionEvent(statusMsg, EVENT_INTERACTION_DECODER_DIED);
205 void Agent::HandleProsumerError(SessionStatusMsg::Ptr &statusMsg)
208 RETURN_IF_NULL(statusMsg);
209 RETURN_IF_NULL(statusMsg->msg);
211 statusMsg->prosumerId, statusMsg->msg->errorCode);
212 SendInteractionEvent(statusMsg, EVENT_INTERACTION_MSG_ERROR);
213 switch (statusMsg->msg->errorCode) {
219 statusMsg->status = SESSION_STOP;
220 UpdateSessionStatus(statusMsg);
223 statusMsg->status = SESSION_DESTROY;
224 UpdateSessionStatus(statusMsg);
228 SendChannelEvent(statusMsg, EVENT_MEDIA_CHANNEL_DESTROY);
230 SendContextEvent(statusMsg, EVENT_CONTEXT_STATE_AGENT_DESTROY);
240 void Agent::HandleProsumerState(SessionStatusMsg::Ptr &statusMsg)
243 RETURN_IF_NULL(statusMsg);
244 RETURN_IF_NULL(statusMsg->msg);
246 statusMsg->prosumerId,
247 std::string(magic_enum::enum_name(static_cast<EventType>(statusMsg->msg->type))).c_str());
254 switch (statusMsg->msg->type) {
278 statusMsg->status = mediaStatus;
279 session_->UpdateMediaStatus(statusMsg);
280 PushNextStep(statusMsg);
283 void Agent::PushNextStep(SessionStatusMsg::Ptr &statusMsg)
286 RETURN_IF_NULL(statusMsg);
287 RETURN_IF_NULL(statusMsg->msg);
288 switch (statusMsg->msg->type) {
293 statusMsg->status = SESSION_DESTROY;
294 UpdateSessionStatus(statusMsg);
299 SendChannelEvent(statusMsg, EVENT_MEDIA_CHANNEL_DESTROY);
301 SendContextEvent(statusMsg, EVENT_CONTEXT_STATE_AGENT_DESTROY);
323 void Agent::OnSessionNotify(SessionStatusMsg::Ptr &statusMsg)
326 RETURN_IF_NULL(statusMsg);
328 std::string(magic_enum::enum_name(static_cast<SessionNotifyStatus>(statusMsg->status))).c_str());
329 statusMsg->prosumerId = prosumerId_;
330 switch (statusMsg->status) {
332 NotifyPrivateEvent(statusMsg);
335 HandleSessionError(statusMsg);
343 void Agent::HandleSessionError(SessionStatusMsg::Ptr &statusMsg)
346 RETURN_IF_NULL(statusMsg);
347 RETURN_IF_NULL(statusMsg->msg);
348 SHARING_LOGI("agentId: %{public}u, error: %{public}d.", GetId(), statusMsg->msg->errorCode);
349 SendInteractionEvent(statusMsg, EVENT_INTERACTION_MSG_ERROR);
350 switch (statusMsg->msg->errorCode) {
368 void Agent::UpdateSessionStatus(SessionStatusMsg::Ptr &statusMsg)
371 std::string(magic_enum::enum_name(static_cast<SessionRunningStatus>(statusMsg->status))).c_str(),
374 session_->UpdateOperation(statusMsg);
378 uint32_t Agent::NotifyPrivateEvent(SessionStatusMsg::Ptr &statusMsg)
381 RETURN_INVALID_IF_NULL(statusMsg);
382 RETURN_INVALID_IF_NULL(statusMsg->msg);
385 std::string(magic_enum::enum_name(statusMsg->msg->type)).c_str());
386 auto toMgr = statusMsg->msg->toMgr;
390 std::string(magic_enum::enum_name(statusMsg->msg->type)).c_str());
397 statusMsg->msg->dstId = mediaChannelId_;
398 auto channelMsg = std::static_pointer_cast<ChannelEventMsg>(statusMsg->msg);
401 channelMsg->errorCode = statusMsg->msg->errorCode;
402 channelMsg->requestId = statusMsg->msg->requestId;
409 auto agentMsg = std::static_pointer_cast<AgentStatusMsg>(statusMsg);
425 void Agent::SendInteractionEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType)
428 RETURN_IF_NULL(statusMsg);
429 RETURN_IF_NULL(statusMsg->msg);
433 std::string(magic_enum::enum_name(statusMsg->msg->type)).c_str());
440 interactionMsg->errorCode = statusMsg->msg->errorCode;
441 interactionMsg->requestId = statusMsg->msg->requestId;
442 interactionMsg->surfaceId = statusMsg->surfaceId;
452 void Agent::SendChannelEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType)
455 RETURN_IF_NULL(statusMsg);
456 RETURN_IF_NULL(statusMsg->msg);
460 std::string(magic_enum::enum_name(statusMsg->msg->type)).c_str());
469 channelMsg->errorCode = statusMsg->msg->errorCode;
470 channelMsg->requestId = statusMsg->msg->requestId;
480 void Agent::SendChannelAppendSurfaceEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType)
483 RETURN_IF_NULL(statusMsg);
484 RETURN_IF_NULL(statusMsg->msg);
488 std::string(magic_enum::enum_name(statusMsg->msg->type)).c_str());
497 channelMsg->surface = statusMsg->surface;
498 channelMsg->sceneType = statusMsg->sceneType;
499 channelMsg->errorCode = statusMsg->msg->errorCode;
500 channelMsg->requestId = statusMsg->msg->requestId;
510 void Agent::SendChannelRemoveSurfaceEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType)
513 RETURN_IF_NULL(statusMsg);
514 RETURN_IF_NULL(statusMsg->msg);
518 std::string(magic_enum::enum_name(statusMsg->msg->type)).c_str());
527 channelMsg->surfaceId = statusMsg->surfaceId;
528 channelMsg->errorCode = statusMsg->msg->errorCode;
529 channelMsg->requestId = statusMsg->msg->requestId;
539 void Agent::SendChannelSceneTypeEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType)
542 RETURN_IF_NULL(statusMsg);
543 RETURN_IF_NULL(statusMsg->msg);
547 std::string(magic_enum::enum_name(statusMsg->msg->type)).c_str());
556 channelMsg->surfaceId = statusMsg->surfaceId;
557 channelMsg->sceneType = statusMsg->sceneType;
558 channelMsg->errorCode = statusMsg->msg->errorCode;
559 channelMsg->requestId = statusMsg->msg->requestId;
569 void Agent::SendChannelKeyRedirectEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType)
572 RETURN_IF_NULL(statusMsg);
573 RETURN_IF_NULL(statusMsg->msg);
577 std::string(magic_enum::enum_name(statusMsg->msg->type)).c_str());
586 channelMsg->surfaceId = statusMsg->surfaceId;
587 channelMsg->keyRedirect = statusMsg->keyRedirect;
588 channelMsg->errorCode = statusMsg->msg->errorCode;
589 channelMsg->requestId = statusMsg->msg->requestId;
599 void Agent::SendChannelSetVolumeEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType)
602 RETURN_IF_NULL(statusMsg);
603 RETURN_IF_NULL(statusMsg->msg);
607 std::string(magic_enum::enum_name(statusMsg->msg->type)).c_str());
616 channelMsg->volume = statusMsg->volume;
617 channelMsg->errorCode = statusMsg->msg->errorCode;
618 channelMsg->requestId = statusMsg->msg->requestId;
628 void Agent::SendContextEvent(SessionStatusMsg::Ptr &statusMsg, EventType eventType)
631 RETURN_IF_NULL(statusMsg);
632 RETURN_IF_NULL(statusMsg->msg);
636 std::string(magic_enum::enum_name(statusMsg->msg->type)).c_str());
645 contextMsg->errorCode = statusMsg->msg->errorCode;
646 contextMsg->requestId = statusMsg->msg->requestId;