class StoreState
extends java.lang.Object
コンストラクタ | 説明 |
---|---|
StoreState(RouterContext ctx,
Hash key,
DatabaseEntry data) |
|
StoreState(RouterContext ctx,
Hash key,
DatabaseEntry data,
java.util.Set<Hash> toSkip) |
修飾子とタイプ | メソッド | 説明 |
---|---|---|
void |
addPending(java.util.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) |
|
java.util.Set<Hash> |
getAttempted() |
|
int |
getCompleteCount() |
|
DatabaseEntry |
getData() |
|
java.util.Set<Hash> |
getFailed() |
getFailed
|
java.util.Set<Hash> |
getPending() |
|
MessageWrapper.WrappedMessage |
getPendingMessage(Hash peer) |
|
java.util.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;
}
|
java.lang.String |
toString() |
public StoreState(RouterContext ctx, Hash key, DatabaseEntry data)
public StoreState(RouterContext ctx, Hash key, DatabaseEntry data, java.util.Set<Hash> toSkip)
public Hash getTarget()
public DatabaseEntry getData()
public java.util.Set<Hash> getPending()
public java.util.Set<Hash> getAttempted()
public java.util.Set<Hash> getSuccessful()
public java.util.Set<Hash> getFailed()
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(java.util.Collection<Hash> pending)
public void addSkipped(Hash peer)
public long confirmed(Hash peer)
public void replyTimeout(Hash peer)
public java.lang.String toString()
toString
クラス内 java.lang.Object