(event_msg EventMsg)
| 292 | } |
| 293 | |
| 294 | func (this *module) handle_agent_enter(event_msg EventMsg) { |
| 295 | ses_event := event_msg.(*SessionEventMsg) |
| 296 | agent := ses_event.Sender.(Agent) |
| 297 | this.agent_map[agent.GetID()] = agent |
| 298 | |
| 299 | if sesmgr, ok := this.commgr_map[ses_event.Cid]; ok == true { |
| 300 | sesmgr.(SessionMgr).OnLinkerConneted(agent.GetID(), agent) |
| 301 | return |
| 302 | } |
| 303 | slog.LogError("agent", "module[%v] agent enter not found component[%v]", this.name, ses_event.Cid) |
| 304 | } |
| 305 | |
| 306 | func (this *module) handle_agent_closed(event_msg EventMsg) { |
| 307 | ses_event := event_msg.(*SessionEventMsg) |
no test coverage detected