1 /* Socket.java -- Client socket implementation
2 Copyright (C) 1998, 1999, 2000, 2002 Free Software Foundation, Inc.
4 This file is part of GNU Classpath.
6 GNU Classpath is free software; you can redistribute it and/or modify
7 it under the terms of the GNU General Public License as published by
8 the Free Software Foundation; either version 2, or (at your option)
11 GNU Classpath is distributed in the hope that it will be useful, but
12 WITHOUT ANY WARRANTY; without even the implied warranty of
13 MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
14 General Public License for more details.
16 You should have received a copy of the GNU General Public License
17 along with GNU Classpath; see the file COPYING. If not, write to the
18 Free Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
21 Linking this library statically or dynamically with other modules is
22 making a combined work based on this library. Thus, the terms and
23 conditions of the GNU General Public License cover the whole
26 As a special exception, the copyright holders of this library give you
27 permission to link this library with independent modules to produce an
28 executable, regardless of the license terms of these independent
29 modules, and to copy and distribute the resulting executable under
30 terms of your choice, provided that you also meet, for each linked
31 independent module, the terms and conditions of the license of that
32 module. An independent module is a module which is not derived from
33 or based on this library. If you modify this library, you may extend
34 this exception to your version of the library, but you are not
35 obligated to do so. If you do not wish to do so, delete this
36 exception statement from your version. */
41 import java
.nio
.channels
.SocketChannel
;
43 /* Written using on-line Java Platform 1.2 API Specification.
44 * Status: I believe all methods are implemented.
48 * This class models a client site socket. A socket is a TCP/IP endpoint
49 * for network communications conceptually similar to a file handle.
51 * This class does not actually do any work. Instead, it redirects all of
52 * its calls to a socket implementation object which implements the
53 * <code>SocketImpl</code> interface. The implementation class is
54 * instantiated by factory class that implements the
55 * <code>SocketImplFactory interface</code>. A default
56 * factory is provided, however the factory may be set by a call to
57 * the <code>setSocketImplFactory</code> method. Note that this may only be
58 * done once per virtual machine. If a subsequent attempt is made to set the
59 * factory, a <code>SocketException</code> will be thrown.
61 * @author Aaron M. Renn (arenn@urbanophile.com)
62 * @author Per Bothner (bothner@cygnus.com)
70 * This is the user SocketImplFactory for this class. If this variable is
71 * null, a default factory is used.
73 static SocketImplFactory factory
;
78 * The implementation object to which calls are redirected
82 SocketChannel ch
; // this field must have been set if created by SocketChannel
87 * Initializes a new instance of <code>Socket</code> object without
88 * connecting to a remote host. This useful for subclasses of socket that
89 * might want this behavior.
91 * @specnote This constructor is public since JDK 1.4
96 impl
= factory
.createSocketImpl();
98 impl
= new PlainSocketImpl();
102 * Initializes a new instance of <code>Socket</code> object without
103 * connecting to a remote host. This is useful for subclasses of socket
104 * that might want this behavior.
106 * Additionally, this socket will be created using the supplied
107 * implementation class instead the default class or one returned by a
108 * factory. This value can be <code>null</code>, but if it is, all instance
109 * methods in <code>Socket</code> should be overridden because most of them
110 * rely on this value being populated.
112 * @param impl The <code>SocketImpl</code> to use for this
113 * <code>Socket</code>
115 * @exception SocketException If an error occurs
117 protected Socket (SocketImpl impl
) throws SocketException
123 * Initializes a new instance of <code>Socket</code> and connects to the
124 * hostname and port specified as arguments.
126 * @param host The name of the host to connect to
127 * @param port The port number to connect to
129 * @exception UnknownHostException If the hostname cannot be resolved to a
131 * @exception IOException If an error occurs
133 public Socket (String host
, int port
)
134 throws UnknownHostException
, IOException
136 this(InetAddress
.getByName(host
), port
, null, 0, true);
140 * Initializes a new instance of <code>Socket</code> and connects to the
141 * address and port number specified as arguments.
143 * @param address The address to connect to
144 * @param port The port number to connect to
146 * @exception IOException If an error occurs
148 public Socket (InetAddress address
, int port
)
151 this(address
, port
, null, 0, true);
155 * Initializes a new instance of <code>Socket</code> that connects to the
156 * named host on the specified port and binds to the specified local address
159 * @param host The name of the remote host to connect to.
160 * @param port The remote port to connect to.
161 * @param loadAddr The local address to bind to.
162 * @param localPort The local port to bind to.
164 * @exception SecurityException If the <code>SecurityManager</code>
165 * exists and does not allow a connection to the specified host/port or
166 * binding to the specified local host/port.
167 * @exception IOException If a connection error occurs.
169 public Socket (String host
, int port
,
170 InetAddress localAddr
, int localPort
) throws IOException
172 this(InetAddress
.getByName(host
), port
, localAddr
, localPort
, true);
176 * Initializes a new instance of <code>Socket</code> and connects to the
177 * address and port number specified as arguments, plus binds to the
178 * specified local address and port.
180 * @param address The remote address to connect to
181 * @param port The remote port to connect to
182 * @param localAddr The local address to connect to
183 * @param localPort The local port to connect to
185 * @exception IOException If an error occurs
187 public Socket (InetAddress address
, int port
,
188 InetAddress localAddr
, int localPort
) throws IOException
190 this(address
, port
, localAddr
, localPort
, true);
194 * Initializes a new instance of <code>Socket</code> and connects to the
195 * hostname and port specified as arguments. If the stream argument is set
196 * to <code>true</code>, then a stream socket is created. If it is
197 * <code>false</code>, a datagram socket is created.
199 * @param host The name of the host to connect to
200 * @param port The port to connect to
201 * @param stream <code>true</code> for a stream socket, <code>false</code>
202 * for a datagram socket
204 * @exception IOException If an error occurs
206 * @deprecated Use the <code>DatagramSocket</code> class to create
207 * datagram oriented sockets.
209 public Socket (String host
, int port
, boolean stream
) throws IOException
211 this(InetAddress
.getByName(host
), port
, null, 0, stream
);
215 * Initializes a new instance of <code>Socket</code> and connects to the
216 * address and port number specified as arguments. If the stream param is
217 * <code>true</code>, a stream socket will be created, otherwise a datagram
220 * @param host The address to connect to
221 * @param port The port number to connect to
222 * @param stream <code>true</code> to create a stream socket,
223 * <code>false</code> to create a datagram socket.
225 * @exception IOException If an error occurs
227 * @deprecated Use the <code>DatagramSocket</code> class to create
228 * datagram oriented sockets.
230 public Socket (InetAddress host
, int port
, boolean stream
) throws IOException
232 this(host
, port
, null, 0, stream
);
236 * This constructor is where the real work takes place. Connect to the
237 * specified address and port. Use default local values if not specified,
238 * otherwise use the local host and port passed in. Create as stream or
239 * datagram based on "stream" argument.
242 * @param raddr The remote address to connect to
243 * @param rport The remote port to connect to
244 * @param laddr The local address to connect to
245 * @param lport The local port to connect to
246 * @param stream true for a stream socket, false for a datagram socket
248 * @exception IOException If an error occurs
250 private Socket(InetAddress raddr
, int rport
, InetAddress laddr
, int lport
,
251 boolean stream
) throws IOException
255 throw new IOException("Cannot initialize Socket implementation");
257 SecurityManager sm
= System
.getSecurityManager();
259 sm
.checkConnect(raddr
.getHostName(), rport
);
263 // FIXME: JCL p. 1586 says if localPort is unspecified, bind to any port,
264 // i.e. '0' and if localAddr is unspecified, use getLocalAddress() as
265 // that default. JDK 1.2 doc infers not to do a bind.
267 impl
.bind(laddr
, lport
);
270 impl
.connect(raddr
, rport
);
274 * Binds the socket to the givent local address/port
276 * @param bindpoint The address/port to bind to
278 * @exception If an error occurs
282 public void bind (SocketAddress bindpoint
) throws IOException
284 if ( !(bindpoint
instanceof InetSocketAddress
))
285 throw new IllegalArgumentException ();
287 InetSocketAddress tmp
= (InetSocketAddress
) bindpoint
;
288 impl
.bind (tmp
.getAddress(), tmp
.getPort());
292 * Connects the socket with a remote address.
294 * @param endpoint The address to connect to
296 * @exception IOException If an error occurs
300 public void connect (SocketAddress endpoint
)
303 impl
.connect (endpoint
, 0);
307 * Connects the socket with a remote address. A timeout of zero is
308 * interpreted as an infinite timeout. The connection will then block
309 * until established or an error occurs.
311 * @param endpoint The address to connect to
313 * @exception IOException If an error occurs
317 public void connect (SocketAddress endpoint
, int timeout
)
320 impl
.connect (endpoint
, timeout
);
324 * Returns the address of the remote end of the socket. If this socket
325 * is not connected, then <code>null</code> is returned.
327 * @return The remote address this socket is connected to
329 public InetAddress
getInetAddress ()
332 return impl
.getInetAddress();
338 * Returns the local address to which this socket is bound. If this socket
339 * is not connected, then <code>null</code> is returned.
341 * @return The local address
343 public InetAddress
getLocalAddress ()
348 InetAddress addr
= null;
351 addr
= (InetAddress
)impl
.getOption(SocketOptions
.SO_BINDADDR
);
353 catch(SocketException e
)
355 // (hopefully) shouldn't happen
356 // throw new java.lang.InternalError
357 // ("Error in PlainSocketImpl.getOption");
361 // FIXME: According to libgcj, checkConnect() is supposed to be called
362 // before performing this operation. Problems: 1) We don't have the
363 // addr until after we do it, so we do a post check. 2). The docs I
364 // see don't require this in the Socket case, only DatagramSocket, but
365 // we'll assume they mean both.
366 SecurityManager sm
= System
.getSecurityManager();
368 sm
.checkConnect(addr
.getHostName(), getLocalPort());
374 * Returns the port number of the remote end of the socket connection. If
375 * this socket is not connected, then -1 is returned.
377 * @return The remote port this socket is connected to
379 public int getPort ()
382 return impl
.getPort();
388 * Returns the local port number to which this socket is bound. If this
389 * socket is not connected, then -1 is returned.
391 * @return The local port
393 public int getLocalPort ()
396 return impl
.getLocalPort();
402 * Returns an InputStream for reading from this socket.
404 * @return The InputStream object
406 * @exception IOException If an error occurs or Socket is not connected
408 public InputStream
getInputStream () throws IOException
411 return(impl
.getInputStream());
413 throw new IOException("Not connected");
417 * Returns an OutputStream for writing to this socket.
419 * @return The OutputStream object
421 * @exception IOException If an error occurs or Socket is not connected
423 public OutputStream
getOutputStream () throws IOException
426 return impl
.getOutputStream();
428 throw new IOException("Not connected");
432 * Sets the TCP_NODELAY option on the socket.
434 * @param on true to enable, false to disable
436 * @exception SocketException If an error occurs or Socket is not connected
438 public void setTcpNoDelay (boolean on
) throws SocketException
441 throw new SocketException("Not connected");
443 impl
.setOption(SocketOptions
.TCP_NODELAY
, new Boolean(on
));
447 * Tests whether or not the TCP_NODELAY option is set on the socket.
448 * Returns true if enabled, false if disabled. When on it disables the
449 * Nagle algorithm which means that packets are always send immediatly and
450 * never merged together to reduce network trafic.
452 * @return Whether or not TCP_NODELAY is set
454 * @exception SocketException If an error occurs or Socket not connected
456 public boolean getTcpNoDelay() throws SocketException
459 throw new SocketException("Not connected");
461 Object on
= impl
.getOption(SocketOptions
.TCP_NODELAY
);
463 if (on
instanceof Boolean
)
464 return(((Boolean
)on
).booleanValue());
466 throw new SocketException("Internal Error");
470 * Sets the value of the SO_LINGER option on the socket. If the
471 * SO_LINGER option is set on a socket and there is still data waiting to
472 * be sent when the socket is closed, then the close operation will block
473 * until either that data is delivered or until the timeout period
474 * expires. The linger interval is specified in hundreths of a second
475 * (platform specific?)
477 * @param on true to enable SO_LINGER, false to disable
478 * @param linger The SO_LINGER timeout in hundreths of a second or -1 if
481 * @exception SocketException If an error occurs or Socket not connected
483 public void setSoLinger(boolean on
, int linger
) throws SocketException
486 throw new SocketException("No socket created");
491 throw new IllegalArgumentException("SO_LINGER must be >= 0");
496 impl
.setOption(SocketOptions
.SO_LINGER
, new Integer(linger
));
500 impl
.setOption(SocketOptions
.SO_LINGER
, new Boolean(false));
505 * Returns the value of the SO_LINGER option on the socket. If the
506 * SO_LINGER option is set on a socket and there is still data waiting to
507 * be sent when the socket is closed, then the close operation will block
508 * until either that data is delivered or until the timeout period
509 * expires. This method either returns the timeouts (in hundredths of
510 * of a second (platform specific?)) if SO_LINGER is set, or -1 if
511 * SO_LINGER is not set.
513 * @return The SO_LINGER timeout in hundreths of a second or -1
514 * if SO_LINGER not set
516 * @exception SocketException If an error occurs or Socket is not connected
518 public int getSoLinger() throws SocketException
521 throw new SocketException("Not connected");
523 Object linger
= impl
.getOption(SocketOptions
.SO_LINGER
);
524 if (linger
instanceof Integer
)
525 return(((Integer
)linger
).intValue());
531 * Sends urgent data through the socket
533 * @param data The data to send.
534 * Only the lowest eight bits of data are sent
536 * @exception IOException If an error occurs
540 public void sendUrgentData (int data
) throws IOException
542 impl
.sendUrgentData (data
);
546 * Enables/disables the SO_OOBINLINE option
548 * @param on True if SO_OOBLINE should be enabled
550 * @exception SocketException If an error occurs
554 public void setOOBInline (boolean on
) throws SocketException
557 throw new SocketException("Not connected");
559 impl
.setOption(SocketOptions
.SO_OOBINLINE
, new Boolean(on
));
563 * Returns the current setting of the SO_OOBINLINE option for this socket
565 * @exception SocketException If an error occurs
569 public boolean getOOBInline () throws SocketException
572 throw new SocketException("Not connected");
574 Object buf
= impl
.getOption(SocketOptions
.SO_OOBINLINE
);
576 if (buf
instanceof Boolean
)
577 return(((Boolean
)buf
).booleanValue());
579 throw new SocketException("Internal Error: Unexpected type");
583 * Sets the value of the SO_TIMEOUT option on the socket. If this value
584 * is set, and an read/write is performed that does not complete within
585 * the timeout period, a short count is returned (or an EWOULDBLOCK signal
586 * would be sent in Unix if no data had been read). A value of 0 for
587 * this option implies that there is no timeout (ie, operations will
588 * block forever). On systems that have separate read and write timeout
589 * values, this method returns the read timeout. This
590 * value is in thousandths of a second (****????*****)
592 * @param timeout The length of the timeout in thousandth's of a second or
595 * @exception SocketException If an error occurs or Socket not connected
597 public synchronized void setSoTimeout (int timeout
) throws SocketException
600 throw new SocketException("Not connected");
603 throw new IllegalArgumentException("SO_TIMEOUT value must be >= 0");
605 impl
.setOption(SocketOptions
.SO_TIMEOUT
, new Integer(timeout
));
609 * Returns the value of the SO_TIMEOUT option on the socket. If this value
610 * is set, and an read/write is performed that does not complete within
611 * the timeout period, a short count is returned (or an EWOULDBLOCK signal
612 * would be sent in Unix if no data had been read). A value of 0 for
613 * this option implies that there is no timeout (ie, operations will
614 * block forever). On systems that have separate read and write timeout
615 * values, this method returns the read timeout. This
616 * value is in thousandths of a second (implementation specific?).
618 * @return The length of the timeout in thousandth's of a second or 0
621 * @exception SocketException If an error occurs or Socket not connected
623 public synchronized int getSoTimeout () throws SocketException
626 throw new SocketException("Not connected");
628 Object timeout
= impl
.getOption(SocketOptions
.SO_TIMEOUT
);
629 if (timeout
instanceof Integer
)
630 return(((Integer
)timeout
).intValue());
636 * This method sets the value for the system level socket option
637 * SO_SNDBUF to the specified value. Note that valid values for this
638 * option are specific to a given operating system.
640 * @param size The new send buffer size.
642 * @exception SocketException If an error occurs or Socket not connected
646 public void setSendBufferSize (int size
) throws SocketException
649 throw new SocketException("Not connected");
652 throw new IllegalArgumentException("SO_SNDBUF value must be > 0");
654 impl
.setOption(SocketOptions
.SO_SNDBUF
, new Integer(size
));
658 * This method returns the value of the system level socket option
659 * SO_SNDBUF, which is used by the operating system to tune buffer
660 * sizes for data transfers.
662 * @return The send buffer size.
664 * @exception SocketException If an error occurs or socket not connected
668 public int getSendBufferSize () throws SocketException
671 throw new SocketException("Not connected");
673 Object buf
= impl
.getOption(SocketOptions
.SO_SNDBUF
);
675 if (buf
instanceof Integer
)
676 return(((Integer
)buf
).intValue());
678 throw new SocketException("Internal Error: Unexpected type");
682 * This method sets the value for the system level socket option
683 * SO_RCVBUF to the specified value. Note that valid values for this
684 * option are specific to a given operating system.
686 * @param size The new receive buffer size.
688 * @exception SocketException If an error occurs or Socket is not connected
692 public void setReceiveBufferSize (int size
) throws SocketException
695 throw new SocketException("Not connected");
698 throw new IllegalArgumentException("SO_RCVBUF value must be > 0");
700 impl
.setOption(SocketOptions
.SO_RCVBUF
, new Integer(size
));
704 * This method returns the value of the system level socket option
705 * SO_RCVBUF, which is used by the operating system to tune buffer
706 * sizes for data transfers.
708 * @return The receive buffer size.
710 * @exception SocketException If an error occurs or Socket is not connected
714 public int getReceiveBufferSize () throws SocketException
717 throw new SocketException("Not connected");
719 Object buf
= impl
.getOption(SocketOptions
.SO_RCVBUF
);
721 if (buf
instanceof Integer
)
722 return(((Integer
)buf
).intValue());
724 throw new SocketException("Internal Error: Unexpected type");
728 * This method sets the value for the socket level socket option
731 * @param on True if SO_KEEPALIVE should be enabled
733 * @exception SocketException If an error occurs or Socket is not connected
737 public void setKeepAlive (boolean on
) throws SocketException
740 throw new SocketException("Not connected");
742 impl
.setOption(SocketOptions
.SO_KEEPALIVE
, new Boolean(on
));
746 * This method returns the value of the socket level socket option
749 * @return The setting
751 * @exception SocketException If an error occurs or Socket is not connected
755 public boolean getKeepAlive () throws SocketException
758 throw new SocketException("Not connected");
760 Object buf
= impl
.getOption(SocketOptions
.SO_KEEPALIVE
);
762 if (buf
instanceof Boolean
)
763 return(((Boolean
)buf
).booleanValue());
765 throw new SocketException("Internal Error: Unexpected type");
771 * @exception IOException If an error occurs
773 public synchronized void close () throws IOException
780 * Converts this <code>Socket</code> to a <code>String</code>.
782 * @return The <code>String</code> representation of this <code>Socket</code>
784 public String
toString ()
786 return("Socket " + impl
);
792 * Sets the <code>SocketImplFactory</code>. This may be done only once per
793 * virtual machine. Subsequent attempts will generate a
794 * <code>SocketException</code>. Note that a <code>SecurityManager</code>
795 * check is made prior to setting the factory. If
796 * insufficient privileges exist to set the factory, then an
797 * <code>IOException</code> will be thrown.
799 * @exception SecurityException If the <code>SecurityManager</code> does
800 * not allow this operation.
801 * @exception SocketException If the SocketImplFactory is already defined
802 * @exception IOException If any other error occurs
804 public static synchronized void setSocketImplFactory (SocketImplFactory fac
)
807 // See if already set
809 throw new SocketException("SocketImplFactory already defined");
812 SecurityManager sm
= System
.getSecurityManager();
814 sm
.checkSetFactory();
820 * Closes the input side of the socket stream.
822 * @exception IOException If an error occurs.
824 public void shutdownInput() throws IOException
827 impl
.shutdownInput();
831 * Closes the output side of the socket stream.
833 * @exception IOException If an error occurs.
835 public void shutdownOutput() throws IOException
838 impl
.shutdownOutput();
842 * Returns the socket channel associated with this socket.
844 * It returns null if no associated socket exists.
846 public SocketChannel
getChannel()