app/vppn
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 8 Wiki Activity

WIP: Fixed rate limiting

Browse Source
This commit is contained in:
jdl 2025-08-26 16:17:46 +02:00
parent 169231d848
commit 3c4534f620
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
peer/remote.go
View File

@ -87,10 +87,6 @@ func (r *Remote) updateConf(conf remoteConfig) {
// ---------------------------------------------------------------------------- // ----------------------------------------------------------------------------
func (r *Remote) sendUDP(b []byte, addr netip.AddrPort) { func (r *Remote) sendUDP(b []byte, addr netip.AddrPort) {
if err := r.limiter.Limit(); err != nil {
r.logf("Rate limiter")
return
}
if _, err := r.SendUDP(b, addr); err != nil { if _, err := r.SendUDP(b, addr); err != nil {
r.logf("Failed to send URP packet: %v", err) r.logf("Failed to send URP packet: %v", err)
} }
@ -162,6 +158,11 @@ func (r *Remote) relayData(toIP byte, enc []byte) {
} }
func (r *Remote) sendControl(conf remoteConfig, data []byte) { func (r *Remote) sendControl(conf remoteConfig, data []byte) {
if err := r.limiter.Limit(); err != nil {
r.logf("Rate limiter")
return
}
if conf.Direct { if conf.Direct {
r.sendControlDirect(conf, data) r.sendControlDirect(conf, data)
} else { } else {