Method Start

bgp/bgp_nonwindows.go:105–165

()

}

func (bgph *BGPHandler) Start() error {
	s := bgph.server
	go s.Serve()

	if len(bgph.config.GOBGPDCfgFile) > 0 {
		initialCfg, err := bgpconfig.ReadConfigFile(bgph.config.GOBGPDCfgFile, "toml")
		if err != nil {
			// shouldn't happen if we called validate first.
			return err
		}
		_, err = bgpconfig.InitialConfig(context.Background(), s, initialCfg, false)
		if err != nil {
			return fmt.Errorf("bgp: error initializing from gobgp config: %w", err)
		}
	} else {
		// If we weren't passed a gobgp config file, configure using the values passed from the fabio
		// config, and make sure we have a sane policy where we export our routes to peers but don't
		// import from any peers.
		err := bgph.startBGP(context.Background())
		if err != nil {
			return fmt.Errorf("bgp: error starting: %w", err)
		}

		err = bgph.setPolicies()
		if err != nil {
			return fmt.Errorf("bgp error setting policy: %w", err)
		}

	}

	errCh := make(chan error, 1)
	exit.Listen(func(sig os.Signal) {
		log.Printf("[INFO] Stopping BGP")
		err := s.StopBgp(context.Background(), &api.StopBgpRequest{})
		errCh <- err
	})

	// monitor the change of the peer state
	if err := s.WatchEvent(context.Background(), &api.WatchEventRequest{Peer: &api.WatchEventRequest_Peer{}}, func(r *api.WatchEventResponse) {
		if p := r.GetPeer(); p != nil && p.Type == api.WatchEventResponse_PeerEvent_STATE {
			log.Printf("[DEBUG] bgp event: %#v", p)
		}
	}); err != nil {
		log.Printf("[ERROR] bgp watcher failed: %s", err)
	}
	if len(bgph.config.GOBGPDCfgFile) == 0 || len(bgph.config.Peers) > 0 {
		// add peers
		err := bgph.addNeighbors(context.Background(), bgph.config.Peers)
		if err != nil {
			return fmt.Errorf("bgp error adding neighbors: %w", err)
		}
	}
	if len(bgph.config.AnycastAddresses) > 0 {
		err := bgph.AddRoutes(context.Background(), bgph.config.AnycastAddresses)
		if err != nil {
			return fmt.Errorf("bgp error adding anycastaddresses: %w", err)
		}
	}