class StoreState extends Object
Constructor and Description |
---|
StoreState(RouterContext ctx,
Hash key,
DatabaseEntry data) |
StoreState(RouterContext ctx,
Hash key,
DatabaseEntry data,
Set<Hash> toSkip) |
Modifier and Type | Method and Description |
---|---|
void |
addPending(Hash peer)
Increments attempted count
|
void |
addPending(Hash peer,
MessageWrapper.WrappedMessage msg) |
void |
addSkipped(Hash peer)
we aren't even going to try to contact this peer
|
void |
complete(boolean completed) |
boolean |
completed() |
long |
confirmed(Hash peer) |
Set<Hash> |
getAttempted()
The peers attempted OR skipped.
|
int |
getAttemptedCount()
The number of peers attempted.
|
int |
getCompleteCount() |
DatabaseEntry |
getData() |
int |
getPendingCount()
The number of peers pending.
|
MessageWrapper.WrappedMessage |
getPendingMessage(Hash peer) |
Hash |
getSuccessful()
Return a successful peer (a random one if more than one was successful)
or null.
|
Hash |
getTarget() |
long |
getWhenCompleted() |
long |
getWhenStarted() |
void |
replyTimeout(Hash peer) |
String |
toString() |
public StoreState(RouterContext ctx, Hash key, DatabaseEntry data)
public StoreState(RouterContext ctx, Hash key, DatabaseEntry data, Set<Hash> toSkip)
key
- the DatabaseEntry hashtoSkip
- may be null, if non-null, all attempted and skipped targets will be added as of 0.9.53public Hash getTarget()
public DatabaseEntry getData()
public int getPendingCount()
public Set<Hash> getAttempted()
public int getAttemptedCount()
public Hash getSuccessful()
public boolean completed()
public void complete(boolean completed)
public int getCompleteCount()
public long getWhenStarted()
public long getWhenCompleted()
public void addPending(Hash peer, MessageWrapper.WrappedMessage msg)
public MessageWrapper.WrappedMessage getPendingMessage(Hash peer)
public void addPending(Hash peer)
public void addSkipped(Hash peer)
public long confirmed(Hash peer)
public void replyTimeout(Hash peer)