|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object | +--dd.api.DDRouteMsg | +--dd.api.DDMacRouteMsg | +--ostore.archive.dissemination.DisseminateFragAckMsg
The DisseminateFragAckMsg
is a response of type
DDMacRouteMsg
dispatched
by a StorageServer
to respond
to an associated DisseminateFragMsg
requesting the storage
of a Disseminatable
.
To actually disseminate
, dispatch a
DisseminateFragsReq
. The
DisseminatorStage
will then dispatch a
DisseminateFragMsg
to each member of the
dissemination set
. The process is done when
enough DisseminateFragAckMsg
are received to consider
the dissemination effective.
DisseminateFragMsg
,
DisseminatorStage
,
ArchivalStorageStage
,
DisseminateFragsReq
,
DisseminateFragsResp
,
Disseminatable
,
Fragment
,
DDMacRouteMsg
Nested Class Summary | |
---|---|
static class |
DisseminateFragAckMsg.Local
A simple class to store DisseminateFragAckMsg requests to send to another local stage. |
Field Summary | |
---|---|
SortedMap |
acks
A guid->ack map containing the ack associated with guid.
|
SecureHash |
aguid
aguid is the guid that matches the object that was disseminated. |
int |
index
index of disseminatable being acknowledged. |
SecureHash |
vguid
aguid is the guid that matches the version that was disseminated. |
Fields inherited from class dd.api.DDRouteMsg |
---|
dd_intermediate_upcall, hopCount, inbound, one_hop, peer, recursive_route, TTL |
Constructor Summary | |
---|---|
DisseminateFragAckMsg(InputBuffer buffer)
Constructs a DisseminateFragAckMsg from its
serialized form. |
|
DisseminateFragAckMsg(SecureHash requestorGuid,
SecureHash activeGuid,
SecureHash versionGuid,
int i,
Map acknowledgements,
boolean recursive,
boolean dd_intermediate_upcall,
boolean one_hop)
Construct according to the given fields. |
Method Summary | |
---|---|
Map |
getAcks()
getAcks returns the acks to the DisseminateFragMsg. |
SecureHash |
getAguid()
getAguid returns the aguid that matches the object that was disseminated. |
int |
getIndex()
getIndex returns the index of disseminatable being acknowledged. |
SecureHash |
getVguid()
getVguid returns the vguid that matches the version that was disseminated. |
void |
serialize(OutputBuffer buffer)
Specified by ostore.util.QuickSerializable |
String |
toString()
Specified by java.lang.Object |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
public SecureHash aguid
public SecureHash vguid
public int index
public SortedMap acks
guid->ack
map containing the ack associated with guid.
Ack is the acknowledgement of the request to store a disseminatable.
The map is kept sorted, to ensure a deterministic serialization.
Constructor Detail |
public DisseminateFragAckMsg(SecureHash requestorGuid, SecureHash activeGuid, SecureHash versionGuid, int i, Map acknowledgements, boolean recursive, boolean dd_intermediate_upcall, boolean one_hop)
public DisseminateFragAckMsg(InputBuffer buffer) throws QSException
DisseminateFragAckMsg
from its
serialized
form.
buffer
- serialized
form of object.Method Detail |
public final Map getAcks()
public final SecureHash getAguid()
public final SecureHash getVguid()
public final int getIndex()
public void serialize(OutputBuffer buffer)
serialize
in interface QuickSerializable
serialize
in class DDRouteMsg
buffer
- the output buffer to add the object topublic String toString()
toString
in class Object
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |