|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.i2p.router.networkdb.kademlia.StoreState
class StoreState
Tracks the state of a StoreJob
Constructor Summary | |
---|---|
StoreState(RouterContext ctx,
Hash key,
DatabaseEntry data)
|
|
StoreState(RouterContext ctx,
Hash key,
DatabaseEntry data,
Set<Hash> toSkip)
|
Method Summary | |
---|---|
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()
public Set |
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()
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public StoreState(RouterContext ctx, Hash key, DatabaseEntry data)
public StoreState(RouterContext ctx, Hash key, DatabaseEntry data, Set<Hash> toSkip)
Method Detail |
---|
public Hash getTarget()
public DatabaseEntry getData()
public Set<Hash> getPending()
public Set<Hash> getAttempted()
public Set<Hash> getSuccessful()
public 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(Collection<Hash> pending)
public void addSkipped(Hash peer)
public long confirmed(Hash peer)
public void replyTimeout(Hash peer)
public String toString()
toString
in class Object
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |