Changeset 99ebad30


Ignore:
Timestamp:
Feb 9, 2011 4:15:36 PM (9 years ago)
Author:
sponge <sponge@…>
Branches:
master
Children:
2db136b, c8866be
Parents:
467de344
Message:

BOB config fix, I2CP fix some leaks, see history.txt for details

Files:
5 edited

Legend:

Unmodified
Added
Removed
  • apps/BOB/src/net/i2p/BOB/BOB.java

    r467de344 r99ebad30  
    121121        public final static String PROP_BOB_PORT = "BOB.port";
    122122        public final static String PROP_BOB_HOST = "BOB.host";
     123        public final static String PROP_CFG_VER = "BOB.CFG.VER";
    123124        private static NamedDB database;
    124125        private static Properties props = new Properties();
     
    210211                        if (!props.containsKey(I2PClient.PROP_TCP_HOST)) {
    211212                                props.setProperty(I2PClient.PROP_TCP_HOST, "localhost");
     213                                save = true;
    212214                        }
    213215                        if (!props.containsKey(I2PClient.PROP_TCP_PORT)) {
    214216                                props.setProperty(I2PClient.PROP_TCP_PORT, "7654");
    215                         }
    216                         if (!props.containsKey(I2PClient.PROP_RELIABILITY)) {
    217                                 props.setProperty(I2PClient.PROP_RELIABILITY, I2PClient.PROP_RELIABILITY_BEST_EFFORT);
     217                                save = true;
    218218                        }
    219219                        if (!props.containsKey(PROP_BOB_PORT)) {
    220220                                props.setProperty(PROP_BOB_PORT, "2827"); // 0xB0B
     221                                save = true;
    221222                        }
    222223                        if (!props.containsKey("inbound.length")) {
    223224                                props.setProperty("inbound.length", "1");
     225                                save = true;
    224226                        }
    225227                        if (!props.containsKey("outbound.length")) {
    226228                                props.setProperty("outbound.length", "1");
     229                                save = true;
    227230                        }
    228231                        if (!props.containsKey("inbound.lengthVariance")) {
    229232                                props.setProperty("inbound.lengthVariance", "0");
     233                                save = true;
    230234                        }
    231235                        if (!props.containsKey("outbound.lengthVariance")) {
    232236                                props.setProperty("outbound.lengthVariance", "0");
     237                                save = true;
    233238                        }
    234239                        if (!props.containsKey(PROP_BOB_HOST)) {
    235240                                props.setProperty(PROP_BOB_HOST, "localhost");
     241                                save = true;
     242                        }
     243                        // PROP_RELIABILITY_NONE, PROP_RELIABILITY_BEST_EFFORT, PROP_RELIABILITY_GUARANTEED
     244                        if (!props.containsKey(PROP_CFG_VER)) {
     245                                props.setProperty(I2PClient.PROP_RELIABILITY, I2PClient.PROP_RELIABILITY_NONE);
     246                                props.setProperty(PROP_CFG_VER,"1");
     247                                save = true;
    236248                        }
    237249                        if (save) {
  • core/java/src/net/i2p/data/i2cp/I2CPMessageReader.java

    r467de344 r99ebad30  
    198198            }
    199199            _stream = null;
     200            _listener = null;
     201            _reader = null;
     202            _readerThread = null;
    200203        }
    201204    }
  • core/java/src/net/i2p/internal/QueuedI2CPMessageReader.java

    r467de344 r99ebad30  
    1212 */
    1313public class QueuedI2CPMessageReader extends I2CPMessageReader {
    14     private final I2CPMessageQueue in;
     14    private /* final */ I2CPMessageQueue in;
    1515
    1616    public QueuedI2CPMessageReader(I2CPMessageQueue in, I2CPMessageEventListener lsnr) {
    1717        super(lsnr);
    1818        this.in = in;
     19        _reader = null;
     20        _readerThread = null;
    1921        _reader = new QueuedI2CPMessageReaderRunner();
    2022        _readerThread = new I2PThread(_reader, "I2CP Internal Reader " + (++__readerId), true);
     
    5860                }
    5961            }
     62            super.run(); // Since we are dead, this will do some clean up, nothing else :-)
     63            in = null;
     64            _readerThread = null;
     65            _reader = null;
    6066        }
    6167    }
  • history.txt

    r467de344 r99ebad30  
     12011-02-09 sponge
     2    * BOB: fixup delivery in config, adds config file versioning.
     3    * I2CP: Fix most of the I2CP leaks. Two leaks remain, but they are small.
     4            net.i2p.internal.QueuedI2CPMessageReader and
     5            net.i2p.router.client.I2CPMessageQueueImpl
     6            are the two remaining leaks.
     7
    182011-02-07 zzz
    29    * i2psnark:
  • router/java/src/net/i2p/router/client/QueuedClientConnectionRunner.java

    r467de344 r99ebad30  
    1818 */
    1919class QueuedClientConnectionRunner extends ClientConnectionRunner {
    20     private final I2CPMessageQueue queue;
     20    private /* final */ I2CPMessageQueue queue;
    2121   
    2222    /**
     
    4747        super.stopRunning();
    4848        queue.close();
     49        queue = null;
    4950    }
    5051   
Note: See TracChangeset for help on using the changeset viewer.