Method newWorkLoop

ethstorage/miner/worker.go:240–297

newWorkLoop is a standalone goroutine to do the following upon received events: 1) start new task loop 2) submit new mining work

()

// 1) start new task loop
// 2) submit new mining work
func (w *worker) newWorkLoop() {
	defer w.wg.Done()

	for {
		select {
		case shardIdx := <-w.startCh:
			miner, _ := w.storageMgr.GetShardMiner(shardIdx)
			var taskChs []chan *taskItem
			for i := uint64(0); i < w.config.ThreadsPerShard; i++ {
				taskCh := make(chan *taskItem, taskQueueSize)
				taskChs = append(taskChs, taskCh)
				w.wg.Add(1)
				w.lg.Debug("Worker is starting task loop", "shard", shardIdx, "thread", i)
				go w.taskLoop(taskCh)
			}
			w.lg.Info("Worker is starting task loops", "shard", shardIdx, "threads", w.config.ThreadsPerShard)

			if w.config.EmailEnabled {
				emailSubject := fmt.Sprintf("EthStorage Mining Task Started: Shard %d", shardIdx)
				msg := fmt.Sprintf("A new mining task has been initiated for shard %d on es-node.\r\n\r\n", shardIdx)
				msg += fmt.Sprintf("Chain ID: %d\r\n", w.config.ChainID)
				msg += fmt.Sprintf("Contract: %s\r\n", w.storageMgr.ContractAddress().Hex())
				msg += fmt.Sprintf("Miner: %s\r\n", miner.Hex())
				msg += fmt.Sprintf("Threads per shard: %d\r\n", w.config.ThreadsPerShard)
				msg += fmt.Sprintf("Minimum profit: %s wei\r\n", w.config.MinimumProfit)
				msg += fmt.Sprintf("Maximum gas price: %s gwei\r\n", fmtGwei(w.config.MaxGasPrice))
				go func() {
					email.SendEmail(emailSubject, msg, w.config.EmailConfig, w.lg)
				}()
			}
			task := task{
				miner:    miner,
				shardIdx: shardIdx,
				taskChs:  taskChs,
			}
			w.shardTaskMap[shardIdx] = task

		case block := <-w.chainHeadCh:
			if !w.isRunning() {
				break
			}
			w.lg.Debug("Updating tasks with L1 new head", "blockNumber", block.Number, "blockTime", block.Time, "blockHash", block.Hash, "now", uint64(time.Now().Unix()))
			// TODO suspend mining if:
			// 1) a mining tx is already submitted; or
			// 2) if the last mining time is too close (the reward is not enough).
			for shardIdx, task := range w.shardTaskMap {
				reqDiff, err := w.updateDifficulty(shardIdx, block)
				if err != nil {
					continue
				}
				w.assignTasks(task, block, reqDiff)
			}
		case <-w.exitCh:
			w.lg.Warn("Worker is exiting from work loop...")
			return
		}
	}
}