Method Start

controller/controller.go:101–151

Start() begins the Controller service

()

// Start() begins the Controller service
func (c *Controller) Start() {
	rootChainId, err := c.FSM.GetRootChainId()
	if err != nil {
		c.log.Fatal(err.Error())
	}
	// in a non-blocking sub-function
	go func() {
		// start the P2P module
		c.P2P.Start()
		// log the beginning of the root-chain API connection
		c.log.Warnf("Attempting to connect to the root-chain: %d", rootChainId)
		// set a timer to go off once per second
		t := time.NewTicker(time.Second)
		// once function completes, stop the timer
		defer t.Stop()
		// each time the timer fires
		for range t.C {
			// get the root chain info from the rpc
			rootChainInfo, e := c.RCManager.GetRootChainInfo(rootChainId, c.Config.ChainId)
			if e != nil {
				c.log.Error(e.Error()) // log error but continue
			} else if rootChainInfo != nil && rootChainInfo.Height != 0 {
				c.log.Infof("Received root chain info with %d validators", len(rootChainInfo.ValidatorSet.GetValidatorSet()))
				// call mempool check
				c.Mempool.CheckMempool()
				// update the peer 'must connect'
				c.UpdateP2PMustConnect(rootChainInfo.ValidatorSet)
				// exit the loop
				break
			}
			c.log.Warnf("Empty root chain info")
		}
		// start mempool service
		go c.CheckMempool()
		// start internal Controller listeners for P2P
		c.StartListeners()
		// Wait until peers reaches minimum count
		c.P2P.WaitForMinimumPeers()
		// start the syncing process (if not synced to top)
		go c.Sync()
		// allow sleep and wake up using config
		wakeDate := time.Unix(int64(c.Config.SleepUntil), 0)
		if time.Now().Before(wakeDate) {
			untilTime := time.Until(wakeDate)
			c.log.Infof("Sleeping until %s", untilTime.String())
			time.Sleep(untilTime)
		}
		// start the bft consensus (if synced to top)
		go c.Consensus.Start()
	}()
}

// StartListeners() runs all listeners on separate threads
func (c *Controller) StartListeners() {