diff --git a/apps/streaming/java/src/net/i2p/client/streaming/impl/StandardServerSocket.java b/apps/streaming/java/src/net/i2p/client/streaming/impl/StandardServerSocket.java index aaab086f05767200e33c047e1e3ca9f76379312b..0fecaa3cf9d90ef9ea0542eaf748c8c25f1bdb46 100644 --- a/apps/streaming/java/src/net/i2p/client/streaming/impl/StandardServerSocket.java +++ b/apps/streaming/java/src/net/i2p/client/streaming/impl/StandardServerSocket.java @@ -10,6 +10,7 @@ import java.nio.channels.ServerSocketChannel; import net.i2p.I2PException; import net.i2p.client.streaming.I2PSocket; +import net.i2p.client.streaming.I2PSocketAddress; /** * Bridge to I2PServerSocket. @@ -99,11 +100,14 @@ class StandardServerSocket extends ServerSocket { } /** - * @return null always + * Port in returned SocketAddress will be zero. + * + * @return an I2PSocketAddress as of 0.9.26; prior to that, returned null + * @since implemented in 0.9.26 */ @Override public SocketAddress getLocalSocketAddress() { - return null; + return new I2PSocketAddress(_socket.getManager().getSession().getMyDestination(), 0); } @Override diff --git a/apps/streaming/java/src/net/i2p/client/streaming/impl/StandardSocket.java b/apps/streaming/java/src/net/i2p/client/streaming/impl/StandardSocket.java index 151c1f3959ab452611982b58ff17d1762d1658cd..0a1fb093e66d6facee5a974de524c1423675efdd 100644 --- a/apps/streaming/java/src/net/i2p/client/streaming/impl/StandardSocket.java +++ b/apps/streaming/java/src/net/i2p/client/streaming/impl/StandardSocket.java @@ -10,6 +10,7 @@ import java.net.SocketException; import java.nio.channels.SocketChannel; import net.i2p.client.streaming.I2PSocket; +import net.i2p.client.streaming.I2PSocketAddress; import net.i2p.client.streaming.I2PSocketOptions; /** @@ -117,11 +118,12 @@ class StandardSocket extends Socket { } /** - * @return null always + * @return an I2PSocketAddress as of 0.9.26; prior to that, returned null + * @since implemented in 0.9.26 */ @Override public SocketAddress getLocalSocketAddress() { - return null; + return new I2PSocketAddress(_socket.getThisDestination(), _socket.getLocalPort()); } /** @@ -157,11 +159,12 @@ class StandardSocket extends Socket { } /** - * @throws UnsupportedOperationException always + * @return an I2PSocketAddress as of 0.9.26; prior to that, threw UnsupportedOperationException + * @since implemented in 0.9.26 */ @Override public SocketAddress getRemoteSocketAddress() { - throw new UnsupportedOperationException(); + return new I2PSocketAddress(_socket.getPeerDestination(), _socket.getPort()); } /**