server: introduce fastpath for fsm state change

for robust fsm handling

Signed-off-by: ISHIDA Wataru <ishida.wataru@lab.ntt.co.jp>

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++
 				}