repairWalFile decodes messages from src (until the decoder errors) and writes them to dst.

console function for parsing input and running commands

Request specific callback that should be set on individual reqRes objects to incorporate local information when processing the response. This allows u

requestChunk requests a chunk from a peer.

Responsible for making more requests as necessary Returns only when a block is found (e.g. AddBlock() is called)

callback, which is called after the app checked the tx for the first time. The case where the app checks the tx for the second and subsequent times i

callback, which is called after the app rechecked the tx. The case where the app checks the tx for the first time is handled by the resCbFirstTime ca

----------------------------------------

This is called from the requestRoutine, upon redo().

resetDB drops all the data from the test database.

resolve resolves a set of peer addresses into PEX addresses. FIXME: This is necessary because the current PEX protocol only supports IP/port pairs, w

respondToPeer loads a block and sends it to the requesting peer, if we have it. Otherwise, we'll respond saying we do not have it.

restoreTrustedLightBlock loads the latest trusted light block from the store

Try to resubscribe with exponential backoff.

retryUntil will continue to evaluate fn and will return successfully when true or fail when the timeout is reached.

deletes conn even if close errs

routeChannel receives outbound channel messages and routes them to the appropriate peer. It also receives peer errors and reports them to the peer man

rpcEndpoints takes a list of persistent peers and splits them into a list of rpc endpoints using 26657 as the port number

run runs the application - basically like main() with error handling.

saveMetadata saves snapshot metadata. Does not take out locks, since it's called internally from e.g. Create().

Periodically saves the trust history data to the DB

scanNumber scans for numbers with optional fractional parts. Examples: 0, 1, 3.14

schedule works out the next height to attempt sequential verification

Queues message to send to this channel. Goroutine-safe Times out (and returns false) after defaultSendTimeout

Returns true if messages from channels were exhausted.

sendPeer sends queued messages to a peer.

sendRequestForPeers pops the first peerID off the list and sends the peer a request for more peer addresses. The function then moves the peer into the

----------------------------------------

sendRoutine polls for packets to send from channels.

Returns true if the peer matches and block doesn't already exist.

launch unix and tcp servers

signProposal checks if the proposal is good to sign and sets the proposal signature. It may need to set the timestamp as well if the proposal is other

------------------------------------------------------------------------------------ signVote checks if the vote is good to sign and sets the vote sig

Request desired, pretend like we got the block immediately.