extern/netbird
1
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2025-06-24 11:41:35 +02:00
Code Issues Packages Projects Releases Wiki Activity

Apply same pausedCond logic on all implementation

Browse Source
This commit is contained in:
Zoltán Papp 2025-02-21 14:55:56 +01:00
parent 648b4cdf72
commit d496d21693
2 changed files with 6 additions and 22 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
client/iface/wgproxy/bind/proxy.go
View File

@ -161,17 +161,9 @@ func (p *ProxyBind) proxyToLocal(ctx context.Context) {
return
}
for {
p.pausedCond.L.Lock()
if p.paused {
p.pausedCond.Wait()
if !p.paused {
break
}
p.pausedCond.L.Unlock()
continue
}
break
p.pausedCond.L.Lock()
for p.paused {
p.pausedCond.Wait()
}
msg := bind.RecvMessage{

14
client/iface/wgproxy/ebpf/wrapper.go
View File

@ -120,17 +120,9 @@ func (p *ProxyWrapper) proxyToLocal(ctx context.Context) {
return
}
for {
p.pausedCond.L.Lock()
if p.paused {
p.pausedCond.Wait()
if !p.paused {
break
}
p.pausedCond.L.Unlock()
continue
}
break
p.pausedCond.L.Lock()
for p.paused {
p.pausedCond.Wait()
}
err = p.wgeBPFProxy.sendPkg(buf[:n], p.wgEndpointCurrentUsedAddr)