diff options
Diffstat (limited to 'gobgpd')
| -rw-r--r-- | gobgpd/main.go | 32 |
1 files changed, 13 insertions, 19 deletions
diff --git a/gobgpd/main.go b/gobgpd/main.go index 15ad1a56..f60f250b 100644 --- a/gobgpd/main.go +++ b/gobgpd/main.go @@ -37,7 +37,7 @@ import ( func main() { sigCh := make(chan os.Signal, 1) - signal.Notify(sigCh, syscall.SIGHUP, syscall.SIGTERM, syscall.SIGUSR1) + signal.Notify(sigCh, syscall.SIGTERM, syscall.SIGUSR1) var opts struct { ConfigFile string `short:"f" long:"config-file" description:"specifying a config file"` @@ -160,10 +160,8 @@ func main() { } configCh := make(chan config.BgpConfigSet) - reloadCh := make(chan bool) if opts.Dry { - go config.ReadConfigfileServe(opts.ConfigFile, opts.ConfigType, configCh, reloadCh) - reloadCh <- true + go config.ReadConfigfileServe(opts.ConfigFile, opts.ConfigType, configCh) c := <-configCh if opts.LogLevel == "debug" { p.Println(c) @@ -172,8 +170,17 @@ func main() { } log.Info("gobgpd started") - bgpServer := server.NewBgpServer() + go bgpServer.Serve() + + // start grpc Server + grpcServer := server.NewGrpcServer(opts.GrpcPort, bgpServer.GrpcReqCh) + go func() { + if err := grpcServer.Serve(); err != nil { + log.Fatalf("failed to listen grpc port: %s", err) + } + }() + if opts.Ops { m, err := ops.NewOpsManager(bgpServer.GrpcReqCh) if err != nil { @@ -183,18 +190,8 @@ func main() { log.Info("Coordination with OpenSwitch") m.Serve() } else if opts.ConfigFile != "" { - go config.ReadConfigfileServe(opts.ConfigFile, opts.ConfigType, configCh, reloadCh) - reloadCh <- true + go config.ReadConfigfileServe(opts.ConfigFile, opts.ConfigType, configCh) } - go bgpServer.Serve() - - // start grpc Server - grpcServer := server.NewGrpcServer(opts.GrpcPort, bgpServer.GrpcReqCh) - go func() { - if err := grpcServer.Serve(); err != nil { - log.Fatalf("failed to listen grpc port: %s", err) - } - }() var bgpConfig *config.Bgp = nil var policyConfig *config.RoutingPolicy = nil @@ -256,9 +253,6 @@ func main() { } case sig := <-sigCh: switch sig { - case syscall.SIGHUP: - log.Info("reload the config file") - reloadCh <- true case syscall.SIGKILL, syscall.SIGTERM: bgpServer.Shutdown() case syscall.SIGUSR1: |