diff options
| author |   Ondrej Fabry <ofabry@cisco.com> | 2019-07-30 16:19:35 +0200 |
|---|---|---|
| committer | Ondrej Fabry <ofabry@cisco.com> | 2019-07-30 16:19:35 +0200 |
| commit | 572c0840e77d2c34077a054548e7559cb3670308 (patch) | |
| tree | bd14f5cc0b992de31ae17822d4ca4c205742d872 | |
| parent | bde85d422c7949ec32fb067e9c36320ccc47fb9e (diff) | |
Use common logger in core package
Change-Id: If9da8381212273f8f2655d7b0a3077b5ba32921f
Signed-off-by: Ondrej Fabry <ofabry@cisco.com>
| -rw-r--r-- | core/channel.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/core/channel.go b/core/channel.go index c464708..5b513e3 100644 --- a/core/channel.go +++ b/core/channel.go @@ -257,7 +257,7 @@ func (ch *Channel) receiveReplyInternal(msg api.Message, expSeqNum uint16) (last case vppReply := <-ch.replyChan: ignore, lastReplyReceived, err = ch.processReply(vppReply, expSeqNum, msg) if ignore { - logrus.WithFields(logrus.Fields{ + log.WithFields(logrus.Fields{ "expSeqNum": expSeqNum, "channel": ch.id, }).Warnf("ignoring received reply: %+v (expecting: %s)", vppReply, msg.GetMessageName()) @@ -266,7 +266,7 @@ func (ch *Channel) receiveReplyInternal(msg api.Message, expSeqNum uint16) (last return lastReplyReceived, err case <-timer.C: - logrus.WithFields(logrus.Fields{ + log.WithFields(logrus.Fields{ "expSeqNum": expSeqNum, "channel": ch.id, }).Debugf("timeout (%v) waiting for reply: %s", ch.replyTimeout, msg.GetMessageName()) @@ -281,7 +281,7 @@ func (ch *Channel) processReply(reply *vppReply, expSeqNum uint16, msg api.Messa cmpSeqNums := compareSeqNumbers(reply.seqNum, expSeqNum) if cmpSeqNums == -1 { // reply received too late, ignore the message - logrus.WithField("seqNum", reply.seqNum). + log.WithField("seqNum", reply.seqNum). Warn("Received reply to an already closed binary API request") ignore = true return |