*************************************************************** Checkpoint DBKeyMR***************************************************************.

Sig is signed message, msg is raw message.

return a (possibly empty) of coinbase payouts to be scheduled at this height.

Return the Hard Coded Grants.

put a height in the first 5 bytes of a hash so we can use it to look up dependent message in holding.

This function will be replaced by a calculation from the Matryoshka hashes from the servers but for now, we are just going to make it a function of the dbheight.

Remember that Unix time is in seconds since 1970.

NewEntrySync creates a new EntrySync.

NewMissingState creates a new MissingState for the DBState at a specific height.

NewRateCalculatorTime is good for unit tests, or if you want to change the measureing time.

NewReceivedState creates a new member for the StatesReceived list.

NewStatesMissing creates a new list of missing DBStates.

NonBlockingChannelAdd will only add to the channel if the action is non-blocking.

Called by AddServer Message.

RegisterPrometheus registers the variables to be exposed.

BATCH_SIZE is the amount of blocks per torrent.

Double this for the period we protect, i.e.

Queues.

good-ish value.

EntrySyncMaxEBlocks is the maximum amount of eblocks to process concurrently.

EntrySyncRetry dictates after what period to retry an unanswered request.

EntrySyncWarning is the number of failed requests before warning in the console.

Entry Syncing Controller.

Filter hold two hours of messages, one in the past one in the future.

Executions.

Eom/DBSig delay.

Where all Identities register.

Used by debug code only.

Time window for identity to require registration: 24hours = 144 blocks.

Acks Queue.

Commits map.

Holding Queue.

MsgQueue chan.

ProcessList.

Durations.

TPS.

XReview Queue.

map of the last N Acks indexed by height.

CrossReplayFilter checks for old messages across reboots based on the salts inside the ack messages.

Data needed to add to admin block.

This struct will contain all information wanted by the control panel from the state.

EntrySync is responsible for sending the requests to fetch missing entries to the network.

This hold a slice of messages dependent on a hash.

MissingMessageResponseCache will cache all processlist items from the last 2 blocks.

MissingState is information about a DBState that is known to exist but is not available on the current node.

map of the last N messages indexed by hash.

The pair of messages for a missing message response.

RateCalculator will maintain the rate of msgs arriving and rate of msgs leaving a queue.

ReceivedState represents a DBStateMsg received from the network.

Keep the history last N acks and Ackable messages.

SafeMsgMap is a threadsafe map[[32]byte]interfaces.IMsg.

Because we have to go back to a previous state should the network be partitioned and we are on a separate branch, we need to log our state periodically so we can reset to a state prior to the network partition.

StatesReceived is the list of DBStates received from the network.

Controls the flow of uploading torrents.

IPrometheusRateMethods indicated which prometheus counters/gauges to set.