---

java.net
Class SocksSocketImpl

java.lang.Object
 |
 +--java.net.SocketImpl
 |
 +--java.net.PlainSocketImpl
 |
 +--java.net.SocksSocketImpl

All Implemented Interfaces:

SocketOptions, SocksConsts

---

class SocksSocketImpl

extends PlainSocketImpl

implements SocksConsts

SOCKS (V4 & V5) TCP socket implementation (RFC 1928). This is a subclass of PlainSocketImpl. Note this class should NOT be public.

---

server

private String server

---

port

private int port

---

external_address

private InetSocketAddress external_address

---

useV4

private boolean useV4

---

cmdsock

private Socket cmdsock

---

cmdIn

private InputStream cmdIn

---

cmdOut

private OutputStream cmdOut

---

PROTO_VERS4

public static final int PROTO_VERS4

---

PROTO_VERS

public static final int PROTO_VERS

---

DEFAULT_PORT

public static final int DEFAULT_PORT

---

NO_AUTH

public static final int NO_AUTH

---

GSSAPI

public static final int GSSAPI

---

USER_PASSW

public static final int USER_PASSW

---

NO_METHODS

public static final int NO_METHODS

---

CONNECT

public static final int CONNECT

---

BIND

public static final int BIND

---

UDP_ASSOC

public static final int UDP_ASSOC

---

IPV4

public static final int IPV4

---

DOMAIN_NAME

public static final int DOMAIN_NAME

---

IPV6

public static final int IPV6

---

REQUEST_OK

public static final int REQUEST_OK

---

GENERAL_FAILURE

public static final int GENERAL_FAILURE

---

NOT_ALLOWED

public static final int NOT_ALLOWED

---

NET_UNREACHABLE

public static final int NET_UNREACHABLE

---

HOST_UNREACHABLE

public static final int HOST_UNREACHABLE

---

CONN_REFUSED

public static final int CONN_REFUSED

---

TTL_EXPIRED

public static final int TTL_EXPIRED

---

CMD_NOT_SUPPORTED

public static final int CMD_NOT_SUPPORTED

---

ADDR_TYPE_NOT_SUP

public static final int ADDR_TYPE_NOT_SUP

---

timeout

int timeout

---

SHUT_RD

public static final int SHUT_RD

---

SHUT_WR

public static final int SHUT_WR

SocksSocketImpl

SocksSocketImpl(String server,
 int port)

setV4

void setV4()

---

privilegedConnect

private void privilegedConnect(String host,
 int port,
 int timeout)
 throws IOException

IOException

---

superConnectServer

private void superConnectServer(String host,
 int port,
 int timeout)
 throws IOException

IOException

---

readSocksReply

private int readSocksReply(InputStream in,
 byte[] data)
 throws IOException

IOException

---

authenticate

private boolean authenticate(byte method,
 InputStream in,
 DataOutputStream out)
 throws IOException

Provides the authentication machanism required by the proxy.

IOException

---

connectV4

private void connectV4(InputStream in,
 OutputStream out,
 InetSocketAddress endpoint)
 throws IOException

IOException

---

connect

protected void connect(SocketAddress endpoint,
 int timeout)
 throws IOException

Connects the Socks Socket to the specified endpoint. It will first connect to the SOCKS proxy and negotiate the access. If the proxy grants the connections, then the connect is successful and all further traffic will go to the "real" endpoint.

Overrides:

connect in class PlainSocketImpl

Parameters:

endpoint - the SocketAddress to connect to.

timeout - the timeout value in milliseconds

Throws:

IOException - if the connection can't be established.

SecurityException - if there is a security manager and it doesn't allow the connection

IllegalArgumentException - if endpoint is null or a SocketAddress subclass not supported by this socket

---

bindV4

private void bindV4(InputStream in,
 OutputStream out,
 InetAddress baddr,
 int lport)
 throws IOException

IOException

---

bind

protected void bind(InetAddress baddr,
 int lport)
 throws IOException

Binds this socket to the specified port number on the specified host.

Overrides:

bind in class PlainSocketImpl

Parameters:

baddr - the IP address of the remote host.

lport - the port number.

IOException

---

accept

protected void accept(SocketImpl s)
 throws IOException

Accepts a connection.

Overrides:

accept in class PlainSocketImpl

Parameters:

s - the accepted connection.

IOException

---

getInetAddress

protected InetAddress getInetAddress()

Returns the value of this socket's address field.

Overrides:

getInetAddress in class SocketImpl

Returns:

the value of this socket's address field.

See Also:

java.net.SocketImpl#address

---

getPort

protected int getPort()

Returns the value of this socket's port field.

Overrides:

getPort in class SocketImpl

Returns:

the value of this socket's port field.

See Also:

java.net.SocketImpl#port

---

getLocalPort

protected int getLocalPort()

Description copied from class: SocketImpl

Returns the value of this socket's localport field.

Overrides:

getLocalPort in class SocketImpl

Returns:

the value of this socket's localport field.

See Also:

java.net.SocketImpl#localport

---

close

protected void close()
 throws IOException

Description copied from class: PlainSocketImpl

Closes the socket.

Overrides:

close in class PlainSocketImpl

IOException

---

create

protected void create(boolean stream)
 throws IOException

Creates a socket with a boolean that specifies whether this is a stream socket (true) or an unconnected UDP socket (false).

Specified by:

create in class SocketImpl

Parameters:

stream - if true, create a stream socket; otherwise, create a datagram socket.

IOException

---

connect

protected void connect(String host,
 int port)
 throws UnknownHostException,
 IOException

Creates a socket and connects it to the specified port on the specified host.

