From cd1a6c80a801e5e19d896d4505cdecc6fa835442 Mon Sep 17 00:00:00 2001 From: Harry Cheng Date: Thu, 3 Mar 2022 16:19:00 +0800 Subject: [PATCH] Add CloseProxy to manual close --- server/control.go | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/server/control.go b/server/control.go index b157dbd2..09740611 100644 --- a/server/control.go +++ b/server/control.go @@ -578,5 +578,20 @@ func (ctl *Control) CloseProxy(closeMsg *msg.CloseProxy) (err error) { ctl.mu.Unlock() metrics.Server.CloseProxy(pxy.GetName(), pxy.GetConf().GetBaseInfo().ProxyType) + + notifyContent := &plugin.CloseProxyContent{ + User: plugin.UserInfo{ + User: ctl.loginMsg.User, + Metas: ctl.loginMsg.Metas, + RunID: ctl.loginMsg.RunID, + }, + CloseProxy: msg.CloseProxy{ + ProxyName: pxy.GetName(), + }, + } + go func() { + ctl.pluginManager.CloseProxy(notifyContent) + }() + return }