Changeset fc38d54
- Timestamp:
- Feb 10, 2011 3:21:23 PM (10 years ago)
- Branches:
- master
- Children:
- e68fbc0
- Parents:
- 5eb511b
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
core/java/src/net/i2p/internal/QueuedI2CPMessageReader.java
r5eb511b rfc38d54 43 43 try { 44 44 msg = in.take(); 45 if (msg.getType() == PoisonI2CPMessage.MESSAGE_TYPE) 45 if (msg.getType() == PoisonI2CPMessage.MESSAGE_TYPE) { 46 _listener.disconnected(QueuedI2CPMessageReader.this); 46 47 cancelRunner(); 47 else48 } else { 48 49 _listener.messageReceived(QueuedI2CPMessageReader.this, msg); 50 } 49 51 } catch (InterruptedException ie) {} 50 52 }
Note: See TracChangeset
for help on using the changeset viewer.