From 8d63a755ba06f45895d78fc1f538aedf3847d099 Mon Sep 17 00:00:00 2001 From: Cuong Manh Le Date: Thu, 22 Jan 2026 13:01:59 +0700 Subject: [PATCH] Removing outdated netlink codes --- cmd/cli/netlink_linux.go | 34 ---------------------------------- cmd/cli/netlink_others.go | 7 ------- cmd/cli/prog.go | 1 - 3 files changed, 42 deletions(-) delete mode 100644 cmd/cli/netlink_linux.go delete mode 100644 cmd/cli/netlink_others.go diff --git a/cmd/cli/netlink_linux.go b/cmd/cli/netlink_linux.go deleted file mode 100644 index d757f8b..0000000 --- a/cmd/cli/netlink_linux.go +++ /dev/null @@ -1,34 +0,0 @@ -package cli - -import ( - "context" - - "github.com/vishvananda/netlink" - "golang.org/x/sys/unix" -) - -func (p *prog) watchLinkState(ctx context.Context) { - ch := make(chan netlink.LinkUpdate) - done := make(chan struct{}) - defer close(done) - if err := netlink.LinkSubscribe(ch, done); err != nil { - mainLog.Load().Warn().Err(err).Msg("could not subscribe link") - return - } - for { - select { - case <-ctx.Done(): - return - case lu := <-ch: - if lu.Change == 0xFFFFFFFF { - continue - } - if lu.Change&unix.IFF_UP != 0 { - mainLog.Load().Debug().Msgf("link state changed, re-bootstrapping") - for _, uc := range p.cfg.Upstream { - uc.ReBootstrap() - } - } - } - } -} diff --git a/cmd/cli/netlink_others.go b/cmd/cli/netlink_others.go deleted file mode 100644 index 5a298b9..0000000 --- a/cmd/cli/netlink_others.go +++ /dev/null @@ -1,7 +0,0 @@ -//go:build !linux - -package cli - -import "context" - -func (p *prog) watchLinkState(ctx context.Context) {} diff --git a/cmd/cli/prog.go b/cmd/cli/prog.go index 42e2efe..c499f84 100644 --- a/cmd/cli/prog.go +++ b/cmd/cli/prog.go @@ -537,7 +537,6 @@ func (p *prog) run(reload bool, reloadCh chan struct{}) { defer wg.Done() p.runClientInfoDiscover(ctx) }() - go p.watchLinkState(ctx) } if !reload {