scoot pinning around

This commit is contained in:
JackDoan
2026-05-05 12:58:33 -05:00
parent 694414771c
commit 264a25337b
4 changed files with 9 additions and 7 deletions
+2 -1
View File
@@ -14,6 +14,7 @@ import (
"github.com/gaissmai/bart"
"github.com/rcrowley/go-metrics"
"github.com/slackhq/nebula/util"
"github.com/slackhq/nebula/cert"
"github.com/slackhq/nebula/config"
@@ -395,7 +396,7 @@ func (f *Interface) listenIn(reader tio.Queue, i int) {
if n := len(f.cpuAffinity); n > 0 {
cpu = f.cpuAffinity[i%n]
}
if err := pinThreadToCPU(cpu); err != nil {
if err := util.PinThreadToCPU(cpu); err != nil {
f.l.Warn("failed to pin tun reader to CPU", "queue", i, "cpu", cpu, "err", err)
}
rejectBuf := make([]byte, mtu)