Changeset 6422f7ef


Ignore:
Timestamp:
Sep 2, 2005 6:34:14 PM (15 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
9aaad00
Parents:
3e51584
git-author:
jrandom <jrandom> (09/02/05 18:34:14)
git-committer:
zzz <zzz@…> (09/02/05 18:34:14)
Message:

2005-09-02 jrandom

  • Don't refuse to send a netDb store if the targetted peer has failed a bit (the value was an arbitrary amount).
  • Logging changes
Files:
5 edited

Legend:

Unmodified
Added
Removed
  • history.txt

    r3e51584 r6422f7ef  
    1 $Id: history.txt,v 1.234 2005/09/01 01:55:02 jrandom Exp $
     1$Id: history.txt,v 1.235 2005/09/01 15:27:35 jrandom Exp $
     2
     32005-09-02  jrandom
     4    * Don't refuse to send a netDb store if the targetted peer has failed a
     5      bit (the value was an arbitrary amount).
     6    * Logging changes
    27
    38* 2005-09-01  0.6.0.4 released
  • router/java/src/net/i2p/router/RouterVersion.java

    r3e51584 r6422f7ef  
    1616 */
    1717public class RouterVersion {
    18     public final static String ID = "$Revision: 1.223 $ $Date: 2005/09/01 01:55:01 $";
     18    public final static String ID = "$Revision: 1.224 $ $Date: 2005/09/01 15:27:35 $";
    1919    public final static String VERSION = "0.6.0.4";
    20     public final static long BUILD = 0;
     20    public final static long BUILD = 1;
    2121    public static void main(String args[]) {
    2222        System.out.println("I2P Router version: " + VERSION);
  • router/java/src/net/i2p/router/client/ClientManager.java

    r3e51584 r6422f7ef  
    272272   
    273273    public boolean shouldPublishLeaseSet(Hash destHash) {
     274        if (false) return true;
    274275        if (destHash == null) return true;
    275276        ClientConnectionRunner runner = getRunner(destHash);
    276277        if (runner == null) return true;
    277278        String dontPublish = runner.getConfig().getOptions().getProperty(ClientManagerFacade.PROP_CLIENT_ONLY);
    278         if ( (dontPublish != null) && ("true".equals(dontPublish)) )
     279        if ( (dontPublish != null) && ("true".equals(dontPublish)) ) {
     280            if (_log.shouldLog(Log.INFO))
     281                _log.info("Not publishing the leaseSet for " + destHash.toBase64());
    279282            return false;
     283        }
    280284        return true;
    281285    }
  • router/java/src/net/i2p/router/networkdb/kademlia/FloodfillStoreJob.java

    r3e51584 r6422f7ef  
    4949    }
    5050
    51     protected int getParallelization() { return 1; }
     51    protected int getParallelization() { return 2; }
    5252    protected int getRedundancy() { return 1; }
    5353
     
    5959        getContext().jobQueue().addJob(new FloodfillVerifyStoreJob(getContext(), _state.getTarget(), _facade));
    6060    }
     61   
     62    public String getName() { return "Floodfill netDb store"; }
    6163}
  • router/java/src/net/i2p/router/networkdb/kademlia/StoreJob.java

    r3e51584 r6422f7ef  
    162162                    RateStat failing = prof.getDBHistory().getFailedLookupRate();
    163163                    Rate failed = failing.getRate(60*60*1000);
    164                     long failedCount = failed.getCurrentEventCount()+failed.getLastEventCount();
    165                     if (failedCount > 10) {
    166                         _state.addSkipped(peer);
    167                         continue;
    168                     }
     164                    //long failedCount = failed.getCurrentEventCount()+failed.getLastEventCount();
     165                    //if (failedCount > 10) {
     166                    //    _state.addSkipped(peer);
     167                    //    continue;
     168                    //}
    169169                    //
    170170                    //if (failed.getCurrentEventCount() + failed.getLastEventCount() > avg) {
Note: See TracChangeset for help on using the changeset viewer.