personal_interest_mirrors/nebula
1
0
Fork 0
mirror of https://github.com/slackhq/nebula.git synced 2026-05-16 04:47:38 +02:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

nbio for tun

Browse Source
This commit is contained in:
JackDoan
2026-04-15 14:01:55 -05:00
parent e448eb1a8c
commit 4a91f0b8d5
1 changed files with 6 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
interface.go
View File

@@ -294,7 +294,7 @@ func (f *Interface) listenOut(i int) {
//TODO: Trigger Control to close //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) { 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.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) { func (f *Interface) RegisterConfigChangeCallbacks(c *config.C) {
@@ -493,13 +493,14 @@ func (f *Interface) GetCertState() *CertState {
} }
func (f *Interface) Close() error { func (f *Interface) Close() error {
var err error
f.closed.Store(true) f.closed.Store(true)
// Release the udp readers // Release the udp readers
for _, u := range f.writers { for i, u := range f.writers {
err := u.Close() err = u.Close()
if err != nil { 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")
} }
} }