diff options
| -rw-r--r-- | server/fsm_test.go | 1 | ||||
| -rw-r--r-- | server/mrt.go | 4 | ||||
| -rw-r--r-- | server/server.go | 12 |
3 files changed, 0 insertions, 17 deletions
diff --git a/server/fsm_test.go b/server/fsm_test.go index 519a2382..f973fb76 100644 --- a/server/fsm_test.go +++ b/server/fsm_test.go @@ -34,7 +34,6 @@ type MockConnection struct { recvCh chan chan byte sendBuf [][]byte currentCh chan byte - readBytes int isClosed bool wait int } diff --git a/server/mrt.go b/server/mrt.go index ce4ac90b..639a2ceb 100644 --- a/server/mrt.go +++ b/server/mrt.go @@ -44,10 +44,6 @@ func (w *mrtWatcher) stop() { w.t.Kill(nil) } -func (w *mrtWatcher) restart(filename string) error { - return nil -} - func (w *mrtWatcher) loop() error { c := func() *time.Ticker { if w.interval == 0 { 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{ |