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(Collection<Hash> pending) |
void |
addPending(Hash peer) |
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() |
int |
getCompleteCount() |
DatabaseEntry |
getData() |
Set<Hash> |
getFailed()
getFailed
|
Set<Hash> |
getPending() |
MessageWrapper.WrappedMessage |
getPendingMessage(Hash peer) |
Set<Hash> |
getSuccessful() |
Hash |
getTarget() |
long |
getWhenCompleted() |
long |
getWhenStarted() |
void |
replyTimeout(Hash peer)
public long confirmedExploratory(Hash peer) {
long rv = -1;
synchronized (_pendingPeers) {
_pendingPeers.remove(peer);
Long when = _pendingPeerTimes.remove(peer);
if (when != null)
rv = _context.clock().now() - when.longValue();
}
synchronized (_successfulExploratoryPeers) {
_successfulExploratoryPeers.add(peer);
}
return rv;
}
|
String |
toString() |
public StoreState(RouterContext ctx, Hash key, DatabaseEntry data)
public StoreState(RouterContext ctx, Hash key, DatabaseEntry data, Set<Hash> toSkip)
public Hash getTarget()
public DatabaseEntry getData()
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 addPending(Collection<Hash> pending)
public void addSkipped(Hash peer)
public long confirmed(Hash peer)
public void replyTimeout(Hash peer)