echelon/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

SocketErrorListener callback is unimplemented

Browse Source
This commit is contained in:
zzz
2014-04-05 12:18:14 +00:00
parent 7487ab8848
commit e1fc6893b4
3 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
apps/i2ptunnel/java/src/net/i2p/i2ptunnel/I2PTunnelRunner.java
View File

@ -145,7 +145,8 @@ public class I2PTunnelRunner extends I2PAppThread implements I2PSocket.SocketErr
try { try {
InputStream in = getSocketIn(); InputStream in = getSocketIn();
OutputStream out = getSocketOut(); // = new BufferedOutputStream(s.getOutputStream(), NETWORK_BUFFER_SIZE); OutputStream out = getSocketOut(); // = new BufferedOutputStream(s.getOutputStream(), NETWORK_BUFFER_SIZE);
i2ps.setSocketErrorListener(this); // unimplemented in streaming
//i2ps.setSocketErrorListener(this);
InputStream i2pin = i2ps.getInputStream(); InputStream i2pin = i2ps.getInputStream();
OutputStream i2pout = i2ps.getOutputStream(); //new BufferedOutputStream(i2ps.getOutputStream(), MAX_PACKET_SIZE); OutputStream i2pout = i2ps.getOutputStream(); //new BufferedOutputStream(i2ps.getOutputStream(), MAX_PACKET_SIZE);
if (initialI2PData != null) { if (initialI2PData != null) {
@ -246,7 +247,8 @@ public class I2PTunnelRunner extends I2PAppThread implements I2PSocket.SocketErr
if (_log.shouldLog(Log.WARN)) if (_log.shouldLog(Log.WARN))
_log.warn("Could not close I2PSocket", ex); _log.warn("Could not close I2PSocket", ex);
} }
i2ps.setSocketErrorListener(null); // unimplemented in streaming
//i2ps.setSocketErrorListener(null);
} }
} }
} }

5
apps/ministreaming/java/src/net/i2p/client/streaming/I2PSocket.java
View File

@ -76,6 +76,9 @@ public interface I2PSocket extends Closeable {
public boolean isClosed(); public boolean isClosed();
/**
* Deprecated, unimplemented, does nothing
*/
public void setSocketErrorListener(SocketErrorListener lsnr); public void setSocketErrorListener(SocketErrorListener lsnr);
/** /**
@ -93,6 +96,8 @@ public interface I2PSocket extends Closeable {
public int getLocalPort(); public int getLocalPort();
/** /**
* Deprecated, unimplemented, does nothing. Original description:
*
* Allow notification of underlying errors communicating across I2P without * Allow notification of underlying errors communicating across I2P without
* waiting for any sort of cleanup process. For example, if some data could * waiting for any sort of cleanup process. For example, if some data could
* not be sent, this listener is notified immediately, and while the input/output * not be sent, this listener is notified immediately, and while the input/output

3
apps/streaming/java/src/net/i2p/client/streaming/impl/I2PSocketFull.java
View File

@ -139,6 +139,9 @@ class I2PSocketFull implements I2PSocket {
c.getOptions().setReadTimeout(ms); c.getOptions().setReadTimeout(ms);
} }
/**
* Deprecated, unimplemented, does nothing
*/
public void setSocketErrorListener(I2PSocket.SocketErrorListener lsnr) { public void setSocketErrorListener(I2PSocket.SocketErrorListener lsnr) {
} }