diff options
| author | ISHIDA Wataru <ishida.wataru@lab.ntt.co.jp> | 2016-01-01 03:08:16 +0900 |
|---|---|---|
| committer | ISHIDA Wataru <ishida.wataru@lab.ntt.co.jp> | 2016-01-04 16:46:28 +0900 |
| commit | afcd2e72fbe12e9ad8ab426e14c7110123678bad (patch) | |
| tree | 7a0e0e69811e8f72512e1ed64564f29c6e7330a5 /test/performance_test/main.go | |
| parent | ce1d27ba8c49856c2e67c65f076caf48dbb6765e (diff) | |
server: introduce fastpath for fsm state change
for robust fsm handling
Signed-off-by: ISHIDA Wataru <ishida.wataru@lab.ntt.co.jp>
Diffstat (limited to 'test/performance_test/main.go')
| -rw-r--r-- | test/performance_test/main.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/test/performance_test/main.go b/test/performance_test/main.go index 4385dd68..aec15b54 100644 --- a/test/performance_test/main.go +++ b/test/performance_test/main.go @@ -31,7 +31,7 @@ import ( func newPeer(g config.Global, p config.Neighbor, incoming chan *server.FsmMsg) *server.Peer { tbl := table.NewTableManager([]bgp.RouteFamily{bgp.RF_IPv4_UC, bgp.RF_IPv6_UC}, 0, 0) peer := server.NewPeer(g, p, tbl, table.NewRoutingPolicy()) - server.NewFSMHandler(peer.Fsm(), incoming, peer.Outgoing()) + server.NewFSMHandler(peer.Fsm(), incoming, incoming, peer.Outgoing()) return peer } @@ -85,7 +85,7 @@ func main() { nextState := msg.MsgData.(bgp.FSMState) fsm := peer.Fsm() fsm.StateChange(nextState) - server.NewFSMHandler(fsm, incoming, peer.Outgoing()) + server.NewFSMHandler(fsm, incoming, incoming, peer.Outgoing()) if nextState == bgp.BGP_FSM_ESTABLISHED { established++ } |