- Timestamp:
- Feb 22, 2018 2:54:57 PM (3 years ago)
- Branches:
- master
- Children:
- 6fe25cd
- Parents:
- 2374471
- Location:
- core/java/src/net/i2p/util
- Files:
-
- 2 added
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
core/java/src/net/i2p/util/InternalServerSocket.java
r2374471 r0196275 101 101 if (iss == null) 102 102 throw new IOException("No server for port: " + port); 103 PipedInputStream cis = newPipedInputStream(64*1024);104 PipedInputStream sis = newPipedInputStream(64*1024);105 PipedOutputStream cos = new PipedOutputStream(sis);106 PipedOutputStream sos = new PipedOutputStream(cis);103 TimeoutPipedInputStream cis = new TimeoutPipedInputStream(64*1024); 104 TimeoutPipedInputStream sis = new TimeoutPipedInputStream(64*1024); 105 PipedOutputStream cos = new TimeoutPipedOutputStream(sis); 106 PipedOutputStream sos = new TimeoutPipedOutputStream(cis); 107 107 clientSock.setInputStream(cis); 108 108 clientSock.setOutputStream(cos); -
core/java/src/net/i2p/util/InternalSocket.java
r2374471 r0196275 99 99 } 100 100 101 /** 102 * Supported as of 0.9.34, if constructed with TimeoutPipedInputStream 103 * and TimeoutPipedOutputStream. Otherwise, does nothing. 104 * @see TimeoutPipedInputStream 105 */ 106 @Override 107 public synchronized void setSoTimeout(int timeout) { 108 if (_is != null && _is instanceof TimeoutPipedInputStream) 109 ((TimeoutPipedInputStream) _is).setReadTimeout(timeout); 110 } 111 101 112 // ignored stuff 102 /** warning - unsupported */ 103 @Override104 public void setSoTimeout(int timeout) {}105 113 114 /** 115 * Always returns 0, even if setSoTimeout() was called. 116 */ 106 117 @Override 107 118 public int getSoTimeout () {
Note: See TracChangeset
for help on using the changeset viewer.