diff --git a/client/internal/wgproxy/proxy_ebpf.go b/client/internal/wgproxy/proxy_ebpf.go index f1b338407..f420dfbba 100644 --- a/client/internal/wgproxy/proxy_ebpf.go +++ b/client/internal/wgproxy/proxy_ebpf.go @@ -104,6 +104,7 @@ func (p *WGEBPFProxy) CloseConn() error { // Free resources func (p *WGEBPFProxy) Free() error { + log.Debugf("free up ebpf wg proxy") var err1, err2, err3 error if p.conn != nil { err1 = p.conn.Close() @@ -155,9 +156,11 @@ func (p *WGEBPFProxy) proxyToRemote() { p.turnConnMutex.Lock() conn, ok := p.turnConnStore[uint16(addr.Port)] + size := len(p.turnConnStore) p.turnConnMutex.Unlock() if !ok { log.Errorf("turn conn not found by port: %d", addr.Port) + log.Debugf("conn store size: %d", size) continue } diff --git a/client/internal/wgproxy/proxy_userspace.go b/client/internal/wgproxy/proxy_userspace.go index f2411e976..b22707554 100644 --- a/client/internal/wgproxy/proxy_userspace.go +++ b/client/internal/wgproxy/proxy_userspace.go @@ -20,6 +20,7 @@ type WGUserSpaceProxy struct { // NewWGUserSpaceProxy instantiate a user space WireGuard proxy func NewWGUserSpaceProxy(wgPort int) *WGUserSpaceProxy { + log.Debugf("instantiate new userspace proxy") p := &WGUserSpaceProxy{ localWGListenPort: wgPort, } @@ -37,6 +38,7 @@ func (p *WGUserSpaceProxy) AddTurnConn(remoteConn net.Conn) (net.Addr, error) { log.Errorf("failed dialing to local Wireguard port %s", err) return nil, err } + log.Debugf("add turn conn: %s", remoteConn.RemoteAddr()) go p.proxyToRemote() go p.proxyToLocal()