Package com.gigaspaces.internal.space.transport.xnio

Class XNioChannel

java.lang.Object

com.gigaspaces.internal.space.transport.xnio.XNioChannel

public class XNioChannel
extends Object

Since:

16.0

Author:

Niv Ingberg

Constructor Summary

Constructors

Constructor	Description
XNioChannel(SocketChannel socketChannel)

Method Summary

Modifier and Type	Method	Description
void	close()
Object	deserialize(ByteBuffer buffer)
ReadProcessor	getReadProcessor()
SocketChannel	getSocketChannel()
ByteBuffer	readBlocking()
ByteBuffer	readNonBlocking()
void	release()
ByteBuffer	serialize(Object obj)
void	setReadProcessor(ReadProcessor readProcessor)
boolean	tryAcquire()
void	writeBlocking(ByteBuffer buffer)

Methods inherited from class java.lang.Object

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

Constructor Details

XNioChannel

public XNioChannel(SocketChannel socketChannel)

Method Details

tryAcquire

public boolean tryAcquire()

release

public void release()

getSocketChannel

public SocketChannel getSocketChannel()

serialize

public ByteBuffer serialize(Object obj)
                     throws IOException

Throws:

IOException

deserialize

public Object deserialize(ByteBuffer buffer)
                   throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException

writeBlocking

public void writeBlocking(ByteBuffer buffer)
                   throws IOException

Throws:

IOException

readBlocking

public ByteBuffer readBlocking()
                        throws IOException

Throws:

IOException

readNonBlocking

public ByteBuffer readNonBlocking()
                           throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

getReadProcessor

public ReadProcessor getReadProcessor()

setReadProcessor

public void setReadProcessor(ReadProcessor readProcessor)