(event_msg EventMsg)
| 304 | } |
| 305 | |
| 306 | func (this *module) handle_agent_closed(event_msg EventMsg) { |
| 307 | ses_event := event_msg.(*SessionEventMsg) |
| 308 | agent := ses_event.Sender.(Agent) |
| 309 | delete(this.agent_map, agent.GetID()) |
| 310 | if sesmgr, ok := this.commgr_map[ses_event.Cid]; ok == true { |
| 311 | sesmgr.(SessionMgr).OnLinkerClosed(agent.GetID(), agent) |
| 312 | return |
| 313 | } |
| 314 | slog.LogError("agent", "module[%v] agent closed not found component[%v]", this.name, ses_event.Cid) |
| 315 | } |
| 316 | |
| 317 | func (this *module) handle_rpc(event_msg EventMsg) { |
| 318 | rpc_msg := event_msg.(*RpcEventMsg) |
no test coverage detected