diff options
Diffstat (limited to 'server/server.go')
| -rw-r--r-- | server/server.go | 12 |
1 files changed, 0 insertions, 12 deletions
diff --git a/server/server.go b/server/server.go index 757b645e..a2662a4d 100644 --- a/server/server.go +++ b/server/server.go @@ -95,7 +95,6 @@ type BgpServer struct { fsmincomingCh *channels.InfiniteChannel fsmStateCh chan *FsmMsg acceptCh chan *net.TCPConn - collector *Collector GrpcReqCh chan *GrpcRequest policy *table.RoutingPolicy @@ -1499,17 +1498,6 @@ func (server *BgpServer) handleModConfig(grpcReq *GrpcRequest) error { return nil } -func sendMultipleResponses(grpcReq *GrpcRequest, results []*GrpcResponse) { - defer close(grpcReq.ResponseCh) - for _, r := range results { - select { - case grpcReq.ResponseCh <- r: - case <-grpcReq.EndCh: - return - } - } -} - func (server *BgpServer) handleGrpc(grpcReq *GrpcRequest) { logOp := func(addr string, action string) { log.WithFields(log.Fields{ |