demo.repair
Class RepairDirectoryTest2.DisseminateReq

java.lang.Object
  |
  +--ostore.network.NetworkMessage
        |
        +--demo.repair.RepairDirectoryTest2.DisseminateReq

All Implemented Interfaces:

Cloneable, QueueElementIF, QuickSerializable, soss.network.SimulatedMsgSize

Enclosing class:

RepairDirectoryTest2

public static class RepairDirectoryTest2.DisseminateReq

extends NetworkMessage

implements soss.network.SimulatedMsgSize

DisseminateReq is a request sent by the leader; that is, node responsible for coordinating the repair of an object replicated on a set of nodes.

Field Summary

SecureHash	dest
SecureHash	src

Fields inherited from class ostore.network.NetworkMessage

comp_q, est_rtt_ms, inbound, peer, sender, tries, user_data, wait_ms

Constructor Summary

RepairDirectoryTest2.DisseminateReq(InputBuffer buffer)
Constructs a DisseminateReq from its serialized form.

RepairDirectoryTest2.DisseminateReq(NodeId peer, SecureHash src, SecureHash dest, SecureHash objguid, DDThresholdTag ttag, QuickSerializable object, int redundancy, int additional_simulated_size)
Construct according to the given fields.

Method Summary

QuickSerializable	getObj() getObj returns the object to be replicated on storage server.
SecureHash	getObjguid() getObjguid returns the guid of the originally requested obj specified in the DisseminateReq.
int	getRedundancy() getRedundancy returns the number of replicas for the object; that is, the object is replicated on redundancy storage server.
DDThresholdTag	getTag() getTag returns the DDThresholdTag associated with the objguid.
void	serialize(OutputBuffer buffer) Specified by ostore.util.QuickSerializable
void	setSimulatedSize(int additional_simulated_size) sets the additional simulated size for msg .
int	simulatedSize() Specified in soss.network.SimulatedMsgSize
String	toString() Specified by java.lang.Object

Methods inherited from class ostore.network.NetworkMessage

clone

Methods inherited from class java.lang.Object

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

Field Detail

src

public SecureHash src

dest

public SecureHash dest

Constructor Detail

RepairDirectoryTest2.DisseminateReq

public RepairDirectoryTest2.DisseminateReq(NodeId peer,
                                           SecureHash src,
                                           SecureHash dest,
                                           SecureHash objguid,
                                           DDThresholdTag ttag,
                                           QuickSerializable object,
                                           int redundancy,
                                           int additional_simulated_size)

Construct according to the given fields.

RepairDirectoryTest2.DisseminateReq

public RepairDirectoryTest2.DisseminateReq(InputBuffer buffer)
                                    throws QSException

Constructs a DisseminateReq from its serialized form.

Parameters:

buffer - serialized form of object.

Method Detail

getObj

public final QuickSerializable getObj()

getObj returns the object to be replicated on storage server.

Returns:

the object to be replicated on storage server.

getRedundancy

public final int getRedundancy()

getRedundancy returns the number of replicas for the object; that is, the object is replicated on redundancy storage server.

Returns:

the number of replicas for the object.

getObjguid

public final SecureHash getObjguid()

getObjguid returns the guid of the originally requested obj specified in the DisseminateReq.

Returns:

the guid specified in the DisseminateReq.

getTag

public final DDThresholdTag getTag()

getTag returns the DDThresholdTag associated with the objguid.

Returns:

the DDThresholdTag associated to the objguid.

serialize

public void serialize(OutputBuffer buffer)

Specified by ostore.util.QuickSerializable

Specified by:

serialize in interface QuickSerializable

Overrides:

serialize in class NetworkMessage

toString

public String toString()

Specified by java.lang.Object

Overrides:

toString in class NetworkMessage

simulatedSize

public int simulatedSize()

Specified in soss.network.SimulatedMsgSize

Specified by:

simulatedSize in interface soss.network.SimulatedMsgSize

setSimulatedSize

public void setSimulatedSize(int additional_simulated_size)

sets the additional simulated size for msg .