Package org.jppf.io

Class SocketWrapperInputSource

java.lang.Object

org.jppf.io.SocketWrapperInputSource

All Implemented Interfaces:

Closeable, AutoCloseable, InputSource, IO

public class SocketWrapperInputSource
extends Object
implements InputSource

Input source backed by a SocketWrapper.

Author:

Laurent Cohen

Field Summary

Fields inherited from interface org.jppf.io.IO

CHECK_LOW_MEMORY, EMPTY_BYTES, FREE_MEM_TO_SIZE_RATIO, GC_ON_DISK_OVERFLOW, LENGTH_BUFFER_POOL, LENGTH_BUFFER_POOL_SIZE, LOW_MEMORY_THRESHOLD, SOCKET_BUFFER_SIZE, SOCKET_KEEPALIVE, SOCKET_TCP_NODELAY, TEMP_BUFFER_POOL, TEMP_BUFFER_POOL_SIZE, TEMP_BUFFER_SIZE

Constructor Summary

Constructors

Constructor	Description
SocketWrapperInputSource(SocketWrapper socketWrapper)	Initialize this input source with the specified SocketWrapper.

Method Summary

Modifier and Type	Method	Description
void	close()	This method does nothing.
int	read(byte[] data, int offset, int len)	Read data from this input source into an array of bytes.
int	read(ByteBuffer data)	Read data from this input source into a byte buffer.
int	readInt()	Read an int value from this input source.
int	skip(int n)	Skip n bytes of data form this input source.

Methods inherited from class java.lang.Object

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

Constructor Details

SocketWrapperInputSource

public SocketWrapperInputSource(SocketWrapper socketWrapper)

Initialize this input source with the specified SocketWrapper.

Parameters:

socketWrapper - the backing SocketWrapper.

Method Details

read

public int read(byte[] data,
 int offset,
 int len)
         throws Exception

Read data from this input source into an array of bytes.

Specified by:

read in interface InputSource

Parameters:

data - the buffer into which to write.

offset - the position in the buffer where to start storing the data.

len - the size in bytes of the data to read.

Returns:

the number of bytes actually read, or -1 if end of stream was reached.

Throws:

Exception - if an IO error occurs.

read

public int read(ByteBuffer data)
         throws Exception

Read data from this input source into a byte buffer.

Specified by:

read in interface InputSource

Parameters:

data - the buffer into which to write.

Returns:

the number of bytes actually read, or -1 if end of stream was reached.

Throws:

Exception - if an IO error occurs.

readInt

public int readInt()
            throws Exception

Read an int value from this input source.

Specified by:

readInt in interface InputSource

Returns:

the value read, or -1 if an end of file condition was reached.

Throws:

Exception - if an IO error occurs.

skip

public int skip(int n)
         throws Exception

Skip n bytes of data form this input source.

Specified by:

skip in interface InputSource

Parameters:

n - the number of bytes to skip.

Returns:

the number of bytes actually skipped.

Throws:

Exception - if an IO error occurs.

close

public void close()
           throws IOException

This method does nothing.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException - if an IO error occurs.