Skip to content

Commit

Permalink
publish all notifications
Browse files Browse the repository at this point in the history
  • Loading branch information
denis-tingaikin committed Aug 28, 2019
1 parent 8cdc8da commit c8bd5c8
Showing 1 changed file with 6 additions and 7 deletions.
13 changes: 6 additions & 7 deletions plugins/vpp/ifplugin/publish_state.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,9 @@ import (
"github.com/ligato/cn-infra/datasync"
"github.com/ligato/cn-infra/health/statuscheck"
"github.com/ligato/cn-infra/health/statuscheck/model/status"
"github.com/pkg/errors"

"github.com/ligato/vpp-agent/api/models/vpp"
interfaces "github.com/ligato/vpp-agent/api/models/vpp/interfaces"
"github.com/pkg/errors"
)

// watchStatusEvents watches for resync event of interface state data.
Expand Down Expand Up @@ -140,11 +139,11 @@ func (p *IfPlugin) publishIfStateEvents() {
p.Log.Debugf("Updating link state: %+v", ifState)
}
p.linkStateDescriptor.UpdateLinkState(ifState)
if p.PushNotification != nil {
p.PushNotification(&vpp.Notification{
Interface: ifState,
})
}
}
if p.PushNotification != nil {
p.PushNotification(&vpp.Notification{
Interface: ifState,
})
}

p.publishLock.Unlock()
Expand Down

0 comments on commit c8bd5c8

Please sign in to comment.