onroad

Documentation

Index

• Constants
• Variables
• type AutoReceiveWorker
  • func NewAutoReceiveWorker(manager *Manager, entropystore string, address types.Address, ...) *AutoReceiveWorker
  • func (w *AutoReceiveWorker) Close() error
  • func (w AutoReceiveWorker) GetEntropystore() string
  • func (w *AutoReceiveWorker) NewOnroadTxAlarm()
  • func (w *AutoReceiveWorker) ProcessOneBlock(sendBlock *ledger.AccountBlock)
  • func (w *AutoReceiveWorker) ResetAutoReceiveFilter(filters map[types.TokenTypeId]big.Int)
  • func (w AutoReceiveWorker) ResetPowDifficulty(powDifficulty *big.Int)
  • func (w *AutoReceiveWorker) Start()
  • func (w AutoReceiveWorker) Status() int
  • func (w *AutoReceiveWorker) Stop()
• type ContractTaskProcessor
  • func NewContractTaskProcessor(worker *ContractWorker, index int) *ContractTaskProcessor
• type ContractWorker
  • func NewContractWorker(manager *Manager) *ContractWorker
  • func (w *ContractWorker) Close() error
  • func (w *ContractWorker) GetPledgeQuota(addr types.Address) uint64
  • func (w *ContractWorker) GetPledgeQuotas(beneficialList []types.Address) map[types.Address]uint64
  • func (w *ContractWorker) Start(accEvent producerevent.AccountStartEvent)
  • func (w ContractWorker) Status() int
  • func (w *ContractWorker) Stop()
  • func (w *ContractWorker) WakeupAllTps()
  • func (w *ContractWorker) WakeupOneTp()
• type Manager
  • func NewManager(net Net, pool Pool, producer Producer, wallet *wallet.Manager) *Manager
  • func (manager Manager) Chain() chain.Chain
  • func (manager *Manager) Close() error
  • func (manager Manager) DbAccess() *model.UAccess
  • func (manager Manager) GetOnroadBlocksPool() *model.OnroadBlocksPool
  • func (manager *Manager) Init(chain chain.Chain)
  • func (manager Manager) ListWorkingAutoReceiveWorker() []types.Address
  • func (manager Manager) Net() Net
  • func (manager Manager) Producer() Producer
  • func (manager *Manager) ResetAutoReceiveFilter(addr types.Address, filter map[types.TokenTypeId]big.Int)
  • func (manager *Manager) Start()
  • func (manager *Manager) StartAutoReceiveWorker(entropystore string, addr types.Address, filter map[types.TokenTypeId]big.Int, ...) error
  • func (manager *Manager) Stop()
  • func (manager *Manager) StopAutoReceiveWorker(addr types.Address) error
• type Net
• type Pool
• type Producer
• type SimpleAutoReceiveFilterPair
• type Worker

Constants

const (
	Create = iota
	Start
	Stop
)

Variables

var (
	POMAXPROCS                = runtime.NumCPU()
	CommonFetchSize           = 4 * POMAXPROCS
	ContractTaskProcessorSize = 2 * POMAXPROCS
	ContractFetchSize         = 2 * POMAXPROCS
)

var (
	ErrNotSyncDone = errors.New("network synchronization is not complete")
)

Types

type AutoReceiveWorker

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

func NewAutoReceiveWorker

func NewAutoReceiveWorker(manager *Manager, entropystore string, address types.Address, filters map[types.TokenTypeId]big.Int, powDifficulty *big.Int) *AutoReceiveWorker

func (*AutoReceiveWorker) Close

func (w *AutoReceiveWorker) Close() error

func (AutoReceiveWorker) GetEntropystore

func (w AutoReceiveWorker) GetEntropystore() string

func (*AutoReceiveWorker) NewOnroadTxAlarm

func (w *AutoReceiveWorker) NewOnroadTxAlarm()

func (*AutoReceiveWorker) ProcessOneBlock

func (w *AutoReceiveWorker) ProcessOneBlock(sendBlock *ledger.AccountBlock)

