+++ /dev/null
-/*
- * Written by Dawid Kurzyniec and released to the public domain, as explained
- * at http://creativecommons.org/licenses/publicdomain
- */
-
-//package edu.emory.mathcs.util.net;
-
-import java.io.*;
-import java.net.*;
-import java.nio.channels.*;
-
-/**
- * Wrapper for sockets which enables to add functionality in subclasses
- * on top of existing, connected sockets. It is useful when direct subclassing
- * of delegate socket class is not possible, e.g. if the delegate socket is
- * created by a library. Possible usage example is socket factory chaining.
- * This class delegates all socket-related requests to the wrapped delegate,
- * as of JDK 1.4.
- *
- * @author Dawid Kurzyniec
- * @version 1.4
- */
-public abstract class SocketWrapper extends Socket {
-
- /**
- * the wrapped delegate socket.
- */
- protected final Socket delegate;
-
- /**
- * Creates new socket wrapper for a given socket. The delegate
- * must be connected and bound and it must not be closed.
- * @param delegate the delegate socket to wrap
- * @throws SocketException if the delegate socket is closed, not bound,
- * or not connected
- */
- protected SocketWrapper(Socket delegate) throws SocketException {
- super(new WrappingSocketImpl(delegate));
- this.delegate = delegate;
- }
-
- public SocketChannel getChannel() {
- return delegate.getChannel();
- }
-
- /**
- * Returns true, indicating that the socket is bound.
- *
- * @return true
- */
- public boolean isBound() {
- return true;
- }
-
- public boolean isClosed() {
- return super.isClosed() || delegate.isClosed();
- }
-
- /**
- * Returns true, indicating that the socket is connected.
- *
- * @return true
- */
- public boolean isConnected() {
- return true;
- }
-
- public boolean isInputShutdown() {
- return super.isInputShutdown() || delegate.isInputShutdown();
- }
-
- public boolean isOutputShutdown() {
- return super.isInputShutdown() || delegate.isOutputShutdown();
- }
-
- private static class WrappingSocketImpl extends SocketImpl {
- private final Socket delegate;
- WrappingSocketImpl(Socket delegate) throws SocketException {
- if (delegate == null) {
- throw new NullPointerException();
- }
- if (delegate.isClosed()) {
- throw new SocketException("Delegate server socket is closed");
- }
- if (!(delegate.isBound())) {
- throw new SocketException("Delegate server socket is not bound");
- }
- if (!(delegate.isConnected())) {
- throw new SocketException("Delegate server socket is not connected");
- }
- this.delegate = delegate;
- }
-
- protected void create(boolean stream) {}
-
- protected void connect(String host, int port) {
- // delegate is always connected, thus this method is never called
- throw new UnsupportedOperationException();
- }
-
- protected void connect(InetAddress address, int port) {
- // delegate is always connected, thus this method is never called
- throw new UnsupportedOperationException();
- }
-
- protected void connect(SocketAddress address, int timeout) {
- // delegate is always connected, thus this method is never called
- throw new UnsupportedOperationException();
- }
-
- protected void bind(InetAddress host, int port) {
- // delegate is always bound, thus this method is never called
- throw new UnsupportedOperationException();
- }
-
- protected void listen(int backlog) {
- // this wrapper is never used by a ServerSocket
- throw new UnsupportedOperationException();
- }
-
- protected void accept(SocketImpl s) {
- // this wrapper is never used by a ServerSocket
- throw new UnsupportedOperationException();
- }
-
- protected InputStream getInputStream() throws IOException {
- return delegate.getInputStream();
- }
-
- protected OutputStream getOutputStream() throws IOException {
- return delegate.getOutputStream();
- }
-
- protected int available() throws IOException {
- return getInputStream().available();
- }
-
- protected void close() throws IOException {
- delegate.close();
- }
-
- protected void shutdownInput() throws IOException {
- delegate.shutdownInput();
- }
-
- protected void shutdownOutput() throws IOException {
- delegate.shutdownOutput();
- }
-
- protected FileDescriptor getFileDescriptor() {
- // this wrapper is never used by a ServerSocket
- throw new UnsupportedOperationException();
- }
-
- protected InetAddress getInetAddress() {
- return delegate.getInetAddress();
- }
-
- protected int getPort() {
- return delegate.getPort();
- }
-
- protected boolean supportsUrgentData() {
- return false; // must be overridden in sub-class
- }
-
- protected void sendUrgentData (int data) throws IOException {
- delegate.sendUrgentData(data);
- }
-
- protected int getLocalPort() {
- return delegate.getLocalPort();
- }
-
- public Object getOption(int optID) throws SocketException {
- switch (optID) {
- case SocketOptions.IP_TOS:
- return new Integer(delegate.getTrafficClass());
- case SocketOptions.SO_BINDADDR:
- return delegate.getLocalAddress();
- case SocketOptions.SO_KEEPALIVE:
- return Boolean.valueOf(delegate.getKeepAlive());
- case SocketOptions.SO_LINGER:
- return new Integer(delegate.getSoLinger());
- case SocketOptions.SO_OOBINLINE:
- return Boolean.valueOf(delegate.getOOBInline());
- case SocketOptions.SO_RCVBUF:
- return new Integer(delegate.getReceiveBufferSize());
- case SocketOptions.SO_REUSEADDR:
- return Boolean.valueOf(delegate.getReuseAddress());
- case SocketOptions.SO_SNDBUF:
- return new Integer(delegate.getSendBufferSize());
- case SocketOptions.SO_TIMEOUT:
- return new Integer(delegate.getSoTimeout());
- case SocketOptions.TCP_NODELAY:
- return Boolean.valueOf(delegate.getTcpNoDelay());
- case SocketOptions.SO_BROADCAST:
- default:
- throw new IllegalArgumentException("Unsupported option type");
- }
- }
-
- public void setOption(int optID, Object value) throws SocketException {
- switch (optID) {
- case SocketOptions.SO_BINDADDR:
- throw new IllegalArgumentException("Socket is bound");
- case SocketOptions.SO_KEEPALIVE:
- delegate.setKeepAlive(((Boolean)value).booleanValue());
- break;
- case SocketOptions.SO_LINGER:
- if (value instanceof Boolean) {
- delegate.setSoLinger(((Boolean)value).booleanValue(), 0);
- }
- else {
- delegate.setSoLinger(true, ((Integer)value).intValue());
- }
- break;
- case SocketOptions.SO_OOBINLINE:
- delegate.setOOBInline(((Boolean)value).booleanValue());
- break;
- case SocketOptions.SO_RCVBUF:
- delegate.setReceiveBufferSize(((Integer)value).intValue());
- break;
- case SocketOptions.SO_REUSEADDR:
- delegate.setReuseAddress(((Boolean)value).booleanValue());
- break;
- case SocketOptions.SO_SNDBUF:
- delegate.setSendBufferSize(((Integer)value).intValue());
- break;
- case SocketOptions.SO_TIMEOUT:
- delegate.setSoTimeout(((Integer)value).intValue());
- break;
- case SocketOptions.TCP_NODELAY:
- delegate.setTcpNoDelay(((Boolean)value).booleanValue());
- break;
- case SocketOptions.SO_BROADCAST:
- default:
- throw new IllegalArgumentException("Unsupported option type");
- }
- }
- }
-
- public boolean equals(Object obj) {
- if (!(obj instanceof SocketWrapper)) return false;
- SocketWrapper that = (SocketWrapper)obj;
- return this.delegate.equals(that.delegate);
- }
-
- public int hashCode() {
- return delegate.hashCode() ^ 0x01010101;
- }
-}
\ No newline at end of file
projects / invirt/packages/invirt-vnc-client.git / blobdiff