blocksync

package
v0.0.0-...-c9d2d86 Latest Latest
Warning

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

Go to latest
Published: May 25, 2018 License: ISC Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func GetSyncWorkers

func GetSyncWorkers(workerNums int, bc *blockchain.Blockchain) []mpool.VmWorker

Types

type SyncWorker

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

func NewSyncWorker

func NewSyncWorker(ledger *ledger.Ledger, bc *blockchain.Blockchain) *SyncWorker

func (*SyncWorker) OnBlock

func (worker *SyncWorker) OnBlock(workerData *types.WorkerData)

func (*SyncWorker) OnGetBlocks

func (worker *SyncWorker) OnGetBlocks(workerData *types.WorkerData)

func (*SyncWorker) OnGetData

func (worker *SyncWorker) OnGetData(workerData *types.WorkerData)

func (*SyncWorker) OnGetInv

func (worker *SyncWorker) OnGetInv(workerData *types.WorkerData)

func (*SyncWorker) OnStatus

func (worker *SyncWorker) OnStatus(workerData *types.WorkerData)

func (*SyncWorker) OnTransaction

func (worker *SyncWorker) OnTransaction(workerData *types.WorkerData)

func (*SyncWorker) SendMsg

func (worker *SyncWorker) SendMsg(peer *peer.Peer, protoID proto.ProtoID, msgID proto.MsgType, imsg proto.IMsg) error

func (*SyncWorker) VmJob

func (worker *SyncWorker) VmJob(data interface{}) (interface{}, error)

func (*SyncWorker) VmReady

func (worker *SyncWorker) VmReady() bool

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL