Changeset e243e0dd for apps


Ignore:
Timestamp:
Aug 23, 2018 3:20:29 PM (23 months ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
6cf84ac
Parents:
fddaa47
Message:

streaming minor tweaks

Location:
apps/streaming/java/src/net/i2p/client/streaming/impl
Files:
3 edited

Legend:

Unmodified
Added
Removed
  • apps/streaming/java/src/net/i2p/client/streaming/impl/ConnectionHandler.java

    rfddaa47 re243e0dd  
    6565        // FIXME active=false this only kills for one thread in accept()
    6666        // if there are more, they won't get a poison packet.
    67         if (_log.shouldLog(Log.WARN))
    68             _log.warn("setActive(" + active + ") called, previously " + _active, new Exception("I did it"));
     67        if (_log.shouldInfo())
     68            _log.info("setActive(" + active + ") called, previously " + _active, new Exception("I did it"));
    6969        // if starting, clear any old poison
    7070        if (active && !_active) {
  • apps/streaming/java/src/net/i2p/client/streaming/impl/I2PSocketOptionsImpl.java

    rfddaa47 re243e0dd  
    1818   
    1919    public static final int DEFAULT_BUFFER_SIZE = 1024*64;
     20    public static final int DEFAULT_READ_TIMEOUT = -1;
    2021    public static final int DEFAULT_WRITE_TIMEOUT = -1;
    2122    public static final int DEFAULT_CONNECT_TIMEOUT = 60*1000;
     
    7273            _connectTimeout = getInt(opts, PROP_CONNECT_TIMEOUT, DEFAULT_CONNECT_TIMEOUT);
    7374        if (opts.getProperty(PROP_READ_TIMEOUT) != null)
    74             _readTimeout = getInt(opts, PROP_READ_TIMEOUT, -1);
     75            _readTimeout = getInt(opts, PROP_READ_TIMEOUT, DEFAULT_READ_TIMEOUT);
    7576        if (opts.getProperty(PROP_WRITE_TIMEOUT) != null)
    7677            _writeTimeout = getInt(opts, PROP_WRITE_TIMEOUT, DEFAULT_WRITE_TIMEOUT);
  • apps/streaming/java/src/net/i2p/client/streaming/impl/MessageInputStream.java

    rfddaa47 re243e0dd  
    7575        _highestReadyBlockId = -1;
    7676        _highestBlockId = -1;
    77         _readTimeout = -1;
     77        _readTimeout = I2PSocketOptionsImpl.DEFAULT_READ_TIMEOUT;
    7878        _notYetReadyBlocks = new HashMap<Long, ByteArray>(4);
    7979        _dataLock = new Object();
Note: See TracChangeset for help on using the changeset viewer.