Lines Matching defs:event

48 int32_t Agent::HandleEvent(SharingEvent &event)
51 RETURN_INVALID_IF_NULL(event.eventMsg);
53 "fromMgr: %{public}u, srcId: %{public}u channel event: %{public}s.",
54 event.eventMsg->dstId, GetId(), mediaChannelId_, event.eventMsg->fromMgr, event.eventMsg->srcId,
55 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str());
57 if (EventType::EVENT_AGENT_PROSUMER_ERROR == event.eventMsg->type) {
63 SharingErrorCode retCode = CheckRunStep(event, isCached);
73 statusMsg->msg->type = event.eventMsg->type;
74 statusMsg->msg->requestId = event.eventMsg->requestId;
75 statusMsg->msg->errorCode = event.eventMsg->errorCode;
86 auto inputMsg = ConvertEventMsg<AgentEventMsg>(event);
92 switch (event.eventMsg->type) {
197 session_->HandleEvent(event);
384 SHARING_LOGI("agentId: %{public}u, send session event, type: %{public}s.", GetId(),
395 SHARING_LOGI("agentId: %{public}u, send session event to mediachannel mediaChannelId: %{public}u.", GetId(),
404 SHARING_LOGI("agentId: %{public}u, send session event to interaction.", GetId());
717 SharingErrorCode Agent::CheckRunStep(SharingEvent &event, bool &isCached)
723 AgentRunStep step = GetRunStep(event.eventMsg->type);
729 AgentRunStepKey nextKey = {event.eventMsg->requestId, step, weight};
738 runEvents_.emplace(nextKey, event);
740 SHARING_LOGD("cache event: %{public}s agentId: %{public}u.",
741 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str(), GetId());
748 SHARING_LOGW("already has event: %{public}s, agentId: %{public}u.",
749 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str(), GetId());
756 runEvents_.emplace(nextKey, event);
758 SHARING_LOGW("cache event: %{public}s, agentId: %{public}u.",
759 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str(), GetId());
787 SharingEvent event;
803 event = std::move(it->second);
805 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str());
813 SHARING_LOGI("agentId: %{public}u, pop to handle next event: %{public}s.", GetId(),
814 std::string(magic_enum::enum_name(event.eventMsg->type)).c_str());
815 HandleEvent(event);