edu.iu.harp.client

Class DataMSTBcastSender

java.lang.Object

edu.iu.harp.client.Sender

edu.iu.harp.client.DataSender

edu.iu.harp.client.DataMSTBcastSender

public class DataMSTBcastSender
extends DataSender

The actual sender for broadcasting the data using MST method We don't allow the worker broadcasts to itself.

Constructor Summary

Constructors

Constructor and Description
DataMSTBcastSender(Data data, Workers workers, byte command)

Method Summary

Modifier and Type	Method and Description
protected ByteArray	getOPByteArray(int headArrSize) Get the ByteArray storing the size of the head array
protected void	sendDataBytes(Connection conn, ByteArray opArray, Data data) Broadcast the data

Methods inherited from class edu.iu.harp.client.DataSender

getHeadSize, handleData

Methods inherited from class edu.iu.harp.client.Sender

execute, getCommand, getDestWorkerID, getWorkers

Methods inherited from class java.lang.Object

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

Constructor Detail

DataMSTBcastSender

public DataMSTBcastSender(Data data,
                          Workers workers,
                          byte command)

Method Detail

getOPByteArray

protected ByteArray getOPByteArray(int headArrSize)

Get the ByteArray storing the size of the head array

Overrides:

getOPByteArray in class DataSender

Parameters:

headArrSize - the size of the head array

Returns:

the ByteArray storing the size of the head array

sendDataBytes

protected void sendDataBytes(Connection conn,
                             ByteArray opArray,
                             Data data)
                      throws java.io.IOException

Broadcast the data

Overrides:

sendDataBytes in class DataSender

Parameters:

conn - the Connection object

opArray - the ByteArray storing the size of the head array

data - the Data to be broadcast

Throws:

java.io.IOException