Merge pull request #79 from ligato/pantheon-dev

Pantheon dev

glide.yaml

@@ -1,7 +1,7 @@
 package: github.com/ligato/vpp-agent
 import:
 - package: github.com/ligato/cn-infra
-  version: 1504a973dbd7cc2d75ce705ba6fb008f907abfee
+  version: ae475c078bd9d772d2b8d18950951af0d3da0402
 - package: github.com/wadey/gocovmerge
   version: b5bfa59ec0adc420475f97f89b58045c721d761c
 - package: github.com/onsi/gomega

plugins/defaultplugins/publish.go

@@ -37,9 +37,11 @@ func (plugin *Plugin) resyncIfStateEvents(keys []string) error {
 
 		_, _, found := plugin.swIfIndexes.LookupIdx(ifaceName)
 		if !found {
-			log.DefaultLogger().Debug("deleting obsolete status begin ", key)
-			err := plugin.Publish.Put(key, nil /*means delete*/)
-			log.DefaultLogger().Debug("deleting obsolete status end ", key, err)
+			err := plugin.PublishStatistics.Put(key, nil, /*means delete*/)
+			if err != nil {
+				return err
+			}
+			log.DefaultLogger().Debugf("Obsolete status for %v deleted", key)
 		} else {
 			log.DefaultLogger().WithField("ifaceName", ifaceName).Debug("interface status is needed")
 		}
@@ -92,9 +94,11 @@ func (plugin *Plugin) resyncBdStateEvents(keys []string) error {
 		}
 		_, _, found := plugin.bdIndexes.LookupIdx(bdName)
 		if !found {
-			log.DefaultLogger().Debug("deleting obsolete status begin ", key)
 			err := plugin.Publish.Put(key, nil)
-			log.DefaultLogger().Debug("deleting obsolete status end ", key, err)
+			if err != nil {
+				return err
+			}
+			log.DefaultLogger().Debugf("Obsolete status for %v deleted", key)
 		} else {
 			log.DefaultLogger().WithField("bdName", bdName).Debug("bridge domain status required")
 		}