Class KQueueIoHandler.DefaultKqueueIoRegistration

java.lang.Object

io.netty.channel.kqueue.KQueueIoHandler.DefaultKqueueIoRegistration

All Implemented Interfaces:

IoRegistration

Enclosing class:

KQueueIoHandler

private final class KQueueIoHandler.DefaultKqueueIoRegistration
extends Object
implements IoRegistration

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicBoolean	canceled
private boolean	cancellationPending
private final KQueueIoEvent	event
private final ThreadAwareExecutor	executor
(package private) final KQueueIoHandle	handle
(package private) final long	id

Constructor Summary

Constructors

Constructor	Description
DefaultKqueueIoRegistration(ThreadAwareExecutor executor, KQueueIoHandle handle)

Method Summary

Modifier and Type	Method	Description
<T> T	attachment()	Implementation specific attachment, which might be null.
boolean	cancel()	Cancel the registration.
private void	cancel0()
(package private) void	close()
private void	evSet(short filter, short flags, int fflags, long data)
(package private) void	handle(int ident, short filter, short flags, int fflags, long data, long udata)
(package private) boolean	isHandleForChannel()
boolean	isValid()	Returns true if the registration is still valid.
long	submit(IoOps ops)	Submit the IoOps to the registration.

Methods inherited from class Object

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

Field Details

cancellationPending

private boolean cancellationPending

canceled

private final AtomicBoolean canceled

event

private final KQueueIoEvent event

handle

final KQueueIoHandle handle

id

final long id

executor

private final ThreadAwareExecutor executor

Constructor Details

DefaultKqueueIoRegistration

DefaultKqueueIoRegistration(ThreadAwareExecutor executor,
 KQueueIoHandle handle)

Method Details

isHandleForChannel

boolean isHandleForChannel()

attachment

public <T> T attachment()

Description copied from interface: IoRegistration

Implementation specific attachment, which might be null.

Specified by:

attachment in interface IoRegistration

Returns:

attachment.

submit

public long submit(IoOps ops)

Description copied from interface: IoRegistration

Submit the IoOps to the registration.

Specified by:

submit in interface IoRegistration

Parameters:

ops - ops.

Returns:

an identifier for the operation, which might be unique or not (depending on the implementation).

handle

void handle(int ident,
 short filter,
 short flags,
 int fflags,
 long data,
 long udata)

evSet

private void evSet(short filter,
 short flags,
 int fflags,
 long data)

isValid

public boolean isValid()

Description copied from interface: IoRegistration

Returns true if the registration is still valid. Once IoRegistration.cancel() is called this will return false.

Specified by:

isValid in interface IoRegistration

Returns:

valid.

cancel

public boolean cancel()

Description copied from interface: IoRegistration

Cancel the registration.

Specified by:

cancel in interface IoRegistration

Returns:

true if cancellation was successful, false otherwise.

cancel0

private void cancel0()

close

void close()