Package utils.communication.communicationHandler.Broadcast.byzantineBroadcast

Class OmissiveSymmetricBroadcast

java.lang.Object

utils.communication.communicationHandler.Broadcast.byzantineBroadcast.OmissiveSymmetricBroadcast

All Implemented Interfaces:

Broadcast

public class OmissiveSymmetricBroadcast
extends Object
implements Broadcast

Constructor Summary

Constructors

Constructor	Description
OmissiveSymmetricBroadcast()

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

OmissiveSymmetricBroadcast

public OmissiveSymmetricBroadcast()

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