Fixed test

protocols/bgp/server/bmp_router.go

@@ -112,8 +112,7 @@ func (r *router) processRouteMonitoringMsg(msg *bmppkt.RouteMonitoringMsg) {
 
 	n := r.neighbors[msg.PerPeerHeader.PeerAddress]
 	s := n.fsm.state.(*establishedState)
-	_, reason := s.msgReceived(msg.BGPUpdate, s.fsm.decodeOptions())
-	fmt.Printf("Reason: %v\n", reason)
+	s.msgReceived(msg.BGPUpdate, s.fsm.decodeOptions())
 }
 
 func (r *router) processInitiationMsg(msg *bmppkt.InitiationMessage) {

protocols/bgp/server/bmp_router_test.go

@@ -267,6 +267,7 @@ func TestProcessPeerUpNotification(t *testing.T) {
 							neighborID: 169090610,
 							state:      &establishedState{},
 							peer: &peer{
+								routerID:  169090600,
 								addr:      bnet.IPv4FromOctets(10, 0, 255, 1),
 								localAddr: bnet.IPv4FromOctets(10, 0, 255, 0),
 								peerASN:   100,
@@ -277,7 +278,7 @@ func TestProcessPeerUpNotification(t *testing.T) {
 							ipv4Unicast: &fsmAddressFamily{
 								afi:          1,
 								safi:         1,
-								adjRIBIn:     adjRIBIn.New(filter.NewAcceptAllFilter(), &routingtable.ContributingASNs{}, 0, 0, false),
+								adjRIBIn:     adjRIBIn.New(filter.NewAcceptAllFilter(), &routingtable.ContributingASNs{}, 169090600, 0, false),
 								importFilter: filter.NewAcceptAllFilter(),
 							},
 						},

protocols/bgp/server/fsm_open_sent.go

@@ -141,7 +141,6 @@ func (s *openSentState) handleOpenMessage(openMsg *packet.BGPOpen) (state, strin
 	s.processOpenOptions(openMsg.OptParams)
 
 	if s.peerASNRcvd != s.fsm.peer.peerASN {
-		fmt.Printf("s.peerASNRcvd != s.fsm.peer.peerASN: %v != %v\n", s.peerASNRcvd, s.fsm.peer.peerASN)
 		s.fsm.sendNotification(packet.OpenMessageError, packet.BadPeerAS)
 		return newCeaseState(), fmt.Sprintf("Bad Peer AS %d, expected: %d", s.peerASNRcvd, s.fsm.peer.peerASN)
 	}