Changeset 38c02b44


Ignore:
Timestamp:
Dec 19, 2013 12:24:51 PM (7 years ago)
Author:
zzz <zzz@…>
Branches:
master
Children:
bf485d8, cc97a19
Parents:
04a5968
Message:

Streaming: final, volatile, logging

File:
1 edited

Legend:

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

    r04a5968 r38c02b44  
    2222    private final ConnectionManager _manager;
    2323    private final LinkedBlockingQueue<Packet> _synQueue;
    24     private boolean _active;
     24    private volatile boolean _active;
    2525    private int _acceptTimeout;
    2626   
     
    231231   
    232232    private class TimeoutSyn implements SimpleTimer.TimedEvent {
    233         private Packet _synPacket;
     233        private final Packet _synPacket;
     234
    234235        public TimeoutSyn(Packet packet) {
    235236            _synPacket = packet;
     
    240241           
    241242            if (removed) {
    242                 if (_synPacket.isFlagSet(Packet.FLAG_SYNCHRONIZE))
     243                if (_synPacket.isFlagSet(Packet.FLAG_SYNCHRONIZE)) {
     244                    if (_log.shouldLog(Log.WARN))
     245                        _log.warn("Expired on the SYN queue: " + _synPacket);
    243246                    // timeout - send RST
    244247                    sendReset(_synPacket);
    245                 else
     248                } else {
    246249                    // non-syn packet got stranded on the syn queue, send it to the con
    247250                    reReceivePacket(_synPacket);
     251                }
    248252            } else {
    249253                // handled.  noop
Note: See TracChangeset for help on using the changeset viewer.