X-Git-Url: http://git.megacz.com/?p=org.ibex.io.git;a=blobdiff_plain;f=src%2Forg%2Fibex%2Fio%2FConnection.java;fp=src%2Forg%2Fibex%2Fio%2FConnection.java;h=5c8c0fdc435f61897150089a0dbe9484417edaee;hp=5c8d148cbdb0ce6ef88c011384faa9990939b0de;hb=3b2ea827949a6b21b360f43dc829e34650d9c203;hpb=1594d72289e3da167db29dc470b9a3b3080bd676 diff --git a/src/org/ibex/io/Connection.java b/src/org/ibex/io/Connection.java index 5c8d148..5c8c0fd 100644 --- a/src/org/ibex/io/Connection.java +++ b/src/org/ibex/io/Connection.java @@ -13,8 +13,9 @@ public class Connection extends Stream { private final Socket s; public final String vhost; public Connection(Socket s, String vhost) { super(s); this.vhost = vhost; this.s = s; } + protected Connection(InputStream i, OutputStream o) { super(i, o); vhost = null; s = null; } public Socket getSocket() { return s; } - public void close() { try{s.close();}catch(Exception e){throw new Stream.StreamException(e);} super.close(); } + public void close() { try{if (s!=null) s.close();}catch(Exception e){throw new Stream.StreamException(e);} super.close(); } public int getLocalPort() { return s.getLocalPort(); } public InetAddress getLocalAddress() { return ((InetSocketAddress)s.getLocalSocketAddress()).getAddress(); } public int getRemotePort() { return s.getPort(); }