Package utils.communication.communicationHandler.Broadcast.byzantineBroadcast

Class OmissiveAsymmetricBroadcast

java.lang.Object

utils.communication.communicationHandler.Broadcast.byzantineBroadcast.OmissiveAsymmetricBroadcast

All Implemented Interfaces:

Broadcast

public class OmissiveAsymmetricBroadcast
extends Object
implements Broadcast

Constructor Summary

Constructors

Constructor	Description
OmissiveAsymmetricBroadcast()

Method Summary

Modifier and Type	Method	Description
CompletableFuture<Void>	broadcast(byte[] msgPayload, Map<? extends AddressInterface,? extends ProcessInterface> groupCon)	Send the message encoded in payload to every Process in groupConstitution asynchronously.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

OmissiveAsymmetricBroadcast

public OmissiveAsymmetricBroadcast()

Method Details

broadcast

public CompletableFuture<Void> broadcast(byte[] msgPayload,
 Map<? extends AddressInterface,? extends ProcessInterface> groupCon)

Description copied from interface: Broadcast

Send the message encoded in payload to every Process in groupConstitution asynchronously. Completes when every write operation for each process connection completes.

Specified by:

broadcast in interface Broadcast

Parameters:

msgPayload - Encoded message

groupCon - Group constituion, each process and their address

Returns:

A future that is completed when broadcasting is done