Changeset 538427c2


Ignore:
Timestamp:
Feb 29, 2012 6:49:49 PM (8 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
cf41068
Parents:
f61183d2
Message:
Location:
router/java/src/net/i2p/router/networkdb/kademlia
Files:
2 edited

Legend:

Unmodified
Added
Removed
  • router/java/src/net/i2p/router/networkdb/kademlia/StoreJob.java

    rf61183d2 r538427c2  
    9999    /**
    100100     * send the key to the next batch of peers
     101     *
     102     * Synchronized to enforce parallelization limits and prevent dups
    101103     */
    102104    private void sendNext() {
     
    131133     * at any time
    132134     *
    133      */
    134     private void continueSending() {
     135     * Caller should synchronize to enforce parallelization limits and prevent dups
     136     */
     137    private synchronized void continueSending() {
    135138        if (_state.completed()) return;
    136139        int toCheck = getParallelization() - _state.getPending().size();
  • router/java/src/net/i2p/router/networkdb/kademlia/StoreState.java

    rf61183d2 r538427c2  
    1515
    1616/**
    17  *
     17 *  Tracks the state of a StoreJob
    1818 */
    1919class StoreState {
    20     private RouterContext _context;
    21     private Hash _key;
    22     private DatabaseEntry _data;
     20    private final RouterContext _context;
     21    private final Hash _key;
     22    private final DatabaseEntry _data;
    2323    private final HashSet<Hash> _pendingPeers;
    24     private Map<Hash, Long> _pendingPeerTimes;
    25     private Map<Hash, MessageWrapper.WrappedMessage> _pendingMessages;
     24    private final Map<Hash, Long> _pendingPeerTimes;
     25    private final Map<Hash, MessageWrapper.WrappedMessage> _pendingMessages;
    2626    private final HashSet<Hash> _successfulPeers;
    2727    //private final HashSet<Hash> _successfulExploratoryPeers;
Note: See TracChangeset for help on using the changeset viewer.