Private methods

offerSnapshot offers a snapshot to the app. It returns various errors depending on the app's response, or nil if the snapshot was accepted.

parseCond parses a conditional expression: tag OP value.

parseRPCError process the error and return the corresponding error to the light clent NOTE: When an error is sent over the wire it gets "flattened" he

parseTx parses a tx in 'key=value' format into a key and value.

parseValueFromKey parses an event key and extracts out the value, returning an error if one arises. This will also involve ensuring that the key has t

Generates new Args array based off of previous call args to maintain flag persistence

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

poolRoutine handles messages from the poolReactor telling the reactor what to do. NOTE: Don't sleep in the FOR_LOOP or otherwise slow it down!

a small utility function for getting a keys prefix based on a condition and a height

########################## Keys ############################# The indexer has two types of kv stores: 1. txhash - result (primary key) 2. event -

process starts a block process where we listen for Envelopes to enqueue. If there is sufficient capacity, it will be enqueued into the priority queue,

Calculates the current score for good/bad experiences

prunePeers removes low-scored peers from the peer store if it contains more than MaxPeers peers. The caller must hold the mutex lock.

nPeers = nValidators + nNotValidator

----------------------------------------- the main go routines receiveRoutine handles messages which may cause state transitions. it's argument (n) is

reconnect tries to redial up to maxReconnectAttempts with exponential backoff.

Reconstruct LastCommit from SeenCommit, which we saved along with the block, (which happens even before saving the state)

After being reconnected, it is necessary to redo subscription to server otherwise no data will be automatically received.

removePeer removes a peer. The caller must hold the mutex lock.

removeTxByKey removes the specified transaction key from the mempool. The caller must hold txmp.mtx excluxively.

go back count steps by resetting the state and running (pb.count - count) steps

reset clears the current sample state in preparation for the next sample.

resetAllCmd removes address book files plus all data, and resets the privValidator data.

resetState removes address book files plus all databases.

retryDelay calculates a dial retry delay using exponential backoff, based on retry settings in PeerManagerOptions. If retries are disabled (i.e. MinRe

reverseBatchDelete runs a reverse iterator (from end to start) filling up a batch until either (a) the iterator reaches the start or (b) the iterator

routePeer routes inbound and outbound messages between a peer and the reactor channels. It will close the given connection and send queue when done, o

rpcClient sets up a new RPC client

runInTransaction executes query in a fresh database transaction. If query reports an error, the transaction is rolled back and the error from query is

---------------------------------------- safe addition/subtraction/multiplication

save saves the state to disk. It does not take out a lock since it is called internally by Commit which does lock.

saveConsensusParamsInfo persists the consensus params for the next block to disk. It should be called from s.Save(), right before the state itself is

Persist height/round/step and signature

enterNewRound(height, 0) at cs.StartTime.

The event/secondary key

sendEvidence sends evidence to a provider on a best effort basis.

Serialize signature to R || S. R, S are padded to 32 bytes respectively.

signHeader properly signs the header with all keys from first to last exclusive.

Read Signature struct from R || S. Caller needs to ensure that len(sigStr) == 64.

* Private methods */ size returns the number of entries in the store without acquiring the mutex

startSync begins a block sync, signaled by r.events being non-nil. If state is non-nil, the scheduler and processor is updated with this state on star

statusesAreEqual returns true if s1 is equal to s2. Equality here means general equality of fields except for the duration and rates, which can drift

stopServices stops the BaseService and timers and closes the quitSendRoutine. if the quitSendRoutine was already closed, it returns true, otherwise it

testFreeAddr claims a free port so we don't block on listener being ready.

---------------------------------------------------------------- rand node info