edu.iu.harp.client

Class DataSender

java.lang.Object

edu.iu.harp.client.Sender

edu.iu.harp.client.DataSender

Direct Known Subclasses:

DataChainBcastSender, DataMSTBcastSender

public class DataSender
extends Sender

The actual sender for sending the data. Different from DataReceiver, we don't release the encoded bytes in failures.

Constructor Summary

Constructors

Constructor and Description
DataSender(Data data, int destWorkerID, Workers workers, byte command)
DataSender(Data data, java.lang.String host, int port, byte command)

Method Summary

Modifier and Type	Method and Description
protected int	getHeadSize(Data data) Get the size of the head array
protected ByteArray	getOPByteArray(int headArrSize) Get the ByteArray storing the size of the head array
protected void	handleData(Connection conn, Data data) This method defines how to handle the data
protected void	sendDataBytes(Connection conn, ByteArray opArray, Data data) Send the data

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

DataSender

public DataSender(Data data,
                  int destWorkerID,
                  Workers workers,
                  byte command)

DataSender

public DataSender(Data data,
                  java.lang.String host,
                  int port,
                  byte command)

Method Detail

handleData

protected void handleData(Connection conn,
                          Data data)
                   throws java.lang.Exception

This method defines how to handle the data

Specified by:

handleData in class Sender

Parameters:

conn - the connection object

data - the Data

Throws:

java.lang.Exception

getHeadSize

protected int getHeadSize(Data data)

Get the size of the head array

Parameters:

data - the Data

Returns:

the size of the head array of the data

getOPByteArray

protected ByteArray getOPByteArray(int headArrSize)

Get the ByteArray storing the size of the head array

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

Send the data

Parameters:

conn - the Connection object

opArray - the ByteArray storing the size of the head array

data - the Data to be sent

Throws:

java.io.IOException