Package org.jgrapes.net

Class SocketConnectionManager.SocketChannelImpl

java.lang.Object

org.jgrapes.core.Subchannel.DefaultSubchannel

org.jgrapes.io.IOSubchannel.DefaultIOSubchannel

org.jgrapes.net.SocketConnectionManager.SocketChannelImpl

All Implemented Interfaces:

Associator, Channel, Eligible, Subchannel, IOSubchannel, NioHandler, SocketIOChannel

Enclosing class:

SocketConnectionManager

protected class SocketConnectionManager.SocketChannelImpl
extends IOSubchannel.DefaultIOSubchannel
implements NioHandler, SocketIOChannel

Nested Class Summary

Nested classes/interfaces inherited from interface org.jgrapes.core.Channel

Channel.Default

Nested classes/interfaces inherited from interface org.jgrapes.io.IOSubchannel

IOSubchannel.DefaultIOSubchannel

Nested classes/interfaces inherited from interface org.jgrapes.core.Subchannel

Subchannel.DefaultSubchannel

Field Summary

Fields inherited from interface org.jgrapes.core.Channel

BROADCAST, SELF

Constructor Summary

Constructors

Constructor	Description
SocketChannelImpl(OpenSocketConnection openEvent, SocketChannel nioChannel)

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this channel.
EventPipeline	downPipeline()	Gets the down pipeline.
void	handleOps(int ops)	Invoked by the NioDispatcher when operations are pending.
boolean	isPurgeable()	Checks if is purgeable.
SocketAddress	localAddress()	Returns the local address.
SocketChannel	nioChannel()	Gets the nio channel.
Optional<OpenSocketConnection>	openEvent()	Returns the event that caused this connection to be opened.
long	purgeableSince()	Gets the the time when the connection became purgeable.
ManagedBufferPool<ManagedBuffer<ByteBuffer>,ByteBuffer>	readBuffers()	Gets the read buffers.
void	registrationComplete(NioRegistration.Registration registration)	Invoked when registration has completed.
SocketAddress	remoteAddress()	Returns the remote address.
String	toString()
void	write(Output<ByteBuffer> event)	Write the data on this channel.

Methods inherited from class org.jgrapes.io.IOSubchannel.DefaultIOSubchannel

byteBufferPool, charBufferPool, responsePipeline, setByteBufferPool, setCharBufferPool

Methods inherited from class org.jgrapes.core.Subchannel.DefaultSubchannel

associated, mainChannel, setAssociated

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jgrapes.core.Associator

associated, associated, associated, associated, associatedGet, setAssociated

Methods inherited from interface org.jgrapes.io.IOSubchannel

byteBufferPool, charBufferPool, respond, responsePipeline

Methods inherited from interface org.jgrapes.core.Subchannel

defaultCriterion, isEligibleFor, mainChannel

Constructor Details

SocketChannelImpl

public SocketChannelImpl(OpenSocketConnection openEvent,
 SocketChannel nioChannel)
                  throws IOException

Parameters:

nioChannel - the channel

Throws:

IOException - if an I/O error occurred

Method Details

openEvent

public Optional<OpenSocketConnection> openEvent()

Returns the event that caused this connection to be opened.

May be null if the channel was created in response to a client connecting to the server.

Returns:

the event

nioChannel

public SocketChannel nioChannel()

Gets the nio channel.

Returns:

the nioChannel

localAddress

public SocketAddress localAddress()

Description copied from interface: SocketIOChannel

Returns the local address.

Specified by:

localAddress in interface SocketIOChannel

Returns:

the socket address

remoteAddress

public SocketAddress remoteAddress()

Description copied from interface: SocketIOChannel

Returns the remote address.

Specified by:

remoteAddress in interface SocketIOChannel

Returns:

the socket address

readBuffers

public ManagedBufferPool<ManagedBuffer<ByteBuffer>,ByteBuffer> readBuffers()

Gets the read buffers.

Returns:

the readBuffers

downPipeline

public EventPipeline downPipeline()

Gets the down pipeline.

Returns:

the downPipeline

registrationComplete

public void registrationComplete(NioRegistration.Registration registration)

Invoked when registration has completed.

Parameters:

registration - the registration (result from the NioRegistration event)

isPurgeable

public boolean isPurgeable()

Checks if is purgeable.

Specified by:

isPurgeable in interface SocketIOChannel

Returns:

true, if is purgeable

purgeableSince

public long purgeableSince()

Gets the the time when the connection became purgeable.

Specified by:

purgeableSince in interface SocketIOChannel

Returns:

the time

write

public void write(Output<ByteBuffer> event)
           throws InterruptedException

Write the data on this channel.

Parameters:

event - the event

Throws:

InterruptedException

handleOps

public void handleOps(int ops)
               throws InterruptedException

Description copied from interface: NioHandler

Invoked by the NioDispatcher when operations are pending.

Specified by:

handleOps in interface NioHandler

Parameters:

ops - the pending operations as or’ed constants defined by SelectionKey

Throws:

InterruptedException

close

public void close()
           throws IOException,
InterruptedException

Closes this channel.

Throws:

IOException - if an error occurs

InterruptedException - if the execution was interrupted

toString

public String toString()

Overrides:

toString in class Subchannel.DefaultSubchannel