node

Apr 26, 2018

Changes in this version

type TXNPool

+ func (this *TXNPool) AppendToTxnPool(txn *transaction.Transaction) ErrCode

Dec 21, 2017

Changes in this version

+ func InitNode(pubKey *crypto.PubKey) Noder

+ func NewNode() *node

+ func NonTLSDial(nodeAddr string) (net.Conn, error)

+ func TLSDial(nodeAddr string) (net.Conn, error)

+ type ConnectingNodes struct

+ ConnectingAddrs []string

+ type KnownAddress struct

+ func (ka *KnownAddress) GetID() uint64

+ func (ka *KnownAddress) LastAttempt() time.Time

+ func (ka *KnownAddress) NetAddress() NodeAddr

+ func (ka *KnownAddress) SaveAddr(na NodeAddr)

+ type KnownAddressList struct

+ List map[uint64]*KnownAddress

+ func (al *KnownAddressList) AddAddressToKnownAddress(na NodeAddr)

+ func (al *KnownAddressList) AddressExisted(uid uint64) bool

+ func (al *KnownAddressList) DelAddressFromList(id uint64) bool

+ func (al *KnownAddressList) GetAddressCnt() uint64

+ func (al *KnownAddressList) NeedMoreAddresses() bool

+ func (al *KnownAddressList) RandGetAddresses(nbrAddrs []NodeAddr) []NodeAddr

+ func (al *KnownAddressList) RandSelectAddresses() []NodeAddr

+ func (al *KnownAddressList) UpdateAddress(id uint64, na NodeAddr)

+ func (al *KnownAddressList) UpdateLastDisconn(id uint64)

+ type RetryConnAddrs struct

+ RetryAddrs map[string]int

+ type Semaphore chan struct

+ func MakeSemaphore(n int) Semaphore

+ type TXNPool struct

+ func (this *TXNPool) AppendTxnPool(txn *transaction.Transaction) ErrCode

+ func (this *TXNPool) CleanSubmittedTransactions(block *ledger.Block) error

+ func (this *TXNPool) GetTransaction(hash common.Uint256) *transaction.Transaction

+ func (this *TXNPool) GetTransactionCount() int

+ func (this *TXNPool) GetTxnPool(byCount bool) map[common.Uint256]*transaction.Transaction

+ func (this *TXNPool) MaybeAcceptTransaction(txn *tx.Transaction) error

+ func (this *TXNPool) RemoveTransaction(txn *tx.Transaction)