Method PersistBlock

validator/db/store.go:177–231

(block *types.Block)

}

func (self *Store) PersistBlock(block *types.Block) error {
	height := block.Header.Height
	if !((self.bestBlockHeader == nil && height == 0) || height == self.bestBlockHeader.Height+1) {
		return errors.New("can't persist discontinuous block")
	}

	self.mutex.Lock()
	defer self.mutex.Unlock()

	self.db.NewBatch()
	for _, txn := range block.Transactions {
		err := self.saveTransaction(txn, height)
		if err != nil {
			return err
		}
	}

	// is genesis block
	if self.bestBlockHeader == nil {
		key := GenGenesisBlockKey()
		defer keyPool.Put(key)
		value := valuePool.Get()
		defer valuePool.Put(value)

		sink := common.NewZeroCopySink(nil)
		block.Serialization(sink)
		value.Write(sink.Bytes())
		self.db.BatchPut(key.Bytes(), value.Bytes())
	}

	key := GenBestBlockHeaderKey()
	defer keyPool.Put(key)
	value := valuePool.Get()
	defer valuePool.Put(value)

	header := block.Header

	sink := common.NewZeroCopySink(nil)
	header.Serialization(sink)
	value.Write(sink.Bytes())
	self.db.BatchPut(key.Bytes(), value.Bytes())

	err := self.db.BatchCommit()

	if err != nil {
		return err
	}

	if self.bestBlockHeader == nil {
		self.genesisBlock = block
	}
	self.bestBlockHeader = block.Header

	return err
}