chain

package
v1.3.1-alpha.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 21, 2019 License: GPL-3.0 Imports: 29 Imported by: 38

Documentation

Index

Constants

View Source 
const (
	InsertAccountBlocksEvent        = uint8(1)
	InsertAccountBlocksSuccessEvent = uint8(2)

	DeleteAccountBlocksEvent        = uint8(3)
	DeleteAccountBlocksSuccessEvent = uint8(4)

	InsertSnapshotBlocksSuccessEvent = uint8(6)

	DeleteSnapshotBlocksSuccessEvent = uint8(8)
)
View Source 
const (
	SAVE_TRIE_STATUS_STOPPED = 1
	SAVE_TRIE_STATUS_STARTED = 2
)

Variables

View Source 
var GenesisConsensusGroupBlock ledger.AccountBlock
View Source 
var GenesisConsensusGroupBlockVC vmctxt_interface.VmDatabase
View Source 
var GenesisMintageBlock ledger.AccountBlock
View Source 
var GenesisMintageBlockVC vmctxt_interface.VmDatabase
View Source 
var GenesisMintageSendBlock ledger.AccountBlock
View Source 
var GenesisMintageSendBlockVC vmctxt_interface.VmDatabase
View Source 
var GenesisRegisterBlock ledger.AccountBlock
View Source 
var GenesisRegisterBlockVC vmctxt_interface.VmDatabase
View Source 
var GenesisSnapshotBlock ledger.SnapshotBlock
View Source 
var SecondSnapshotBlock ledger.SnapshotBlock

Functions

func NewBlackBlock 

func NewBlackBlock(chain *chain, isOpen bool) *blackBlock

func NewGenesisConsensusGroupBlock added in v1.3.0 

func NewGenesisConsensusGroupBlock(config *config.Genesis) (ledger.AccountBlock, vmctxt_interface.VmDatabase)

func NewGenesisMintageBlock added in v1.3.0 

func NewGenesisMintageBlock(config *config.Genesis) (ledger.AccountBlock, vmctxt_interface.VmDatabase)

func NewGenesisMintageSendBlock added in v1.3.0 

func NewGenesisMintageSendBlock(config *config.Genesis) (ledger.AccountBlock, vmctxt_interface.VmDatabase)

func NewGenesisRegisterBlock added in v1.3.0 

func NewGenesisRegisterBlock(config *config.Genesis) (ledger.AccountBlock, vmctxt_interface.VmDatabase)

func NewGenesisSnapshotBlock added in v1.3.0 

func NewGenesisSnapshotBlock() ledger.SnapshotBlock

func NewSecondSnapshotBlock added in v1.3.0 

func NewSecondSnapshotBlock() ledger.SnapshotBlock

Types

type BlockMapQueryParam 

type BlockMapQueryParam struct {
	OriginBlockHash *types.Hash
	Count           uint64
	Forward         bool
}

type Chain 

