io.netty.channel.epoll

Class AbstractEpollChannel.AbstractEpollUnsafe

java.lang.Object

io.netty.channel.AbstractChannel.AbstractUnsafe

io.netty.channel.epoll.AbstractEpollChannel.AbstractEpollUnsafe

All Implemented Interfaces:

Channel.Unsafe

Direct Known Subclasses:

AbstractEpollServerChannel.EpollServerSocketUnsafe, AbstractEpollStreamChannel.EpollStreamUnsafe, EpollDatagramChannel.EpollDatagramChannelUnsafe

Enclosing class:

AbstractEpollChannel

protected abstract class AbstractEpollChannel.AbstractEpollUnsafe
extends AbstractChannel.AbstractUnsafe

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	rdHup
protected boolean	readPending

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractEpollUnsafe()

Method Summary

Modifier and Type	Method and Description
protected void	clearEpollIn0()
private void	clearEpollRdHup() Clear the Native.EPOLLRDHUP flag from EPOLL, and close on failure.
(package private) abstract void	epollInReady() Called once EPOLLIN event is ready to be processed
(package private) void	epollOutReady() Called once a EPOLLOUT event is ready to be processed
(package private) void	epollRdHupReady() Called once EPOLLRDHUP event is ready to be processed
private void	fireEventAndClose(java.lang.Object evt)
protected void	flush0()
boolean	isRdHup()
(package private) void	shutdownInput() Shutdown the input side of the channel.

Methods inherited from class io.netty.channel.AbstractChannel.AbstractUnsafe

annotateConnectException, beginRead, bind, close, closeForcibly, closeIfClosed, deregister, disconnect, ensureOpen, flush, localAddress, outboundBuffer, prepareToClose, register, remoteAddress, safeSetFailure, safeSetSuccess, voidPromise, write

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.netty.channel.Channel.Unsafe

connect

Field Detail

readPending

protected boolean readPending

rdHup

private boolean rdHup

Constructor Detail

AbstractEpollUnsafe

protected AbstractEpollUnsafe()

Method Detail

epollInReady

abstract void epollInReady()

Called once EPOLLIN event is ready to be processed

isRdHup

public final boolean isRdHup()

epollRdHupReady

final void epollRdHupReady()

Called once EPOLLRDHUP event is ready to be processed

clearEpollRdHup

private void clearEpollRdHup()

Clear the Native.EPOLLRDHUP flag from EPOLL, and close on failure.

shutdownInput

void shutdownInput()

Shutdown the input side of the channel.

fireEventAndClose

private void fireEventAndClose(java.lang.Object evt)

flush0

protected void flush0()

Overrides:

flush0 in class AbstractChannel.AbstractUnsafe

epollOutReady

void epollOutReady()

Called once a EPOLLOUT event is ready to be processed

clearEpollIn0

protected final void clearEpollIn0()