diff options
| author | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2015-03-06 22:11:04 +0900 |
|---|---|---|
| committer | FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp> | 2015-03-06 22:11:04 +0900 |
| commit | 25f1152dafdc785352e19d0893aa9007f279045c (patch) | |
| tree | c6c135e08528739db9024a6d677c35716875d4fd /server/peer.go | |
| parent | 162a6137ac625552c5e248fa36d56edf89ddd06c (diff) | |
server: remove rf in ServerMsg
Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>
Diffstat (limited to 'server/peer.go')
| -rw-r--r-- | server/peer.go | 11 |
1 files changed, 1 insertions, 10 deletions
diff --git a/server/peer.go b/server/peer.go index 4e079c13..d32eacb0 100644 --- a/server/peer.go +++ b/server/peer.go @@ -179,9 +179,6 @@ func (peer *Peer) handleBGPmessage(m *bgp.BGPMessage) { msgData: pathList, } for _, s := range peer.siblings { - if s.rf != peer.rf { - continue - } s.peerMsgCh <- pm } } @@ -240,9 +237,6 @@ func (peer *Peer) handleREST(restReq *api.RestRequest) { msgData: pathList, } for _, s := range peer.siblings { - if s.rf != peer.rf { - continue - } s.peerMsgCh <- pm } if restReq.RequestType == api.REQ_NEIGHBOR_SOFT_RESET_IN { @@ -334,7 +328,7 @@ func (peer *Peer) handleServerMsg(m *serverMsg) { case SRV_MSG_PEER_ADDED: d := m.msgData.(*serverMsgDataPeer) peer.siblings[d.address.String()] = d - pathList := peer.adjRib.GetInPathList(d.rf) + pathList := peer.adjRib.GetInPathList(peer.rf) if len(pathList) == 0 { return } @@ -343,9 +337,6 @@ func (peer *Peer) handleServerMsg(m *serverMsg) { msgData: pathList, } for _, s := range peer.siblings { - if s.rf != peer.rf { - continue - } s.peerMsgCh <- pm } case SRV_MSG_PEER_DELETED: |