Lines Matching defs:agent
17 #include "agent/sinkagent/sink_agent.h"
18 #include "agent/srcagent/src_agent.h"
94 SHARING_LOGI("contextId: %{public}u, destroy agent agentId: %{public}u.", GetId(), eventMsg->agentId);
96 auto agent = GetAgentById(eventMsg->agentId);
97 if (agent == nullptr) {
98 SHARING_LOGE("agent null agentId: %{public}d.", eventMsg->agentId);
102 if (agent->GetAgentType() == SRC_AGENT) {
104 agent->HandleEvent(event);
106 agent->SetDestroy();
109 agent->HandleEvent(event);
111 SHARING_LOGI("contextId: %{public}u, destroy agent need wait src agent destroy. agentId: %{public}u.",
129 auto agent = GetAgentById(eventMsg->agentId);
130 if (agent) {
131 agent->HandleEvent(event);
159 SHARING_LOGD("agent id still has %{public}d.", item.second->GetId());
245 std::shared_ptr<Agent> agent = nullptr;
249 SHARING_LOGE("create agent session error.");
264 SHARING_LOGI("create agent create media channel agentId: %{public}u channelId: %{public}u.",
268 agent = sinkAgent;
279 SHARING_LOGE("create agent session error.");
287 agent = srcAgent;
294 agent->SetAgentListener(shared_from_this());
297 agents_.emplace(agent->GetId(), agent);
298 SHARING_LOGI("contextId: %{public}u, create agent className: %{public}s "
300 GetId(), className.c_str(), std::string(magic_enum::enum_name(agentType)).c_str(), agent->GetId(),
302 return agent->GetId();
332 auto agent = GetAgentById(eventMsg->agentId);
333 if (agent) {
334 AgentType agentType = agent->GetAgentType();
336 auto srcAgent = std::static_pointer_cast<SrcAgent>(agent);
347 SHARING_LOGE("agent null agentId: %{public}d.", eventMsg->agentId);
355 auto agent = GetAgentById(sinkAgentId);
356 RETURN_IF_NULL(agent);
358 if (agent->GetDestroy() && IsEmptySrcAgent(sinkAgentId)) {
359 SHARING_LOGI("produer destroyed. src agent is all destroyed. destroy sink agent now. "
370 agent->HandleEvent(event);