DialPeerWithAddress dials the given peer and runs sw.addPeer if it connects and authenticates successfully. If we're currently dialing this address or

Discard discards a chunk. It will be removed from the queue, available for allocation, and can be added and returned via Next() again. If the chunk is

GenPrivKeyFromSecret hashes the secret with SHA2, and uses that 32 byte output to create the private key. NOTE: secret should be the output of a KDF l

GetChannels returns the list of MConnection.ChannelDescriptor. Make sure that each ID is unique across all the reactors added to the switch.

Send a selection of addresses to peers

Hash returns the hash of the header and the commonHeight. This is designed to cause hash collisions with evidence that have the same conflicting heade

MakeChannelsNoCleanup makes a channel on all nodes and returns them, automatically doing error checks. The caller must ensure proper cleanup of all th

-------------------------------------------------------------------------------- Commit MakeCommit constructs a Commit from the VoteSet. It only inclu

MakeSecretConnection performs handshake and returns a new authenticated SecretConnection. Returns nil if there is an error in handshake. Caller should

Pick an address to dial

PostCheckMaxGas checks that the wanted gas is smaller or equal to the passed maxGas. Returns nil if maxGas is -1.

Propose returns the amount of time to wait for a proposal

Prune removes headers & the associated validator sets when Store reaches a defined size (number of header & validator set pairs).

Ranked returns a list of peers ordered by score (better peers first). Peers with equal scores are returned in an arbitrary order. The returned list mu

Returns info after scanning all files in g.Head's dir.

ReadMessage reads a varint length-delimited protobuf message.

ReapMaxTxs reaps up to max transactions from the mempool. If max is negative, there is no cap on the size of all returned transactions (~ all availabl

Routable returns true if the address is routable.

Shutdown will kill the test harness and attempt to close all open sockets gracefully. If the supplied error is nil, it is assumed that the exit code s

Unwrap will unwrap the inner message contained in this message.

Update attempts to advance the state by downloading the latest light block and verifying it. It returns a new light block on a successful update. Othe

ValidateHash returns an error if the hash is not empty, but its size != tmhash.Size.

LIGHT CLIENT VERIFICATION METHODS VerifyCommitLight verifies +2/3 of the set had signed the given commit.

Wrap will take a message and wrap it in this one if possible.

WriteMessage writes a varint length-delimited protobuf message.

checkScResults checks scheduler handler test results

Get JSON from DigitalOcean API

newSnapshotPool creates a new empty snapshot pool.

setup setups a test suite with a network of nodes. Mocknodes represent the hollow nodes that the test can listen and send on

sign the vote and publish on internalMsgQueue

starts up the pex reactors for each node

trails[0].Hash is the leaf hash for items[0]. trails[i].Parent.Parent....Parent == root for all i.

Reading from abci app

Advertise returns a list of peer addresses to advertise to a peer. It sorts all peers in the peer store, and assembles a list of peers that is most l

ApplyBlock validates the block against the state, executes it against the app, fires the relevant events, commits the app, and saves the new state and

DefaultConfig returns a config with values that have been tested and produce desirable results

DialNext finds an appropriate peer address to dial, and marks it as dialing. If no peer is found, or all connection slots are full, it blocks until on

ForBlock returns true if CommitSig is for the block.

------------------------------------------------------------ Make genesis state from file GenesisDocFromJSON unmarshalls JSON data into a GenesisDoc.

IsComplete returns true if this is a valid BlockID of a non-nil block.

IsVoteTypeValid returns true if t is a valid vote type.

LightBlock returns the LightBlock that corresponds to the given height. 0 - the latest. height must be >= 0. If the provider fails to fetch the Ligh

LoadABCIResponses loads the abciResponse for a given height

LoadConsensusParams loads the consensus params for a given height

Marshal needed for protobuf compatibility

NewMConnTransport sets up a new MConnection transport. This uses the proprietary Tendermint MConnection protocol, which is implemented as conn.MConnec

NewTxIndex creates new KV indexer.

NextInterval manually sends Time on the ticker channel

NextWaitChan can be used to wait until Next becomes not nil. Once it does, channel will be closed.

OpenChannel opens a new channel for the given message type. The caller must close the channel when done, before stopping the Router. messageType is th

Peers returns all known peers, primarily for testing. The order is arbitrary.

PrepareBaseCmd is meant for tendermint and other servers

PruneBlocks removes block up to (but not including) a height. It returns the number of blocks pruned.

ReapMaxBytesMaxGas reaps transactions from the mempool up to maxBytes bytes total with the condition that the total gasWanted must be less than maxGas

RemovePeer is called by the switch when the peer is stopped (due to error or other reason).

SendMessage sends a message on the connection. Returns io.EOF if closed. FIXME: For compatibility with the legacy P2P stack, it returns an additional

Implements PrivValidator.