|
|
|
@ -14,6 +14,7 @@ import (
|
|
|
|
|
const (
|
|
|
|
|
ProxyStatusNew = "new"
|
|
|
|
|
ProxyStatusStartErr = "start error"
|
|
|
|
|
ProxyStatusWaitStart = "wait start"
|
|
|
|
|
ProxyStatusRunning = "running"
|
|
|
|
|
ProxyStatusClosed = "closed"
|
|
|
|
|
)
|
|
|
|
@ -89,6 +90,12 @@ func (pw *ProxyWrapper) GetStatus() *ProxyStatus {
|
|
|
|
|
return ps
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (pw *ProxyWrapper) WaitStart() {
|
|
|
|
|
pw.mu.Lock()
|
|
|
|
|
defer pw.mu.Unlock()
|
|
|
|
|
pw.Status = ProxyStatusWaitStart
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
func (pw *ProxyWrapper) Start(remoteAddr string, serverRespErr string) error {
|
|
|
|
|
if pw.pxy != nil {
|
|
|
|
|
pw.pxy.Close()
|
|
|
|
@ -226,6 +233,7 @@ func (pm *ProxyManager) CheckAndStartProxy(pxyStatus []string) {
|
|
|
|
|
pm.Warn("[%s] proxy send NewProxy message error")
|
|
|
|
|
return
|
|
|
|
|
}
|
|
|
|
|
pxy.WaitStart()
|
|
|
|
|
break
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|