Function newWorker

ethstorage/miner/worker.go:136–184

(
	config Config,
	db ethdb.Database,
	storageMgr *es.StorageManager,
	api L1API,
	dr DataReader,
	chainHeadCh chan eth.L1BlockRef,
	prover MiningProver,
	lg log.Logger,
)

}

func newWorker(
	config Config,
	db ethdb.Database,
	storageMgr *es.StorageManager,
	api L1API,
	dr DataReader,
	chainHeadCh chan eth.L1BlockRef,
	prover MiningProver,
	lg log.Logger,
) *worker {
	var submissionStates map[uint64]SubmissionState
	if status, _ := db.Get(SubmissionStatusKey); status != nil {
		if err := json.Unmarshal(status, &submissionStates); err != nil {
			lg.Error("Failed to decode submission states", "err", err)
		}
	}
	worker := &worker{
		config:           config,
		l1API:            api,
		dataReader:       dr,
		prover:           prover,
		chainHeadCh:      chainHeadCh,
		shardTaskMap:     make(map[uint64]task),
		exitCh:           make(chan struct{}),
		startCh:          make(chan uint64, 1),
		resultCh:         make(chan struct{}, 1),
		miningStates:     make(map[uint64]*MiningState),
		submissionStates: make(map[uint64]*SubmissionState),
		resultLock:       sync.Mutex{},
		resultMap:        make(map[uint64]*result),
		storageMgr:       storageMgr,
		db:               db,
		lg:               lg,
	}
	for _, shardId := range storageMgr.Shards() {
		worker.miningStates[shardId] = &MiningState{MiningPower: 0, SamplingTime: 0}
		if submissionStates != nil {
			if state, ok := submissionStates[shardId]; ok {
				worker.submissionStates[shardId] = &state
				continue
			}
		}
		worker.submissionStates[shardId] = &SubmissionState{Submitted: 0, Failed: 0, Dropped: 0, LastSubmittedTime: 0}
	}
	worker.wg.Add(2)
	go worker.newWorkLoop()
	go worker.resultLoop()
	return worker
}

func (w *worker) start() {
	w.lg.Info("Worker is being started...")