Messages returns the que of messages. The message que get's filled after processing a protocol message. After calling this method the que will be empt

len return the current length of the buffer.

NewRBC returns a new instance of the ReliableBroadcast configured with the given config

HandleMessage will process the given rpc message. The caller is resposible to make sure only RPC messages are passed that are elligible for the BBA pr

NewLocalTransport returns a new LocalTransport.

Output will return the output of the ACS instance. If the output was not nil then it will return the output else nil. Note that after consuming the ou

Consume returns a channel used for consuming and responding to RPC requests.

InputValue will set the given val as the initial value to be proposed in the Agreement and returns an initial AgreementMessage or an error.

NewACS returns a new ACS instance configured with the given Config and node ids.

NewBBA returns a new instance of the Binary Byzantine Agreement.

Output will return the output of the bba instance. If the output was not nil then it will return the output else nil. Note that after consuming the ou

AddTransaction adds the given transaction to the internal buffer.

Done returns true whether ACS has completed its agreements and cleared its messageQue.

InputValue sets the input value for broadcast and returns an initial set of Broadcast and ACS Messages to be broadcasted in the network.

NewAgreementMessage constructs a new AgreementMessage.

NewHoneyBadger returns a new HoneyBadger instance.

handleBvalRequest processes the received binary value and fills up the message que if there are any messages that need to be broadcasted.

newBuffer return a new initialized buffer with the max data cap set to 1024.

push pushes v to the buffer.

AcceptInput returns true whether this bba instance is elligable for accepting a new input value.

Messages returns the que of messages. The message que get's filled after processing a protocol message. After calling this method the que will be empt

makeShards will split the given value into equal sized shards along with somen additional parity shards.

run makes sure we only process 1 message at the same time, avoiding mutexes and race conditions.

validateProof will validate the given ProofRequest and hence return true or false accordingly.

Addr returns the address of the transport. We address transport by the id of the node.

Connect is used to connect this tranport to another transport.

HandleMessage handles incoming messages to ACS and redirects them to the appropriate sub(protocol) instance.

Output will return the output of the rbc instance. If the output was not nil then it will return the output else nil. Note that after consuming the ou

Outputs returns the commited transactions per epoch.

Start attempt to start the consensus engine. TODO(@anthdm): Reconsider API change.

advanceEpoch will reset all the values that are bound to an epoch and increments the epoch value by 1.

countEchos count the number of echos with the given hash.

countReadys count the number of readys with the given hash.

countTruthyAgreements returns the number of truthy received agreement messages.

@optimize: This can be much more efficient. delete removes the given slice of Transactions from the buffer.

Every node that has received (N - f) echo's with the same root hash from distinct nodes knows that at least (f + 1) "good" nodes have sent an echo wit

handleMessage will process the given rpc message. The caller is resposible to make sure only RPC messages are passed that are elligible for the BBA pr

When a node receives a Proof from a proposer it broadcasts the proof as an EchoRequest to the network after validating its content.

If a node had received (2 * f + 1) ready's (with matching root hash) from distinct nodes, it knows that at least (f + 1) good nodes have sent it. Henc

makeTransports is a test helper function for making n number of transports.

propose will propose a new batch for the current epoch.

tryDecodeValue will check whether the Value (V) can be decoded from the received shards. If the decode was successfull output will be set the this val

Simulate the delay of verifying a transaction.

Broadcast implements the Transport interface.

Broadcast multicasts the given messages to all connected nodes.

InputValue will set the given data as value V. The data will first splitted into shards and additional parity shards (used for reconstruction), the eq

SendProofMessages implements the Transport interface.

SendProofMessages will equally spread the given messages under the participating nodes.

countBvals counts all the received Bval inputs matching b.

countOutputs returns the number of received (aux) messages, the corresponding values that where also in our inputs.

handleAgreement processes the received AgreementMessage from sender (sid) for a value proposed by the proposing node (pid).

handleBroadcast processes the received BroadcastMessage.

handleMessage handles incoming messages to ACS and redirects them to the appropriate sub(protocol) instance.

hasSentBval return true if we already sent out the given value.

inputValue will set the given val as the initial value to be proposed in the Agreement.

inputValue sets the input value for broadcast and returns an initial set of Broadcast and ACS Messages to be broadcasted in the network.

makeProofRequests will build a merkletree out of the given shards and make equal ProofRequest to send one proof to each participant in the consensus.

makeProofRequests will build a merkletree out of the given shards and make equal ProofRequest to send one proof to each participant in the consensus.