diff options
| -rw-r--r-- | server/fsm.go | 11 |
1 files changed, 3 insertions, 8 deletions
diff --git a/server/fsm.go b/server/fsm.go index 2ebe8047..b40305f6 100644 --- a/server/fsm.go +++ b/server/fsm.go @@ -729,19 +729,14 @@ func (h *FSMHandler) sendMessageloop() error { } return nil case m := <-h.outgoing: - err := send(m) - if err != nil { + if err := send(m); err != nil { return nil } case <-fsm.keepaliveTicker.C: - m := bgp.NewBGPKeepAliveMessage() - b, _ := m.Serialize() - _, err := conn.Write(b) - if err != nil { - h.errorCh <- true + if err := send(bgp.NewBGPKeepAliveMessage()); err != nil { return nil } - fsm.bgpMessageStateUpdate(m.Header.Type, false) + } } } |