nextPeerID returns the next unused peer ID to use. We assume that the mutex is already held.

nextTwo returns the next two unverified blocks

nextUp returns the next chunk to be returned, or errDone if all chunks have been returned. The caller must hold the mutex lock.

nodeHasSomePeersOrDialingAny returns true if the node is connected to some peers or dialing them currently.

onReceive is a callback for MConnection received messages.

optimize optimizes operations by pregenerating lookup structures. It's a separate method instead of memoizing during calls to avoid dealing with concu

1KB at a time Parse command-line options

peerAddressInfoFromProto converts a Protobuf PeerAddressInfo message to a peerAddressInfo.

peerInfoFromProto converts a Protobuf PeerInfo message to a peerInfo, erroring if the data is invalid.

percentOf calculates what percent of the total is x.

get an array of persistent peers

Pick an available peer with the given height available. If no peers are available, returns nil.

process starts a blocking WDRR scheduler process, where we continuously evaluate if we need to attempt to enqueue an Envelope or schedule Envelopes to

processBlockCh initiates a blocking process where we listen for and handle envelopes on the LightBlockChannel.

processBlockSyncCh initiates a blocking process where we listen for and handle envelopes on the BlockSyncChannel and blockSyncOutBridgeCh. Any error e

Checks changes against duplicates, splits the changes in updates and removals, sorts them by address. Returns: updates, removals - the sorted lists o

processChunkCh initiates a blocking process where we listen for and handle envelopes on the ChunkChannel.

processConsensusBuffer converts all the duplicate votes witnessed from consensus into DuplicateVoteEvidence. It sets the evidence timestamp to the blo

processDataCh initiates a blocking process where we listen for and handle envelopes on the DataChannel. Any error encountered during message execution

processEvidenceCh implements a blocking event loop where we listen for p2p Envelope messages from the evidenceCh.

processMempoolCh implements a blocking event loop where we listen for p2p Envelope messages from the mempoolCh.

processMempoolCh implements a blocking event loop where we listen for p2p Envelope messages from the mempoolCh.

processMessages processes messages received from the connection.

processPeerUpdate processes a PeerUpdate. For added peers, PeerStatusUp, we check if the reactor is running and if we've already started a tx broadcas

processPeerUpdate processes a PeerUpdate. For added peers, PeerStatusUp, we check if the reactor is running and if we've already started a tx broadcas

processPeerUpdate processes a PeerUpdate, returning an error upon failing to handle the PeerUpdate or if a panic is recovered.

processPeerUpdate processes a PeerUpdate. For added peers, PeerStatusUp, we send a request for addresses.

processPeerUpdate processes a PeerUpdate. For new or live peers it will check if an evidence broadcasting goroutine needs to be started. For down or r

processPeerUpdate process a peer update message. For new or reconnected peers, we create a peer state if one does not exist for the peer, which should

processPeerUpdate processes a PeerUpdate.

processPeerUpdates initiates a blocking process where we listen for and handle PeerUpdate messages. When the reactor is stopped, we will catch the sig

processPeerUpdates initiates a blocking process where we listen for and handle PeerUpdate messages. When the reactor is stopped, we will catch the sig

processPeerUpdates initiates a blocking process where we listen for and handle PeerUpdate messages. When the reactor is stopped, we will catch the sig

processPeerUpdates initiates a blocking process where we listen for and handle PeerUpdate messages. When the reactor is stopped, we will catch the sig

processPeerUpdates initiates a blocking process where we listen for and handle PeerUpdate messages. When the reactor is stopped, we will catch the sig

processPeerUpdates initiates a blocking process where we listen for and handle PeerUpdate messages. When the reactor is stopped, we will catch the sig

processPeerUpdates initiates a blocking process where we listen for and handle PeerUpdate messages. When the reactor is stopped, we will catch the sig

processPexCh implements a blocking event loop where we listen for p2p Envelope messages from the pexCh.

* Private methods */ This method is for a goroutine that handles all requests on the metric

processSnapshotCh initiates a blocking process where we listen for and handle envelopes on the SnapshotChannel.

processStateCh initiates a blocking process where we listen for and handle envelopes on the StateChannel. Any error encountered during message executi

processVoteCh initiates a blocking process where we listen for and handle envelopes on the VoteChannel. Any error encountered during message execution

processVoteCh initiates a blocking process where we listen for and handle envelopes on the VoteSetBitsChannel. Any error encountered during message ex

proxyPeerEnvelopes iterates over each p2p Channel and starts a separate go-routine where we listen for outbound envelopes sent during Receive executio

pruneABCIResponses calls a reverse iterator from base height to retain height batch deleting all abci responses in between

pruneConsensusParams calls a reverse iterator from base height to retain height batch deleting all consensus params in between. If the consensus param

pruneValidatorSets calls a reverse iterator from base height to retain height (exclusive), deleting all validator sets in between. Due to the fact tha

purgeExpiredTxs removes all transactions from the mempool that have exceeded their respective height or time-based limits as of the given blockHeight.

NOTE: `queryMaj23Routine` has a simple crude design since it only comes into play for liveness when there's a signature DDoS attack happening.

This only uses the OS's randomness

The client ensures that there is at most one reader to a connection by executing all reads from this goroutine.

Read from the socket and subscribe to or unsubscribe from events

readSchema loads the indexing database schema file

Command line argument processing

Reads the settings from environment variables

Reads the settings from the digital_ocean.ini file

receivePeer receives inbound messages from a peer, deserializes them and passes them on to the appropriate channel.

enforces a minimum amount of time between requests

recentSnapshots fetches the n most recent snapshots from the app

recheckTransactions initiates re-CheckTx ABCI calls for all the transactions currently in the mempool. It reports the number of recheck calls that wer

Handles incoming PacketMsgs. It returns a message bytes if message is complete, which is owned by the caller and will not be modified. Not goroutine-s

recvRoutine reads PacketMsgs and reconstructs the message using the channels' "recving" buffer. After a whole message has been assembled, it's pushed

Tells bpRequester to pick another peer and try again. NOTE: Nonblocking, and does nothing if another redo was already requested.

registers the given type with the given name. The name and type must not be registered already.