(pxy proxy.Proxy)
| 294 | } |
| 295 | |
| 296 | func (ctl *Control) closeProxy(pxy proxy.Proxy) { |
| 297 | pxy.Close() |
| 298 | ctl.sessionCtx.PxyManager.Del(pxy.GetName()) |
| 299 | metrics.Server.CloseProxy(pxy.GetName(), pxy.GetConfigurer().GetBaseConfig().Type) |
| 300 | |
| 301 | notifyContent := &plugin.CloseProxyContent{ |
| 302 | User: ctl.loginUserInfo(), |
| 303 | CloseProxy: msg.CloseProxy{ |
| 304 | ProxyName: pxy.GetName(), |
| 305 | }, |
| 306 | } |
| 307 | go func() { |
| 308 | _ = ctl.sessionCtx.PluginManager.CloseProxy(notifyContent) |
| 309 | }() |
| 310 | } |
| 311 | |
| 312 | func (ctl *Control) worker() { |
| 313 | xl := ctl.xl |
no test coverage detected