com.goldencode.p2j.net

Class NIONetSocketBase

java.lang.Object

com.goldencode.p2j.net.NetSocketBase

com.goldencode.p2j.net.NIONetSocketBase

All Implemented Interfaces:

NetSocket

Direct Known Subclasses:

NIONetSocket, NIOSslSocket

public abstract class NIONetSocketBase
extends NetSocketBase
implements NetSocket

Implements NetSocket operations which are common for all NIO-based implementations.

Nested Class Summary

Nested classes/interfaces inherited from interface com.goldencode.p2j.net.NetSocket

NetSocket.NetSocketFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected java.nio.channels.SocketChannel	channel Underlying SocketChannel instance

Fields inherited from class com.goldencode.p2j.net.NetSocketBase

LOG, TRACE_LM

Fields inherited from interface com.goldencode.p2j.net.NetSocket

BUF_SIZE, FACTORY, handshakeTimeout, LOG

Constructor Summary

Constructors

Constructor and Description
NIONetSocketBase(java.nio.channels.SocketChannel channel) Constructor

Method Summary

Modifier and Type	Method and Description
void	close() Closes the socket.
java.net.InetAddress	getLocalAddr() Access the address of the local system, through which we are connecting.
java.net.InetSocketAddress	getLocalSockAddr() Access the address of the local system, through which we are connecting.
protected int	getMaxMessageSize() Get maximal message size
java.net.InetAddress	getRemoteAddr() Access the address of the remote system, to which we are connecting.
java.net.InetSocketAddress	getRemoteSockAddr() Access the address of the remote system, to which we are connecting.
boolean	isClosed() Reports if the socket is closed (and thus can no longer be used).
byte[]	read() Read the next portion of raw data (byte array) to the output
boolean	readBoolean() Read the boolean from the input
void	readBytes(byte[] bytes) Read the byte sequence from the input
protected abstract byte[]	readFully() Read next data chunk from the channel
int	readInt() Read the integer from the input
java.lang.String	readUTF() Read the UTF string from the input
void	write(byte[] data) Write byte array to the output
protected abstract void	write(java.nio.ByteBuffer bb) Send the data to the channel
void	writeBoolean(boolean val) Write a boolean to the output
void	writeBytes(byte[] bytes) Write a byte sequence to the output
void	writeInt(int val) Write an integer to the output
void	writeUTF(java.lang.String val) Write an UTF String to the output

Methods inherited from class com.goldencode.p2j.net.NetSocketBase

addSessionListener, getSessionListeners

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.goldencode.p2j.net.NetSocket

addSessionListener, flush, getSession, getSessionListeners, tracef, traceln

Field Detail

channel

protected final java.nio.channels.SocketChannel channel

Underlying SocketChannel instance

Constructor Detail

NIONetSocketBase

NIONetSocketBase(java.nio.channels.SocketChannel channel)
          throws java.io.IOException

Constructor

Parameters:

channel - underlying SocketChannel instance

Throws:

java.io.IOException - on error

Method Detail

close

public void close()

Closes the socket.

Specified by:

close in interface NetSocket

isClosed

public boolean isClosed()

Reports if the socket is closed (and thus can no longer be used).

Specified by:

isClosed in interface NetSocket

Returns:

true if the socket is closed.

getLocalAddr

public java.net.InetAddress getLocalAddr()

Access the address of the local system, through which we are connecting.

Specified by:

getLocalAddr in interface NetSocket

Returns:

The local address.

getLocalSockAddr

public java.net.InetSocketAddress getLocalSockAddr()

Access the address of the local system, through which we are connecting.

Specified by:

getLocalSockAddr in interface NetSocket

Returns:

The local socket address.

getRemoteAddr

public java.net.InetAddress getRemoteAddr()

Access the address of the remote system, to which we are connecting.

Specified by:

getRemoteAddr in interface NetSocket

Returns:

The remote address.

getRemoteSockAddr

public java.net.InetSocketAddress getRemoteSockAddr()

Access the address of the remote system, to which we are connecting.

Specified by:

getRemoteSockAddr in interface NetSocket

Returns:

The remote socket address.

write

public void write(byte[] data)
           throws java.io.IOException

Write byte array to the output

Specified by:

write in interface NetSocket

Parameters:

data - byte array

Throws:

java.io.IOException

read

public byte[] read()
            throws java.io.IOException

Read the next portion of raw data (byte array) to the output

Specified by:

read in interface NetSocket

Returns:

byte array

Throws:

java.io.IOException - on error

readInt

public int readInt()
            throws java.io.IOException

Read the integer from the input

Specified by:

readInt in interface NetSocket

Returns:

integer data

Throws:

java.io.IOException - on error

writeInt

public void writeInt(int val)
              throws java.io.IOException

Write an integer to the output

Specified by:

writeInt in interface NetSocket

Parameters:

val - integer data to be written

Throws:

java.io.IOException - on error

readBytes

public void readBytes(byte[] bytes)
               throws java.io.IOException

Read the byte sequence from the input

Specified by:

readBytes in interface NetSocket

Parameters:

bytes - byte array to be filled by the input bytes

Throws:

java.io.IOException - on error

writeBytes

public void writeBytes(byte[] bytes)
                throws java.io.IOException

Write a byte sequence to the output

Specified by:

writeBytes in interface NetSocket

Parameters:

bytes - byte sequence to be written

Throws:

java.io.IOException - on error

readBoolean

public boolean readBoolean()
                    throws java.io.IOException

Read the boolean from the input

Specified by:

readBoolean in interface NetSocket

Returns:

boolean data

Throws:

java.io.IOException - on error

writeBoolean

public void writeBoolean(boolean val)
                  throws java.io.IOException

Write a boolean to the output

Specified by:

writeBoolean in interface NetSocket

Parameters:

val - boolean data to be written

Throws:

java.io.IOException - on error

readUTF

public java.lang.String readUTF()
                         throws java.io.IOException

Read the UTF string from the input

Specified by:

readUTF in interface NetSocket

Returns:

UTF string

Throws:

java.io.IOException - on error

writeUTF

public void writeUTF(java.lang.String val)
              throws java.io.IOException

Write an UTF String to the output

Specified by:

writeUTF in interface NetSocket

Parameters:

val - UTF String to be written

Throws:

java.io.IOException - on error

write

protected abstract void write(java.nio.ByteBuffer bb)
                       throws java.io.IOException

Send the data to the channel

Parameters:

bb - data to be sent

Throws:

java.io.IOException - on error

readFully

protected abstract byte[] readFully()
                             throws java.io.IOException,
                                    java.io.EOFException

Read next data chunk from the channel

Returns:

next data chunk

Throws:

java.io.IOException - on error

java.io.EOFException - if no data can be read

getMaxMessageSize

protected int getMaxMessageSize()

Get maximal message size

Returns:

maximal message size;