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

More audit changes.

Browse Source
This commit is contained in:
jdl
2026-06-14 09:13:01 +02:00
parent 71328eb67e
commit b875313f7d
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
peer/multicast/receiver.go
View File

@@ -12,16 +12,17 @@ import (
) )
func Receiver(selfVPNIP netip.Addr, ch chan<- Packet) { func Receiver(selfVPNIP netip.Addr, ch chan<- Packet) {
limiters := map[netip.Addr]*ratelimiter.Limiter{}
for { for {
if err := receiver(selfVPNIP, limiters, ch); err != nil { if err := receiver(selfVPNIP, ch); err != nil {
log.Printf("[MCReader] %v", err) log.Printf("[MCReader] %v", err)
} }
time.Sleep(errorTimeout) time.Sleep(errorTimeout)
} }
} }
func receiver(selfVPNIP netip.Addr, limiters map[netip.Addr]*ratelimiter.Limiter, ch chan<- Packet) error { func receiver(selfVPNIP netip.Addr, ch chan<- Packet) error {
limiters := map[netip.Addr]*ratelimiter.Limiter{}
selfIP := selfVPNIP.As4()[3] selfIP := selfVPNIP.As4()[3]
addr := multicastAddr(selfVPNIP) addr := multicastAddr(selfVPNIP)