server: make mrt rpc request reliable

Currently, if a mrt request sender doesn't read from bgpd some time, a
message could be dropped. Instead, this makes bgpd keep messages in
memory until they are read.

Signed-off-by: FUJITA Tomonori <fujita.tomonori@lab.ntt.co.jp>

1 files changed, 6 insertions, 1 deletions

diff --git a/server/server.go b/server/server.go
index 0bcc578f..d95d5228 100644
--- a/server/server.go
+++ b/server/server.go
@@ -1933,10 +1933,15 @@ func (server *BgpServer) handleMrt(grpcReq *GrpcRequest) {
 	select {
 	case <-grpcReq.EndCh:
 		return
-	case grpcReq.ResponseCh <- result:
 	default:
 	}
 
+	m := &broadcastMsg{
+		req:    grpcReq,
+		result: result,
+	}
+	server.broadcastMsgs = append(server.broadcastMsgs, m)
+
 	interval := int64(grpcReq.Data.(uint64))
 	if interval > 0 {
 		go func() {