type Chain interface {
	InsertAccountBlocks(vmAccountBlocks []*vm_context.VmAccountBlock) error
	GetAccountBlocksByHash(addr types.Address, origin *types.Hash, count uint64, forward bool) ([]*ledger.AccountBlock, error)
	GetAccountBlocksByHeight(addr types.Address, start uint64, count uint64, forward bool) ([]*ledger.AccountBlock, error)
	GetAccountBlockMap(queryParams map[types.Address]*BlockMapQueryParam) map[types.Address][]*ledger.AccountBlock
	GetLatestAccountBlock(addr *types.Address) (*ledger.AccountBlock, error)
	GetAccountBalance(addr *types.Address) (map[types.TokenTypeId]*big.Int, error)
	GetAccountBalanceByTokenId(addr *types.Address, tokenId *types.TokenTypeId) (*big.Int, error)
	GetAccountBlockHashByHeight(addr *types.Address, height uint64) (*types.Hash, error)

	GetAllLatestAccountBlock() ([]*ledger.AccountBlock, error)
	GetAccountBlockByHeight(addr *types.Address, height uint64) (*ledger.AccountBlock, error)
	GetAccountBlockByHash(blockHash *types.Hash) (*ledger.AccountBlock, error)
	GetAccountBlocksByAddress(addr *types.Address, index int, num int, count int) ([]*ledger.AccountBlock, error)
	GetFirstConfirmedAccountBlockBySbHeight(snapshotBlockHeight uint64, addr *types.Address) (*ledger.AccountBlock, error)

	GetUnConfirmAccountBlocks(addr *types.Address) []*ledger.AccountBlock
	GetUnConfirmedSubLedger() (map[types.Address][]*ledger.AccountBlock, error)
	GetUnConfirmedPartSubLedger(addrList []types.Address) (map[types.Address][]*ledger.AccountBlock, error)

	DeleteAccountBlocks(addr *types.Address, toHeight uint64) (map[types.Address][]*ledger.AccountBlock, error)
	Init()
	Compressor() *compress.Compressor
	TrieGc() trie_gc.Collector

	StopSaveTrie()
	StartSaveTrie()

	ChainDb() *chain_db.ChainDb
	SaList() *chain_cache.AdditionList

	Start()
	Destroy()
	Stop()
	GenStateTrie(prevStateHash types.Hash, snapshotContent ledger.SnapshotContent) (*trie.Trie, error)
	GetNeedSnapshotContent() ledger.SnapshotContent

	InsertSnapshotBlock(snapshotBlock *ledger.SnapshotBlock) error
	GetAccountBlockMetaByHash(hash *types.Hash) (*ledger.AccountBlockMeta, error)
	GetSnapshotBlocksByHash(originBlockHash *types.Hash, count uint64, forward bool, containSnapshotContent bool) ([]*ledger.SnapshotBlock, error)
	GetSnapshotBlocksByHeight(height uint64, count uint64, forward bool, containSnapshotContent bool) ([]*ledger.SnapshotBlock, error)

	GetSnapshotBlockByHeight(height uint64) (*ledger.SnapshotBlock, error)
	GetSnapshotBlockHeadByHeight(height uint64) (*ledger.SnapshotBlock, error)

	GetSnapshotBlockByHash(hash *types.Hash) (*ledger.SnapshotBlock, error)
	GetSnapshotBlockHeadByHash(hash *types.Hash) (*ledger.SnapshotBlock, error)

	GetLatestSnapshotBlock() *ledger.SnapshotBlock
	GetGenesisSnapshotBlock() *ledger.SnapshotBlock

	NewGenesisSnapshotBlock() ledger.SnapshotBlock
	NewSecondSnapshotBlock() ledger.SnapshotBlock
	NewGenesisMintageBlock() (ledger.AccountBlock, vmctxt_interface.VmDatabase)
	NewGenesisMintageSendBlock() (ledger.AccountBlock, vmctxt_interface.VmDatabase)
	NewGenesisConsensusGroupBlock() (ledger.AccountBlock, vmctxt_interface.VmDatabase)
	NewGenesisRegisterBlock() (ledger.AccountBlock, vmctxt_interface.VmDatabase)

	GetConfirmBlock(accountBlockHash *types.Hash) (*ledger.SnapshotBlock, error)
	GetConfirmTimes(accountBlockHash *types.Hash) (uint64, error)
	GetSnapshotBlockBeforeTime(blockCreatedTime *time.Time) (*ledger.SnapshotBlock, error)
	GetConfirmAccountBlock(snapshotHeight uint64, address *types.Address) (*ledger.AccountBlock, error)
	DeleteSnapshotBlocksToHeight(toHeight uint64) ([]*ledger.SnapshotBlock, map[types.Address][]*ledger.AccountBlock, error)
	GetContractGidByAccountBlock(block *ledger.AccountBlock) (*types.Gid, error)
	GetContractGid(addr *types.Address) (*types.Gid, error)
	GetRegisterList(snapshotHash types.Hash, gid types.Gid) ([]*types.Registration, error)
	GetVoteMap(snapshotHash types.Hash, gid types.Gid) ([]*types.VoteInfo, error)
	KafkaSender() *sender.KafkaSender

	// Pledge amount
	GetPledgeAmount(snapshotHash types.Hash, beneficial types.Address) (*big.Int, error)

	// Pledge quota
	GetPledgeQuota(snapshotHash types.Hash, beneficial types.Address) (uint64, error)
	GetPledgeQuotas(snapshotHash types.Hash, beneficialList []types.Address) (map[types.Address]uint64, error)

	GetConsensusGroupList(snapshotHash types.Hash) ([]*types.ConsensusGroupInfo, error)
	GetBalanceList(snapshotHash types.Hash, tokenTypeId types.TokenTypeId, addressList []types.Address) (map[types.Address]*big.Int, error)

	GetTokenInfoById(tokenId *types.TokenTypeId) (*types.TokenInfo, error)
	AccountType(address *types.Address) (uint64, error)
	GetAccount(address *types.Address) (*ledger.Account, error)
	GetSubLedgerByHeight(startHeight uint64, count uint64, forward bool) ([]*ledger.CompressedFileMeta, [][2]uint64)
	GetSubLedgerByHash(startBlockHash *types.Hash, count uint64, forward bool) ([]*ledger.CompressedFileMeta, [][2]uint64, error)
	GetConfirmSubLedger(fromHeight uint64, toHeight uint64) ([]*ledger.SnapshotBlock, map[types.Address][]*ledger.AccountBlock, error)
	GetVmLogList(logListHash *types.Hash) (ledger.VmLogList, error)
	UnRegister(listenerId uint64)
	TrieDb() *leveldb.DB
	CleanTrieNodePool()
	RegisterInsertAccountBlocks(processor InsertProcessorFunc) uint64
	RegisterInsertAccountBlocksSuccess(processor InsertProcessorFuncSuccess) uint64
	RegisterDeleteAccountBlocks(processor DeleteProcessorFunc) uint64
	RegisterDeleteAccountBlocksSuccess(processor DeleteProcessorFuncSuccess) uint64
	RegisterInsertSnapshotBlocksSuccess(processor InsertSnapshotBlocksSuccess) uint64
	RegisterDeleteSnapshotBlocksSuccess(processor DeleteSnapshotBlocksSuccess) uint64
	GetConfirmSubLedgerBySnapshotBlocks(snapshotBlocks []*ledger.SnapshotBlock) (map[types.Address][]*ledger.AccountBlock, error)

	GetStateTrie(stateHash *types.Hash) *trie.Trie
	ShallowCheckStateTrie(stateHash *types.Hash) (bool, error)
	GenStateTrieFromDb(prevStateHash types.Hash, snapshotContent ledger.SnapshotContent) (*trie.Trie, error)
	NewStateTrie() *trie.Trie

	IsGenesisSnapshotBlock(block *ledger.SnapshotBlock) bool
	IsGenesisAccountBlock(block *ledger.AccountBlock) bool

	// Be
	GetLatestBlockEventId() (uint64, error)
	GetEvent(eventId uint64) (byte, []types.Hash, error)

	// onroad
	IsSuccessReceived(addr *types.Address, hash *types.Hash) bool

	// account block is existed
	IsAccountBlockExisted(hash types.Hash) (bool, error)

	// get receive block heights
	GetReceiveBlockHeights(hash *types.Hash) ([]uint64, error)
	Fti() *chain_index.FilterTokenIndex

	// get on road blocks in a snapshot
	GetOnRoadBlocksBySendAccount(sendAccountAddress *types.Address, snapshotBlockHeight uint64) ([]*ledger.AccountBlock, error)
	GetSendAndReceiveBlocks(accountAddress *types.Address, snapshotBlockHeight uint64) ([]*ledger.AccountBlock, []*ledger.AccountBlock, error)
	// contains filtered or unexported methods
}

