libjava/java/net/Socket.java

   1 // Socket.java
   2
   3 /* Copyright (C) 1999  Cygnus Solutions
   4
   5    This file is part of libgcj.
   6
   7 This software is copyrighted work licensed under the terms of the
   8 Libgcj License.  Please consult the file "LIBGCJ_LICENSE" for
   9 details.  */
  10
  11 /**
  12   * @author Per Bothner <bothner@cygnus.com>
  13   * @date January 6, 1999.
  14   */
  15
  16 /** Written using on-line Java Platform 1.2 API Specification.
  17   * Status:  I believe all methods are implemented.
  18   */
  19
  20 package java.net;
  21 import java.io.*;
  22
  23 public class Socket
  24 {
  25   static SocketImplFactory factory;
  26   SocketImpl impl;
  27
  28   protected Socket ()
  29   {
  30   }
  31
  32   protected Socket (SocketImpl impl) throws SocketException
  33   {
  34     this.impl = impl;
  35   }
  36
  37   public Socket (String host, int port)
  38     throws UnknownHostException, IOException
  39   {
  40     this(factory == null ? new PlainSocketImpl() : factory.createSocketImpl());
  41     SecurityManager s = System.getSecurityManager();
  42     if (s != null)
  43       s.checkConnect(host, port);
  44     impl.create(true);
  45     // FIXME: JCL p. 1586 says if localPort is unspecified, bind to any port,
  46     // i.e. '0' and if localAddr is unspecified, use getLocalAddress() as
  47     // that default.  JDK 1.2 doc infers not to do a bind.
  48     impl.connect(host, port);
  49   }
  50
  51   public Socket (InetAddress address, int port)
  52     throws IOException
  53   {
  54     this(factory == null ? new PlainSocketImpl() : factory.createSocketImpl());
  55     SecurityManager s = System.getSecurityManager();
  56     if (s != null)
  57       s.checkConnect(address.getHostName(), port);
  58     impl.create(true);
  59     // FIXME: JCL p. 1586 says if localPort is unspecified, bind to any port,
  60     // i.e. '0' and if localAddr is unspecified, use getLocalAddress() as
  61     // that default.  JDK 1.2 doc infers not to do a bind.
  62     impl.connect(address, port);
  63   }
  64
  65   public Socket (String host, int port,
  66                  InetAddress localAddr, int localPort) throws IOException
  67   {
  68     this(factory == null ? new PlainSocketImpl() : factory.createSocketImpl());
  69     SecurityManager s = System.getSecurityManager();
  70     if (s != null)
  71       s.checkConnect(host, port);
  72     impl.create(true);
  73     // FIXME: JCL p. 1587 says if localAddr is null, use getLocalAddress().
  74     impl.bind(localAddr, localPort);
  75     impl.connect(host, port);
  76   }
  77
  78   public Socket (InetAddress address, int port,
  79                  InetAddress localAddr, int localPort) throws IOException
  80   {
  81     this(factory == null ? new PlainSocketImpl() : factory.createSocketImpl());
  82     SecurityManager s = System.getSecurityManager();
  83     if (s != null)
  84       s.checkConnect(address.getHostName(), port);
  85     impl.create(true);
  86     // FIXME: JCL p. 1587 says if localAddr is null, use getLocalAddress().
  87     impl.bind(localAddr, localPort);
  88     impl.connect(address, port);
  89   }
  90
  91   /**
  92    * @deprecated Use DatagramSocket instead for UDP transport.
  93    */
  94   public Socket (String host, int port, boolean stream) throws IOException
  95   {
  96     impl = factory == null ? new PlainSocketImpl()
  97       : factory.createSocketImpl();
  98     impl.create(stream);
  99     SecurityManager s = System.getSecurityManager();
 100     if (s != null)
 101       s.checkConnect(host, port);
 102     // FIXME: JCL p. 1586 says if localPort is unspecified, bind to any port,
 103     // i.e. '0' and if localAddr is unspecified, use getLocalAddress() as
 104     // that default.  JDK 1.2 doc infers not to do a bind.
 105     impl.connect(host, port);
 106   }
 107
 108   /**
 109    * @deprecated Use DatagramSocket instead for UDP transport.
 110    */
 111   public Socket (InetAddress host, int port, boolean stream) throws IOException
 112   {
 113     impl = factory == null ? new PlainSocketImpl()
 114       : factory.createSocketImpl();
 115     impl.create(stream);
 116     SecurityManager s = System.getSecurityManager();
 117     if (s != null)
 118       s.checkConnect(host.getHostName(), port);
 119     // FIXME: JCL p. 1586 says if localPort is unspecified, bind to any port,
 120     // i.e. '0' and if localAddr is unspecified, use getLocalAddress() as
 121     // that default.  JDK 1.2 doc infers not to do a bind.
 122     impl.connect(host, port);
 123   }
 124
 125   public InetAddress getInetAddress ()
 126   {
 127     return impl.getInetAddress();
 128   }
 129
 130   public InetAddress getLocalAddress ()
 131   {
 132     InetAddress localAddress;
 133     try
 134       {
 135         localAddress = (InetAddress)impl.getOption(SocketOptions.SO_BINDADDR);
 136       }
 137     catch (SocketException x)
 138       {
 139         // (hopefully) shouldn't happen
 140         System.err.println(x);
 141         throw new java.lang.InternalError("Error in PlainSocketImpl.getOption");
 142       }
 143     return localAddress;
 144   }
 145
 146   public int getPort ()
 147   {
 148     return impl.getPort();
 149   }
 150
 151   public int getLocalPort ()
 152   {
 153     return impl.getLocalPort();
 154   }
 155
 156   public InputStream getInputStream () throws IOException
 157   {
 158     return impl.getInputStream();
 159   }
 160
 161   public OutputStream getOutputStream () throws IOException
 162   {
 163     return impl.getOutputStream();
 164   }
 165
 166   public void setTcpNoDelay (boolean on)  throws SocketException
 167   {
 168     impl.setOption( SocketOptions.TCP_NODELAY, new Boolean(on) );
 169   }
 170
 171   public boolean getTcpNoDelay() throws SocketException
 172   {
 173     Boolean bool = (Boolean)impl.getOption( SocketOptions.TCP_NODELAY );
 174     return bool.booleanValue();
 175   }
 176
 177   public void setSoLinger(boolean on, int linger) throws SocketException
 178   {
 179     if ( on && (linger >= 0) )
 180       {
 181         if (linger > 65535)
 182           linger = 65535;
 183         impl.setOption( SocketOptions.SO_LINGER, new Integer(linger) );
 184       }
 185     else if ( on && (linger < 0) )
 186       throw new IllegalArgumentException("SO_LINGER must be >= 0");
 187     else
 188       impl.setOption( SocketOptions.SO_LINGER, new Boolean(false) );
 189   }
 190
 191   public int getSoLinger() throws SocketException
 192   {
 193     Object linger = impl.getOption(SocketOptions.SO_LINGER);
 194     if (linger instanceof Integer)
 195       return ((Integer)linger).intValue();
 196     else
 197       return -1;
 198   }
 199
 200   public synchronized void setSoTimeout (int timeout) throws SocketException
 201   {
 202     if (timeout < 0)
 203       throw new IllegalArgumentException("Invalid timeout: " + timeout);
 204
 205     impl.setOption(SocketOptions.SO_TIMEOUT, new Integer(timeout));
 206   }
 207
 208   public synchronized int getSoTimeout () throws SocketException
 209   {
 210     Object timeout = impl.getOption(SocketOptions.SO_TIMEOUT);
 211     if (timeout instanceof Integer)
 212       return ((Integer)timeout).intValue();
 213     else
 214       return 0;
 215   }
 216
 217   // JDK1.2
 218   public void setSendBufferSize (int size) throws SocketException
 219   {
 220     if (size <= 0)
 221       throw new IllegalArgumentException("Invalid buffer size: " + size);
 222
 223     impl.setOption(SocketOptions.SO_SNDBUF, new Integer(size));
 224   }
 225
 226   // JDK1.2
 227   public int getSendBufferSize () throws SocketException
 228   {
 229     Integer buf = (Integer)impl.getOption(SocketOptions.SO_SNDBUF);
 230     return buf.intValue();
 231   }
 232
 233   // JDK1.2
 234   public void setReceiveBufferSize (int size) throws SocketException
 235   {
 236     if (size <= 0)
 237       throw new IllegalArgumentException("Invalid buffer size: " + size);
 238
 239     impl.setOption(SocketOptions.SO_RCVBUF, new Integer(size));
 240   }
 241
 242   // JDK1.2
 243   public int getReceiveBufferSize () throws SocketException
 244   {
 245     Integer buf = (Integer)impl.getOption(SocketOptions.SO_RCVBUF);
 246     return buf.intValue();
 247   }
 248
 249   public synchronized void close ()  throws IOException
 250   {
 251     impl.close();
 252   }
 253
 254   public String toString ()
 255   {
 256     return "Socket" + impl.toString();
 257   }
 258
 259   public static synchronized void setSocketImplFactory (SocketImplFactory fac)
 260     throws IOException
 261   {
 262     factory = fac;
 263   }
 264 }