diff options
| -rw-r--r-- | server/server.go | 7 |
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() { |