Networks/Reticulum-Go
2
1
Fork 0
Code Issues 5 Pull Requests 1 Actions Packages Projects 1 Releases 1 Wiki Activity

refactor: update bandwidth checks in announce forwarding logic to prevent overload

Browse Source
This commit is contained in:
ivan
2025-12-30 12:35:32 -06:00
parent 04bd23e753
commit 0a3d0c9440
1 changed files with 13 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
pkg/transport/transport.go
View File

@@ -162,7 +162,7 @@ func NewTransport(cfg *common.ReticulumConfig) *Transport {
interfaces: make(map[string]common.NetworkInterface),
paths: make(map[string]*common.Path), // TODO: Load persisted path table from storage/destination_table for faster startup
seenAnnounces: make(map[string]bool),
announceRate: rate.NewLimiter(PROPAGATION_RATE, common.ONE),
announceRate: rate.NewLimiter(rate.DefaultBurstFreq, 20.0),
mutex: sync.RWMutex{},
config: cfg,
links: make(map[string]LinkInterface),
@@ -690,6 +690,12 @@ func (t *Transport) HandleAnnounce(data []byte, sourceIface common.NetworkInterf
continue
}
// Check interface-level bandwidth before forwarding
if !iface.GetBandwidthAvailable() {
debug.Log(debug.DEBUG_VERBOSE, "Skipping announce forwarding on interface due to bandwidth cap", "name", name)
continue
}
debug.Log(debug.DEBUG_ALL, "Forwarding announce on interface", "name", name)
if err := iface.Send(data, ""); err != nil {
debug.Log(debug.DEBUG_ALL, "Failed to forward announce", "name", name, "error", err)
@@ -1135,6 +1141,12 @@ func (t *Transport) handleAnnouncePacket(data []byte, iface common.NetworkInterf
continue
}
// Check interface-level bandwidth before forwarding
if !outIface.GetBandwidthAvailable() {
debug.Log(debug.DEBUG_VERBOSE, "Skipping announce forwarding on interface due to bandwidth cap", "name", name)
continue
}
debug.Log(debug.DEBUG_ALL, "Forwarding announce on interface", "name", name)
if err := outIface.Send(data, ""); err != nil {
debug.Log(debug.DEBUG_ALL, "Failed to forward announce", "name", name, "error", err)