model

Feb 28, 2019

Changes in this version

type OnroadAccountInfo

+ Mutex sync.RWMutex

Jan 10, 2019

Changes in this version

+ type ContractCallerList struct

+ func (cList *ContractCallerList) AddNewTx(block *ledger.AccountBlock)

+ func (cList *ContractCallerList) AddTotalNum()

+ func (cList *ContractCallerList) GetCurrentIndex() int

+ func (cList *ContractCallerList) GetNextTx() *ledger.AccountBlock

+ func (cList *ContractCallerList) Len() int

+ func (cList *ContractCallerList) SubTotalNum()

+ func (cList *ContractCallerList) TxRemain() int

type OnroadBlocksPool

+ func (p *OnroadBlocksPool) AcquireOnroadSortedContractCache(addr types.Address)

+ func (p *OnroadBlocksPool) DeleteContractCache(gid types.Gid)

+ func (p *OnroadBlocksPool) GetContractCallerList(addr types.Address) *ContractCallerList

+ func (p *OnroadBlocksPool) GetNextContractTx(addr types.Address) *ledger.AccountBlock

+ func (p *OnroadBlocksPool) ReleaseContractCache(addr types.Address)

Dec 8, 2018

Changes in this version

+ const MaxReceiveErrCount

+ func AddrListDbDeserialize(buf []byte) ([]types.Address, error)

+ func AddrListDbSerialize(addrList []types.Address) ([]byte, error)

+ type OnroadAccountInfo struct

+ AccountAddress *types.Address

+ TokenBalanceInfoMap map[types.TokenTypeId]*TokenBalanceInfo

+ TotalNumber uint64

+ type OnroadBlocksPool struct

+ func NewOnroadBlocksPool(dbAccess *UAccess) *OnroadBlocksPool

+ func (p *OnroadBlocksPool) AcquireFullOnroadBlocksCache(addr types.Address)

+ func (p *OnroadBlocksPool) AddCommonTxLis(addr types.Address, f func())

+ func (p *OnroadBlocksPool) AddContractLis(gid types.Gid, f func(address types.Address))

+ func (p *OnroadBlocksPool) Close() error

+ func (p *OnroadBlocksPool) DeleteDirect(sendBlock *ledger.AccountBlock) error

+ func (p *OnroadBlocksPool) GetNextCommonTx(addr types.Address) *ledger.AccountBlock

+ func (p *OnroadBlocksPool) GetOnroadAccountInfo(addr types.Address) (*OnroadAccountInfo, error)

+ func (p *OnroadBlocksPool) NewSignalToWorker(block *ledger.AccountBlock)

+ func (p *OnroadBlocksPool) ReleaseFullOnroadBlocksCache(addr types.Address) error

+ func (p *OnroadBlocksPool) RemoveCommonTxLis(addr types.Address)

+ func (p *OnroadBlocksPool) RemoveContractLis(gid types.Gid)

+ func (p *OnroadBlocksPool) ResetCacheCursor(addr types.Address)

+ func (p *OnroadBlocksPool) RevertOnroad(batch *leveldb.Batch, subLedger map[types.Address][]*ledger.AccountBlock) error

+ func (p *OnroadBlocksPool) RevertOnroadSuccess(subLedger map[types.Address][]*ledger.AccountBlock)

+ func (p *OnroadBlocksPool) WriteOnroad(batch *leveldb.Batch, blockList []*vm_context.VmAccountBlock) error

+ func (p *OnroadBlocksPool) WriteOnroadSuccess(blocks []*vm_context.VmAccountBlock)

+ type OnroadMeta struct

+ Address types.Address

+ Gid []byte

+ Hash types.Hash

+ type OnroadSet struct

+ func NewOnroadSet(chain chain.Chain) *OnroadSet

+ func (ucf *OnroadSet) DecreaseReceiveErrCount(batch *leveldb.Batch, hash *types.Hash, addr *types.Address) error

+ func (ucf *OnroadSet) DeleteMeta(batch *leveldb.Batch, addr *types.Address, hash *types.Hash) error

+ func (ucf *OnroadSet) DeleteReceiveErrCount(batch *leveldb.Batch, hash *types.Hash, addr *types.Address) error

+ func (ucf *OnroadSet) GetContractAddrList(gid *types.Gid) ([]types.Address, error)

+ func (ucf *OnroadSet) GetCountByAddress(addr *types.Address) (count uint64, err error)

+ func (ucf *OnroadSet) GetHashList(addr *types.Address) (hashs []*types.Hash, err error)

+ func (ucf *OnroadSet) GetHashsByCount(count uint64, addr *types.Address) (hashs []*types.Hash, err error)

+ func (ucf *OnroadSet) GetReceiveErrCount(hash *types.Hash, addr *types.Address) (uint8, error)

+ func (ucf *OnroadSet) IncreaseReceiveErrCount(batch *leveldb.Batch, hash *types.Hash, addr *types.Address) error

+ func (ucf *OnroadSet) WriteGidAddrList(batch *leveldb.Batch, gid *types.Gid, addrList []types.Address) error

+ func (ucf *OnroadSet) WriteMeta(batch *leveldb.Batch, addr *types.Address, hash *types.Hash) error

+ type TokenBalanceInfo struct

+ Number uint64

+ TotalAmount big.Int

+ type UAccess struct

+ Chain chain.Chain

+ func NewUAccess() *UAccess

+ func (access *UAccess) DeleteContractAddrFromGid(batch *leveldb.Batch, gid types.Gid, address types.Address) error

+ func (access *UAccess) GetAllOnroadBlocks(addr types.Address) (blockList []*ledger.AccountBlock, err error)

+ func (access *UAccess) GetCommonAccInfo(addr *types.Address) (info *OnroadAccountInfo, err error)

+ func (access *UAccess) GetCommonAccTokenInfoMap(addr *types.Address) (map[types.TokenTypeId]*TokenBalanceInfo, uint64, error)

+ func (access *UAccess) GetContractAddrListByGid(gid *types.Gid) ([]types.Address, error)

+ func (access *UAccess) GetOnroadBlocks(index, num, count uint64, addr *types.Address) (blockList []*ledger.AccountBlock, err error)

+ func (access *UAccess) GetOnroadHashs(index, num, count uint64, addr *types.Address) ([]*types.Hash, error)

+ func (access *UAccess) Init(chain chain.Chain)

+ func (access *UAccess) IsSuccessReceived(addr *types.Address, hash *types.Hash) bool

+ func (access *UAccess) WriteContractAddrToGid(batch *leveldb.Batch, gid types.Gid, address types.Address) error