net.i2p.router.networkdb.kademlia.StoreState

class StoreState
extends Object

Tracks the state of a StoreJob

Constructor Summary

Constructors
Constructor	Description
`StoreState(RouterContext ctx, Hash key, DatabaseEntry data)`
`StoreState(RouterContext ctx, Hash key, DatabaseEntry data, Set<Hash> toSkip)`

Method Summary

Modifier and Type	Method	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()`

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details
- StoreState
  
  public StoreState(RouterContext ctx, Hash key, DatabaseEntry data)
- StoreState
  
  public StoreState(RouterContext ctx, Hash key, DatabaseEntry data, Set<Hash> toSkip)
Method Details
- getTarget
  
  public Hash getTarget()
- getData
  
  public DatabaseEntry getData()
- getPending
  
  public Set<Hash> getPending()
- getAttempted
  
  public Set<Hash> getAttempted()
- getSuccessful
  
  public Set<Hash> getSuccessful()
- getFailed
  
  public Set<Hash> getFailed()
  
  getFailed
- completed
  
  public boolean completed()
- complete
  
  public void complete(boolean completed)
- getCompleteCount
  
  public int getCompleteCount()
- getWhenStarted
  
  public long getWhenStarted()
- getWhenCompleted
  
  public long getWhenCompleted()
- addPending
  
  public void addPending(Hash peer, MessageWrapper.WrappedMessage msg)
- getPendingMessage
  
  public MessageWrapper.WrappedMessage getPendingMessage(Hash peer)
- addPending
  
  public void addPending(Hash peer)
- addPending
  
  public void addPending(Collection<Hash> pending)
- addSkipped
  
  public void addSkipped(Hash peer)
  
  we aren't even going to try to contact this peer
- confirmed
  
  public long confirmed(Hash peer)
- replyTimeout
  
  public 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; }
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Object

Class StoreState

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Constructor Details

Method Details