func NewChain 

func NewChain(cfg *config.Config) Chain

type DeleteProcessorFunc 

type DeleteProcessorFunc func(batch *leveldb.Batch, subLedger map[types.Address][]*ledger.AccountBlock) error

type DeleteProcessorFuncSuccess 

type DeleteProcessorFuncSuccess func(subLedger map[types.Address][]*ledger.AccountBlock)

type DeleteSnapshotBlocksSuccess 

type DeleteSnapshotBlocksSuccess func([]*ledger.SnapshotBlock)

type InsertProcessorFunc 

type InsertProcessorFunc func(batch *leveldb.Batch, blocks []*vm_context.VmAccountBlock) error

type InsertProcessorFuncSuccess 

type InsertProcessorFuncSuccess func(blocks []*vm_context.VmAccountBlock)

type InsertSnapshotBlocksSuccess 

type InsertSnapshotBlocksSuccess func([]*ledger.SnapshotBlock)

type StateTriePool 

type StateTriePool struct {
	// contains filtered or unexported fields
}

func NewStateTriePool 

func NewStateTriePool(chain *chain) *StateTriePool

func (*StateTriePool) Delete 

func (pool *StateTriePool) Delete(addrList []types.Address)

func (*StateTriePool) Get 

func (pool *StateTriePool) Get(address *types.Address) (*trie.Trie, error)

func (*StateTriePool) Set 

func (pool *StateTriePool) Set(address *types.Address, trie *trie.Trie)

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.