diff options
| -rw-r--r-- | server/fsm.go | 8 | ||||
| -rw-r--r-- | server/peer.go | 9 |
2 files changed, 8 insertions, 9 deletions
diff --git a/server/fsm.go b/server/fsm.go index 89366d72..ad8be429 100644 --- a/server/fsm.go +++ b/server/fsm.go @@ -546,6 +546,14 @@ func (h *FSMHandler) recvMessageWithError() error { return nil } case bgp.BGP_MSG_NOTIFICATION: + body := m.Body.(*bgp.BGPNotification) + log.WithFields(log.Fields{ + "Topic": "Peer", + "Key": h.fsm.pConf.Config.NeighborAddress, + "Code": body.ErrorCode, + "Subcode": body.ErrorSubcode, + "Data": body.Data, + }).Warn("received notification") h.reason = "Notification received" return nil } diff --git a/server/peer.go b/server/peer.go index b8bc9bcb..77e07252 100644 --- a/server/peer.go +++ b/server/peer.go @@ -172,15 +172,6 @@ func (peer *Peer) handleBGPmessage(e *FsmMsg) ([]*table.Path, []*bgp.BGPMessage) } return paths, nil } - case bgp.BGP_MSG_NOTIFICATION: - body := m.Body.(*bgp.BGPNotification) - log.WithFields(log.Fields{ - "Topic": "Peer", - "Key": peer.conf.Config.NeighborAddress, - "Code": body.ErrorCode, - "Subcode": body.ErrorSubcode, - "Data": body.Data, - }).Warn("received notification") } return nil, nil } |