Method processBlock

cmd/cql-eth-exchange/exchange.go:286–330

(b *types.Block)

}

func (e *Exchange) processBlock(b *types.Block) (err error) {
	// set back to queue
	defer func() {
		if err != nil {
			// set back to queue
			go func() {
				time.Sleep(time.Second)
				e.newBlockCh <- b
			}()
		}
	}()

	blkNumber := b.NumberU64()

	if blkNumber < atomic.LoadUint64(&e.currentBlock) {
		// reorganize current block transactions
		err = InvalidateTx(e.metaDatabase, blkNumber)
		if err != nil {
			return
		}
	}

	// process transactions in block
	for _, t := range b.Body().Transactions {
		if !e.receiveAddrMap[t.To().String()] {
			continue
		}

		// save to database
		if _, err = e.saveTx(b.Number(), t); err != nil {
			return
		}
	}

	// process block complete, advance currentBlock
	e.receivedBlockMap[blkNumber] = true

	for i := atomic.LoadUint64(&e.currentBlock) + 1; e.receivedBlockMap[i]; i++ {
		if atomic.CompareAndSwapUint64(&e.currentBlock, i-1, i) {
			delete(e.receivedBlockMap, i)
		}
	}

	return
}

func (e *Exchange) fetchBlock(head *types.Header) {
	var (