mirror of
https://github.com/osrg/gobgp.git
synced 2024-05-11 05:55:10 +00:00
server: kill unnecessary code
Signed-off-by: FUJITA Tomonori <[email protected]>
This commit is contained in:
@@ -184,6 +184,14 @@ func main() {
|
||||
|
||||
if policyConfig == nil {
|
||||
policyConfig = &newConfig.Policy
|
||||
// FIXME: Currently the following code
|
||||
// is safe because the above
|
||||
// SetRpkiConfig will be blocked
|
||||
// because the length of rpkiConfigCh
|
||||
// is zero. So server.GlobalRib is
|
||||
// allocated before the above
|
||||
// SetPolicy. But this should be
|
||||
// handled more cleanly.
|
||||
if err := bgpServer.SetPolicy(newConfig.Policy); err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
|
||||
+1
-6
@@ -211,9 +211,6 @@ func (server *BgpServer) Serve() {
|
||||
}(g.AfiSafis.AfiSafiList)
|
||||
|
||||
server.globalRib = table.NewTableManager(GLOBAL_RIB_NAME, rfList, g.MplsLabelRange.MinLabel, g.MplsLabelRange.MaxLabel)
|
||||
if server.policy != nil {
|
||||
server.setPolicyByConfig(server.globalRib, g.ApplyPolicy)
|
||||
}
|
||||
listenerMap := make(map[string]*net.TCPListener)
|
||||
acceptCh := make(chan *net.TCPConn)
|
||||
l4, err1 := listenAndAccept("tcp4", server.listenPort, acceptCh)
|
||||
@@ -888,9 +885,7 @@ func (server *BgpServer) SetPolicy(pl config.RoutingPolicy) error {
|
||||
return err
|
||||
}
|
||||
server.policy = p
|
||||
if server.globalRib != nil {
|
||||
server.setPolicyByConfig(server.globalRib, server.bgpConfig.Global.ApplyPolicy)
|
||||
}
|
||||
server.setPolicyByConfig(server.globalRib, server.bgpConfig.Global.ApplyPolicy)
|
||||
return nil
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user