Specified by:

connect in class SocketImpl

Parameters:

host - the specified host

port - the specified port

UnknownHostException

IOException

---

connect

protected void connect(InetAddress address,
 int port)
 throws IOException

Creates a socket and connects it to the specified address on the specified port.

Specified by:

connect in class SocketImpl

Parameters:

address - the address

port - the specified port

IOException

---

setOption

public void setOption(int opt,
 Object val)
 throws SocketException

Description copied from interface: SocketOptions

Enabled: Enable/disable the option specified by optID. If the option is to be enabled, and it takes an option-specific "value", this is passed in value. The actual type of value is option-specific, and it is an error to pass something that isn't of the expected type:

 SocketImpl s;
 ...
 s.setOption(SO_LINGER, new Integer(10));
 // OK - set SO_LINGER w/ timeout of 10 sec.
 s.setOption(SO_LINGER, new Double(10));
 // ERROR - expects java.lang.Integer

If the requested option is binary, it can be set using this method by a java.lang.Boolean:

 s.setOption(TCP_NODELAY, new Boolean(true));
 // OK - enables TCP_NODELAY, a binary option
 

Any option can be disabled using this method with a Boolean(false):

 s.setOption(TCP_NODELAY, new Boolean(false));
 // OK - disables TCP_NODELAY
 s.setOption(SO_LINGER, new Boolean(false));
 // OK - disables SO_LINGER
 

For an option that has a notion of on and off, and requires a non-boolean parameter, setting its value to anything other than Boolean(false) implicitly enables it.
Throws SocketException if the option is unrecognized, the socket is closed, or some low-level error occurred

Parameters:

opt - identifies the option

val - the parameter of the socket option

Throws:

SocketException - if the option is unrecognized, the socket is closed, or some low-level error occurred

See Also:

SocketOptions.getOption(int)

---

getOption

public Object getOption(int opt)
 throws SocketException

Description copied from interface: SocketOptions

Enabled: Fetch the value of an option. Binary options will return java.lang.Boolean(true) if enabled, java.lang.Boolean(false) if disabled, e.g.:

 SocketImpl s;
 ...
 Boolean noDelay = (Boolean)(s.getOption(TCP_NODELAY));
 if (noDelay.booleanValue()) {
 // true if TCP_NODELAY is enabled...
 ...
 }
 

For options that take a particular type as a parameter, getOption(int) will return the paramter's value, else it will return java.lang.Boolean(false):

 Object o = s.getOption(SO_LINGER);
 if (o instanceof Integer) {
 System.out.print("Linger time is " + ((Integer)o).intValue());
 } else {
 // the true type of o is java.lang.Boolean(false);
 }
 

Parameters:

opt - an int identifying the option to fetch

Returns:

the value of the option

Throws:

SocketException - if the socket is closed

See Also:

SocketOptions.setOption(int, java.lang.Object)

---

listen

protected void listen(int count)
 throws IOException

Listens, for a specified amount of time, for connections.

Specified by:

listen in class SocketImpl

Parameters:

count - the amount of time to listen for connections

IOException

---

getInputStream

protected InputStream getInputStream()
 throws IOException

Gets an InputStream for this socket.

Specified by:

getInputStream in class SocketImpl

Returns:

a stream for reading from this socket.

IOException

---

setInputStream

void setInputStream(SocketInputStream in)

---

getOutputStream

protected OutputStream getOutputStream()
 throws IOException

Gets an OutputStream for this socket.

Specified by:

getOutputStream in class SocketImpl

Returns:

an output stream for writing to this socket.

IOException

---

available

protected int available()
 throws IOException

Returns the number of bytes that can be read without blocking.

Specified by:

available in class SocketImpl

Returns:

the number of bytes that can be read from this socket without blocking.

IOException

---

shutdownInput

protected void shutdownInput()
 throws IOException

Shutdown read-half of the socket connection;

Overrides:

shutdownInput in class SocketImpl

IOException

See Also:

java.net.Socket#shutdownOutput(), java.net.Socket#close(), java.net.Socket#setSoLinger(boolean, int)

---

shutdownOutput

protected void shutdownOutput()
 throws IOException

Shutdown write-half of the socket connection;

Overrides:

shutdownOutput in class SocketImpl

IOException

See Also:

java.net.Socket#shutdownInput(), java.net.Socket#close(), java.net.Socket#setSoLinger(boolean, int)

---

supportsUrgentData

protected boolean supportsUrgentData()

Description copied from class: SocketImpl

Returns whether or not this SocketImpl supports sending urgent data. By default, false is returned unless the method is overridden in a sub-class

Overrides:

supportsUrgentData in class SocketImpl

Returns:

true if urgent data supported

See Also:

java.net.SocketImpl#address

---

sendUrgentData

protected void sendUrgentData(int data)
 throws IOException

Description copied from class: SocketImpl

Send one byte of urgent data on the socket. The byte to be sent is the low eight bits of the parameter

Specified by:

sendUrgentData in class SocketImpl

Parameters:

data - The byte of data to send

IOException

---

finalize

protected void finalize()
 throws IOException

Cleans up if the user forgets to close it.

Overrides:

finalize in class Object

IOException

---

acquireFD

public final FileDescriptor acquireFD()

---

releaseFD

public final void releaseFD()

---

isConnectionReset

public boolean isConnectionReset()

---

isConnectionResetPending

public boolean isConnectionResetPending()

---

setConnectionReset

public void setConnectionReset()

---

setConnectionResetPending

public void setConnectionResetPending()

---

isClosedOrPending

public boolean isClosedOrPending()

---

getTimeout

public int getTimeout()

---

---