func (*AutoReceiveWorker) ResetAutoReceiveFilter

func (w *AutoReceiveWorker) ResetAutoReceiveFilter(filters map[types.TokenTypeId]big.Int)

func (AutoReceiveWorker) ResetPowDifficulty

func (w AutoReceiveWorker) ResetPowDifficulty(powDifficulty *big.Int)

func (*AutoReceiveWorker) Start

func (w *AutoReceiveWorker) Start()

func (AutoReceiveWorker) Status

func (w AutoReceiveWorker) Status() int

func (*AutoReceiveWorker) Stop

func (w *AutoReceiveWorker) Stop()

type ContractTaskProcessor

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

func NewContractTaskProcessor

func NewContractTaskProcessor(worker *ContractWorker, index int) *ContractTaskProcessor

type ContractWorker

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

func NewContractWorker

func NewContractWorker(manager *Manager) *ContractWorker

func (*ContractWorker) Close

func (w *ContractWorker) Close() error

func (*ContractWorker) GetPledgeQuota

func (w *ContractWorker) GetPledgeQuota(addr types.Address) uint64

func (*ContractWorker) GetPledgeQuotas

func (w *ContractWorker) GetPledgeQuotas(beneficialList []types.Address) map[types.Address]uint64

func (*ContractWorker) Start

func (w *ContractWorker) Start(accEvent producerevent.AccountStartEvent)

func (ContractWorker) Status

func (w ContractWorker) Status() int

func (*ContractWorker) Stop

func (w *ContractWorker) Stop()

func (*ContractWorker) WakeupAllTps

func (w *ContractWorker) WakeupAllTps()

func (*ContractWorker) WakeupOneTp

func (w *ContractWorker) WakeupOneTp()

type Manager

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

func NewManager

func NewManager(net Net, pool Pool, producer Producer, wallet *wallet.Manager) *Manager

func (Manager) Chain

func (manager Manager) Chain() chain.Chain

func (*Manager) Close

func (manager *Manager) Close() error

func (Manager) DbAccess

func (manager Manager) DbAccess() *model.UAccess

func (Manager) GetOnroadBlocksPool

func (manager Manager) GetOnroadBlocksPool() *model.OnroadBlocksPool

func (*Manager) Init

func (manager *Manager) Init(chain chain.Chain)

func (Manager) ListWorkingAutoReceiveWorker

func (manager Manager) ListWorkingAutoReceiveWorker() []types.Address

func (Manager) Net

func (manager Manager) Net() Net

func (Manager) Producer

func (manager Manager) Producer() Producer

func (*Manager) ResetAutoReceiveFilter

func (manager *Manager) ResetAutoReceiveFilter(addr types.Address, filter map[types.TokenTypeId]big.Int)

func (*Manager) Start

func (manager *Manager) Start()

func (*Manager) StartAutoReceiveWorker

func (manager *Manager) StartAutoReceiveWorker(entropystore string, addr types.Address, filter map[types.TokenTypeId]big.Int, powDifficulty *big.Int) error

func (*Manager) Stop

func (manager *Manager) Stop()

func (*Manager) StopAutoReceiveWorker

func (manager *Manager) StopAutoReceiveWorker(addr types.Address) error

type Net

type Net interface {
	SubscribeSyncStatus(fn func(net.SyncState)) (subId int)
	UnsubscribeSyncStatus(subId int)
	SyncState() net.SyncState
}

type Pool

type Pool interface {
	ExistInPool(address types.Address, fromBlockHash types.Hash) bool
	AddDirectAccountBlock(address types.Address, vmAccountBlock *vm_context.VmAccountBlock) error
	AddDirectAccountBlocks(address types.Address, received *vm_context.VmAccountBlock, sendBlocks []*vm_context.VmAccountBlock) error
}

type Producer

type Producer interface {
	SetAccountEventFunc(func(producerevent.AccountEvent))
}

type SimpleAutoReceiveFilterPair

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

type Worker

type Worker interface {
	Status() int
	Start()
	Stop()
	Close() error
}