Merge 3507c17084642ffc3dabc04acc03b7c32b1a6f73 into e8045194cd133b0981ad7ab781095e9ba76795cf

This commit is contained in:
bobo liu 2024-07-30 14:13:20 +08:00 committed by GitHub
commit 724f7e0970
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -254,8 +254,8 @@ func (pw *Wrapper) statusFailedCallback() {
func (pw *Wrapper) InWorkConn(workConn net.Conn, m *msg.StartWorkConn) { func (pw *Wrapper) InWorkConn(workConn net.Conn, m *msg.StartWorkConn) {
xl := pw.xl xl := pw.xl
pw.mu.RLock() pw.mu.RLock()
defer pw.mu.RUnlock()
pxy := pw.pxy pxy := pw.pxy
pw.mu.RUnlock()
if pxy != nil && pw.Phase == ProxyPhaseRunning { if pxy != nil && pw.Phase == ProxyPhaseRunning {
xl.Debugf("start a new work connection, localAddr: %s remoteAddr: %s", workConn.LocalAddr().String(), workConn.RemoteAddr().String()) xl.Debugf("start a new work connection, localAddr: %s remoteAddr: %s", workConn.LocalAddr().String(), workConn.RemoteAddr().String())
go pxy.InWorkConn(workConn, m) go pxy.InWorkConn(workConn, m)