diff options
| author |   Rastislav Szabo <raszabo@cisco.com> | 2018-07-09 07:56:15 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@fd.io> | 2018-07-09 07:56:15 +0000 |
| commit | a679bbc78b98089f9b221bbe7de963f5274073bb (patch) | |
| tree | 09efc26e2a6d8c01f9e18aeaf8345ecec6154711 /core/notification_handler.go | |
| parent | 3f26790b479f8a0cab00093b83491e9f47648b56 (diff) | |
| parent | f1bef4a3c66f4408afdeb64cda62ccd8562d0fc6 (diff) | |
Merge "make api.Channel as interface"
Diffstat (limited to 'core/notification_handler.go')
| -rw-r--r-- | core/notification_handler.go | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/core/notification_handler.go b/core/notification_handler.go index 89c16a4..c0e8687 100644 --- a/core/notification_handler.go +++ b/core/notification_handler.go @@ -18,13 +18,12 @@ import ( "fmt" "reflect" - logger "github.com/sirupsen/logrus" - "git.fd.io/govpp.git/api" + logger "github.com/sirupsen/logrus" ) // processNotifSubscribeRequest processes a notification subscribe request. -func (c *Connection) processNotifSubscribeRequest(ch *api.Channel, req *api.NotifSubscribeRequest) error { +func (c *Connection) processNotifSubscribeRequest(ch *channel, req *api.NotifSubscribeRequest) error { var err error // subscribe / unsubscribe @@ -36,7 +35,7 @@ func (c *Connection) processNotifSubscribeRequest(ch *api.Channel, req *api.Noti // send the reply into the go channel select { - case ch.NotifSubsReplyChan <- err: + case ch.notifSubsReplyChan <- err: // reply sent successfully default: // unable to write into the channel without blocking |