Method process

cmd/cql-eth-exchange/exchange.go:255–284

()

}

func (e *Exchange) process() {
	if e.newBlockHeaderCh == nil || e.wg == nil {
		return
	}

	defer e.wg.Done()
	processTick := time.NewTicker(10 * conf.GConf.BPPeriod)
	defer processTick.Stop()

	for {
		select {
		case b := <-e.newBlockCh:
			_ = e.processBlock(b)
		case blockHead := <-e.newBlockHeaderCh:
			e.wg.Add(1)
			go e.fetchBlock(blockHead)
		case <-e.processCtx.Done():
			return
		case <-processTick.C:
			// load tx and process
			e.processPendingTxs()
		default:
			// update transferring tx state
			e.updateTransferringTxState()
			// update transferring tx state
			e.expireStaleTx()
		}
	}

}

func (e *Exchange) processBlock(b *types.Block) (err error) {
	// set back to queue