Method Run

protocol/smartpool.go:212–243

Run can be called at most once to start a loop to submit and verify claims after an interval. If the loop has not been started, it starts the loop and return true, it return false otherwise.

()

// If the loop has not been started, it starts the loop and return true, it
// return false otherwise.
func (sp *SmartPool) Run() bool {
	sp.runMu.Lock()
	defer sp.runMu.Unlock()
	if sp.Register(sp.MinerAddress) {
		if sp.loopStarted {
			smartpool.Output.Printf("Warning: calling Run() multiple times\n")
			return false
		}
		err := sp.NetworkClient.Configure(
			sp.ContractAddress,
			sp.ExtraData,
		)
		if err != nil {
			return false
		}
		for {
			if sp.NetworkClient.ReadyToMine() {
				smartpool.Output.Printf("The network is ready for mining.\n")
				sp.ticker = time.Tick(sp.SubmitInterval)
				go sp.actOnTick()
				break
			}
			smartpool.Output.Printf("The network is not ready for mining yet. Retry in 10s...\n")
			time.Sleep(10 * time.Second)
		}
		sp.loopStarted = true
		smartpool.Output.Printf("Share collector is running...")
		return true
	} else {
		return false
	}
}

func NewSmartPool(
	pm smartpool.PoolMonitor, sr smartpool.ShareReceiver,