Compare commits

...

2 Commits

Author SHA1 Message Date
bobo liu
99e9fa3e0f
Merge 3507c17084642ffc3dabc04acc03b7c32b1a6f73 into f1fb2d721a901cd1e91368f0a5f8b9618bb530c3 2024-08-02 16:03:17 -06:00
bobo liu
3507c17084 fix misuse of unlock
phase, which needs protection, is still out of critical section
2024-07-10 21:43:08 +08:00

View File

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