Changeset f1c4a85


Ignore:
Timestamp:
Oct 6, 2008 9:28:59 AM (12 years ago)
Author:
sponge <sponge@…>
Branches:
master
Children:
bb32672
Parents:
0a5eeed3
Message:

Code cleanup in I2PSocketManagerFull and I2PServerSocketFull
BUGFIX ConnectionHandler? had a comparason bug that caused it to block when infact it was asked NOT to block

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

Legend:

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

    r0a5eeed3 rf1c4a85  
    9696                    } else {
    9797                        long remaining = expiration - _context.clock().now();
    98                         if (remaining < 0)
     98// BUGFIX
     99// The specified amount of real time has elapsed, more or less.
     100// If timeout is zero, however, then real time is not taken into consideration
     101// and the thread simply waits until notified.
     102                        if (remaining < 1)
    99103                            break;
    100104                        try { _synQueue.wait(remaining); } catch (InterruptedException ie) {}
  • apps/streaming/java/src/net/i2p/client/streaming/I2PServerSocketFull.java

    r0a5eeed3 rf1c4a85  
    22
    33import java.net.SocketTimeoutException;
    4 import java.util.logging.Level;
    5 import java.util.logging.Logger;
    64import net.i2p.I2PException;
    75
  • apps/streaming/java/src/net/i2p/client/streaming/I2PSocketManagerFull.java

    r0a5eeed3 rf1c4a85  
    129129        } else {
    130130            if(_connectionManager.MgetSoTimeout() == -1) {
    131             return null;
    132         }
     131                return null;
     132            }
    133133            throw new SocketTimeoutException("I2PSocket timed out");
    134134        }
Note: See TracChangeset for help on using the changeset viewer.