From 4a91f0b8d5bb61dad3f2dc2886335c243bbce44a Mon Sep 17 00:00:00 2001 From: JackDoan Date: Wed, 15 Apr 2026 14:01:55 -0500 Subject: [PATCH] nbio for tun --- interface.go | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/interface.go b/interface.go index 520f7969..c38130c5 100644 --- a/interface.go +++ b/interface.go @@ -294,7 +294,7 @@ func (f *Interface) listenOut(i int) { //TODO: Trigger Control to close } - f.l.Debugf("underlay reader %v is done", i) + f.l.Infof("underlay reader %v is done", i) } func (f *Interface) listenIn(reader io.ReadWriteCloser, i int) { @@ -318,7 +318,7 @@ func (f *Interface) listenIn(reader io.ReadWriteCloser, i int) { f.consumeInsidePacket(packet[:n], fwPacket, nb, out, i, conntrackCache.Get(f.l)) } - f.l.Debugf("overlay reader %v is done", i) + f.l.Infof("overlay reader %v is done", i) } func (f *Interface) RegisterConfigChangeCallbacks(c *config.C) { @@ -493,13 +493,14 @@ func (f *Interface) GetCertState() *CertState { } func (f *Interface) Close() error { + var err error f.closed.Store(true) // Release the udp readers - for _, u := range f.writers { - err := u.Close() + for i, u := range f.writers { + err = u.Close() if err != nil { - f.l.WithError(err).Error("Error while closing udp socket") + f.l.WithError(err).WithField("writer", i).Error("Error while closing udp socket") } }