Documentation
¶
Index ¶
Constants ¶
View Source
const ( ProtocolVersion = 0 HandshakeTimeout = 2 MinConnectionCount = 3 KeepAliveTimeout = 30 DialTimeout = 6 SyncBlockTimeout = 10 HeartbeatDuration = 6 MaxSyncHdrReq = 2 //Max Concurrent Sync Header Request MaxOutBoundCount = 8 DefaultMaxPeers = 125 MaxIdCached = 5000 )
View Source
const (
OpenService = 1 << 2
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Noder ¶
type Noder interface {
Version() uint32
ID() uint64
Services() uint64
Addr() string
Addr16() ([16]byte, error)
NetAddress() p2p.NetAddress
Port() uint16
IsExternal() bool
HttpInfoPort() int
SetHttpInfoPort(uint16)
SetState(state uint)
State() uint
IsRelay() bool
Heartbeat()
AddNeighborNode(Noder)
DelNeighborNode(id uint64) (Noder, bool)
Height() uint64
GetConn() net.Conn
CloseConn()
AddToHandshakeQueue(addr string, node Noder)
RemoveFromHandshakeQueue(node Noder)
GetConnectionCount() (uint, uint)
GetTransactionPool(bool) map[common.Uint256]*core.Transaction
AppendToTxnPool(*core.Transaction) errors.ErrCode
IsDuplicateSidechainTx(sidechainTxHash common.Uint256) bool
ExistedID(id common.Uint256) bool
RequireNeighbourList()
UpdateInfo(t time.Time, version uint32, services uint64,
port uint16, nonce uint64, relay uint8, height uint64)
UpdateMsgHelper(handler p2p.MsgHandler)
ConnectNodes()
Connect(nodeAddr string) error
LoadFilter(filter *msg.FilterLoad)
BloomFilter() *bloom.Filter
Send(msg p2p.Message)
GetTime() int64
NodeEstablished(uid uint64) bool
GetTransaction(hash common.Uint256) *core.Transaction
IncRxTxnCnt()
GetTxnCnt() uint64
GetRxTxnCnt() uint64
GetNeighborNodes() []Noder
GetNeighbourAddresses() []p2p.NetAddress
WaitForSyncFinish()
CleanSubmittedTransactions(block *core.Block) error
MaybeAcceptTransaction(txn *core.Transaction) error
RemoveTransaction(txn *core.Transaction)
UpdateLastActive()
SetHeight(height uint64)
Relay(Noder, interface{}) error
IsSyncHeaders() bool
SetSyncHeaders(b bool)
IsRequestedBlock(hash common.Uint256) bool
AddRequestedBlock(hash common.Uint256)
DeleteRequestedBlock(hash common.Uint256)
GetRequestBlockList() map[common.Uint256]time.Time
AcqSyncBlkReqSem()
RelSyncBlkReqSem()
SetStartHash(hash common.Uint256)
GetStartHash() common.Uint256
SetStopHash(hash common.Uint256)
GetStopHash() common.Uint256
ResetRequestedBlock()
}
Click to show internal directories.
Click to hide internal directories.