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") } }