org.jboss.netty.channel

Class DefaultChannelPipeline

java.lang.Object

org.jboss.netty.channel.DefaultChannelPipeline

All Implemented Interfaces:

ChannelPipeline

Direct Known Subclasses:

AbstractCodecEmbedder.EmbeddedChannelPipeline

public class DefaultChannelPipeline
extends java.lang.Object
implements ChannelPipeline

The default ChannelPipeline implementation. It is recommended to use Channels.pipeline() to create a new ChannelPipeline instance rather than calling the constructor directly.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	DefaultChannelPipeline.DefaultChannelHandlerContext
private static class	DefaultChannelPipeline.DiscardingChannelSink

Field Summary

Fields

Modifier and Type	Field and Description
private Channel	channel
(package private) static ChannelSink	discardingSink
private DefaultChannelPipeline.DefaultChannelHandlerContext	head
(package private) static InternalLogger	logger
private java.util.Map<java.lang.String,DefaultChannelPipeline.DefaultChannelHandlerContext>	name2ctx
private ChannelSink	sink
private DefaultChannelPipeline.DefaultChannelHandlerContext	tail

Constructor Summary

Constructors

Constructor and Description
DefaultChannelPipeline()

Method Summary

Modifier and Type	Method and Description
void	addAfter(java.lang.String baseName, java.lang.String name, ChannelHandler handler) Inserts a ChannelHandler after an existing handler of this pipeline.
void	addBefore(java.lang.String baseName, java.lang.String name, ChannelHandler handler) Inserts a ChannelHandler before an existing handler of this pipeline.
void	addFirst(java.lang.String name, ChannelHandler handler) Inserts a ChannelHandler at the first position of this pipeline.
void	addLast(java.lang.String name, ChannelHandler handler) Appends a ChannelHandler at the last position of this pipeline.
void	attach(Channel channel, ChannelSink sink) Attaches this pipeline to the specified Channel and ChannelSink.
private void	callAfterAdd(ChannelHandlerContext ctx)
private static void	callAfterRemove(ChannelHandlerContext ctx)
private static void	callBeforeAdd(ChannelHandlerContext ctx)
private static void	callBeforeRemove(ChannelHandlerContext ctx)
private void	checkDuplicateName(java.lang.String name)
ChannelFuture	execute(java.lang.Runnable task) Schedules the specified task to be executed in the I/O thread associated with this pipeline's Channel.
<T extends ChannelHandler> T	get(java.lang.Class<T> handlerType) Returns the ChannelHandler of the specified type in this pipeline.
ChannelHandler	get(java.lang.String name) Returns the ChannelHandler with the specified name in this pipeline.
private DefaultChannelPipeline.DefaultChannelHandlerContext	getActualDownstreamContext(DefaultChannelPipeline.DefaultChannelHandlerContext ctx)
private DefaultChannelPipeline.DefaultChannelHandlerContext	getActualUpstreamContext(DefaultChannelPipeline.DefaultChannelHandlerContext ctx)
Channel	getChannel() Returns the Channel that this pipeline is attached to.
ChannelHandlerContext	getContext(ChannelHandler handler) Returns the context object of the specified ChannelHandler in this pipeline.
ChannelHandlerContext	getContext(java.lang.Class<? extends ChannelHandler> handlerType) Returns the context object of the ChannelHandler of the specified type in this pipeline.
ChannelHandlerContext	getContext(java.lang.String name) Returns the context object of the ChannelHandler with the specified name in this pipeline.
private DefaultChannelPipeline.DefaultChannelHandlerContext	getContextOrDie(ChannelHandler handler)
private DefaultChannelPipeline.DefaultChannelHandlerContext	getContextOrDie(java.lang.Class<? extends ChannelHandler> handlerType)
private DefaultChannelPipeline.DefaultChannelHandlerContext	getContextOrDie(java.lang.String name)
ChannelHandler	getFirst() Returns the first ChannelHandler in this pipeline.
ChannelHandler	getLast() Returns the last ChannelHandler in this pipeline.
java.util.List<java.lang.String>	getNames() Returns the List of the handler names.
ChannelSink	getSink() Returns the ChannelSink that this pipeline is attached to.
private void	init(java.lang.String name, ChannelHandler handler)
boolean	isAttached() Returns true if and only if this pipeline is attached to a Channel.
protected void	notifyHandlerException(ChannelEvent e, java.lang.Throwable t)
void	remove(ChannelHandler handler) Removes the specified ChannelHandler from this pipeline.
<T extends ChannelHandler> T	remove(java.lang.Class<T> handlerType) Removes the ChannelHandler of the specified type from this pipeline
private DefaultChannelPipeline.DefaultChannelHandlerContext	remove(DefaultChannelPipeline.DefaultChannelHandlerContext ctx)
ChannelHandler	remove(java.lang.String name) Removes the ChannelHandler with the specified name from this pipeline.
ChannelHandler	removeFirst() Removes the first ChannelHandler in this pipeline.
ChannelHandler	removeLast() Removes the last ChannelHandler in this pipeline.
void	replace(ChannelHandler oldHandler, java.lang.String newName, ChannelHandler newHandler) Replaces the specified ChannelHandler with a new handler in this pipeline.
<T extends ChannelHandler> T	replace(java.lang.Class<T> oldHandlerType, java.lang.String newName, ChannelHandler newHandler) Replaces the ChannelHandler of the specified type with a new handler in this pipeline.
private ChannelHandler	replace(DefaultChannelPipeline.DefaultChannelHandlerContext ctx, java.lang.String newName, ChannelHandler newHandler)
ChannelHandler	replace(java.lang.String oldName, java.lang.String newName, ChannelHandler newHandler) Replaces the ChannelHandler of the specified name with a new handler in this pipeline.
void	sendDownstream(ChannelEvent e) Sends the specified ChannelEvent to the last ChannelDownstreamHandler in this pipeline.
(package private) void	sendDownstream(DefaultChannelPipeline.DefaultChannelHandlerContext ctx, ChannelEvent e)
void	sendUpstream(ChannelEvent e) Sends the specified ChannelEvent to the first ChannelUpstreamHandler in this pipeline.
(package private) void	sendUpstream(DefaultChannelPipeline.DefaultChannelHandlerContext ctx, ChannelEvent e)
java.util.Map<java.lang.String,ChannelHandler>	toMap() Converts this pipeline into an ordered Map whose keys are handler names and whose values are handlers.
java.lang.String	toString() Returns the String representation of this pipeline.

Methods inherited from class java.lang.Object

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

Field Detail

logger

static final InternalLogger logger

discardingSink

static final ChannelSink discardingSink

channel

private volatile Channel channel

sink

private volatile ChannelSink sink

head

private volatile DefaultChannelPipeline.DefaultChannelHandlerContext head

tail

private volatile DefaultChannelPipeline.DefaultChannelHandlerContext tail

name2ctx

private final java.util.Map<java.lang.String,DefaultChannelPipeline.DefaultChannelHandlerContext> name2ctx

Constructor Detail

DefaultChannelPipeline

public DefaultChannelPipeline()

Method Detail

getChannel

public Channel getChannel()

Description copied from interface: ChannelPipeline

Returns the Channel that this pipeline is attached to.

Specified by:

getChannel in interface ChannelPipeline

Returns:

the channel. null if this pipeline is not attached yet.

getSink

public ChannelSink getSink()

Description copied from interface: ChannelPipeline

Returns the ChannelSink that this pipeline is attached to.

Specified by:

getSink in interface ChannelPipeline

Returns:

the sink. null if this pipeline is not attached yet.

attach

public void attach(Channel channel,
                   ChannelSink sink)

Description copied from interface: ChannelPipeline

Attaches this pipeline to the specified Channel and ChannelSink. Once a pipeline is attached, it can't be detached nor attached again.

Specified by:

attach in interface ChannelPipeline

isAttached

public boolean isAttached()

Description copied from interface: ChannelPipeline

Returns true if and only if this pipeline is attached to a Channel.

Specified by:

isAttached in interface ChannelPipeline

addFirst

public void addFirst(java.lang.String name,
                     ChannelHandler handler)

Description copied from interface: ChannelPipeline

Inserts a ChannelHandler at the first position of this pipeline.

Specified by:

addFirst in interface ChannelPipeline

Parameters:

name - the name of the handler to insert first

handler - the handler to insert first

addLast

public void addLast(java.lang.String name,
                    ChannelHandler handler)

Description copied from interface: ChannelPipeline

Appends a ChannelHandler at the last position of this pipeline.

Specified by:

addLast in interface ChannelPipeline

Parameters:

name - the name of the handler to append

handler - the handler to append

addBefore

public void addBefore(java.lang.String baseName,
                      java.lang.String name,
                      ChannelHandler handler)

Description copied from interface: ChannelPipeline

Inserts a ChannelHandler before an existing handler of this pipeline.

Specified by:

addBefore in interface ChannelPipeline

Parameters:

baseName - the name of the existing handler

name - the name of the handler to insert before

handler - the handler to insert before

addAfter

public void addAfter(java.lang.String baseName,
                     java.lang.String name,
                     ChannelHandler handler)

Description copied from interface: ChannelPipeline

Inserts a ChannelHandler after an existing handler of this pipeline.

Specified by:

addAfter in interface ChannelPipeline

Parameters:

baseName - the name of the existing handler

name - the name of the handler to insert after

handler - the handler to insert after

remove

public void remove(ChannelHandler handler)

Description copied from interface: ChannelPipeline

Removes the specified ChannelHandler from this pipeline.

Specified by:

remove in interface ChannelPipeline

remove

public ChannelHandler remove(java.lang.String name)

Description copied from interface: ChannelPipeline

Removes the ChannelHandler with the specified name from this pipeline.

Specified by:

remove in interface ChannelPipeline

Returns:

the removed handler

remove

public <T extends ChannelHandler> T remove(java.lang.Class<T> handlerType)

Description copied from interface: ChannelPipeline

Removes the ChannelHandler of the specified type from this pipeline

Specified by:

remove in interface ChannelPipeline

Type Parameters:

T - the type of the handler

Parameters:

handlerType - the type of the handler

Returns:

the removed handler

remove

private DefaultChannelPipeline.DefaultChannelHandlerContext remove(DefaultChannelPipeline.DefaultChannelHandlerContext ctx)

removeFirst

public ChannelHandler removeFirst()

Description copied from interface: ChannelPipeline

Removes the first ChannelHandler in this pipeline.

Specified by:

removeFirst in interface ChannelPipeline

Returns:

the removed handler

removeLast

public ChannelHandler removeLast()

Description copied from interface: ChannelPipeline

Removes the last ChannelHandler in this pipeline.

Specified by:

removeLast in interface ChannelPipeline

Returns:

the removed handler

replace

public void replace(ChannelHandler oldHandler,
                    java.lang.String newName,
                    ChannelHandler newHandler)

Description copied from interface: ChannelPipeline

Replaces the specified ChannelHandler with a new handler in this pipeline.

Specified by:

replace in interface ChannelPipeline

replace

public ChannelHandler replace(java.lang.String oldName,
                              java.lang.String newName,
                              ChannelHandler newHandler)

Description copied from interface: ChannelPipeline

Replaces the ChannelHandler of the specified name with a new handler in this pipeline.

Specified by:

replace in interface ChannelPipeline

Returns:

the removed handler

replace

public <T extends ChannelHandler> T replace(java.lang.Class<T> oldHandlerType,
                                            java.lang.String newName,
                                            ChannelHandler newHandler)

Description copied from interface: ChannelPipeline

Replaces the ChannelHandler of the specified type with a new handler in this pipeline.

Specified by:

replace in interface ChannelPipeline

Returns:

the removed handler

replace

private ChannelHandler replace(DefaultChannelPipeline.DefaultChannelHandlerContext ctx,
                               java.lang.String newName,
                               ChannelHandler newHandler)

callBeforeAdd

private static void callBeforeAdd(ChannelHandlerContext ctx)

callAfterAdd

private void callAfterAdd(ChannelHandlerContext ctx)

callBeforeRemove

private static void callBeforeRemove(ChannelHandlerContext ctx)

callAfterRemove

private static void callAfterRemove(ChannelHandlerContext ctx)

getFirst

public ChannelHandler getFirst()

Description copied from interface: ChannelPipeline

Returns the first ChannelHandler in this pipeline.

Specified by:

getFirst in interface ChannelPipeline

Returns:

the first handler. null if this pipeline is empty.

getLast

public ChannelHandler getLast()

Description copied from interface: ChannelPipeline

Returns the last ChannelHandler in this pipeline.

Specified by:

getLast in interface ChannelPipeline

Returns:

the last handler. null if this pipeline is empty.

get

public ChannelHandler get(java.lang.String name)

Description copied from interface: ChannelPipeline

Returns the ChannelHandler with the specified name in this pipeline.

Specified by:

get in interface ChannelPipeline

Returns:

the handler with the specified name. null if there's no such handler in this pipeline.

get

public <T extends ChannelHandler> T get(java.lang.Class<T> handlerType)

Description copied from interface: ChannelPipeline

Returns the ChannelHandler of the specified type in this pipeline.

Specified by:

get in interface ChannelPipeline

Returns:

the handler of the specified handler type. null if there's no such handler in this pipeline.

getContext

public ChannelHandlerContext getContext(java.lang.String name)

Description copied from interface: ChannelPipeline

Returns the context object of the ChannelHandler with the specified name in this pipeline.

Specified by:

getContext in interface ChannelPipeline

Returns:

the context object of the handler with the specified name. null if there's no such handler in this pipeline.

getContext

public ChannelHandlerContext getContext(ChannelHandler handler)

Description copied from interface: ChannelPipeline

Returns the context object of the specified ChannelHandler in this pipeline.

Specified by:

getContext in interface ChannelPipeline

Returns:

the context object of the specified handler. null if there's no such handler in this pipeline.

getContext

public ChannelHandlerContext getContext(java.lang.Class<? extends ChannelHandler> handlerType)

Description copied from interface: ChannelPipeline

Returns the context object of the ChannelHandler of the specified type in this pipeline.

Specified by:

getContext in interface ChannelPipeline

Returns:

the context object of the handler of the specified type. null if there's no such handler in this pipeline.

getNames

public java.util.List<java.lang.String> getNames()

Description copied from interface: ChannelPipeline

Returns the List of the handler names.

Specified by:

getNames in interface ChannelPipeline

toMap

public java.util.Map<java.lang.String,ChannelHandler> toMap()

Description copied from interface: ChannelPipeline

Converts this pipeline into an ordered Map whose keys are handler names and whose values are handlers.

Specified by:

toMap in interface ChannelPipeline

toString

public java.lang.String toString()

Returns the String representation of this pipeline.

Overrides:

toString in class java.lang.Object

sendUpstream

public void sendUpstream(ChannelEvent e)

Description copied from interface: ChannelPipeline

Sends the specified ChannelEvent to the first ChannelUpstreamHandler in this pipeline.

Specified by:

sendUpstream in interface ChannelPipeline

sendUpstream

void sendUpstream(DefaultChannelPipeline.DefaultChannelHandlerContext ctx,
                  ChannelEvent e)

sendDownstream

public void sendDownstream(ChannelEvent e)

Description copied from interface: ChannelPipeline

Sends the specified ChannelEvent to the last ChannelDownstreamHandler in this pipeline.

Specified by:

sendDownstream in interface ChannelPipeline

sendDownstream

void sendDownstream(DefaultChannelPipeline.DefaultChannelHandlerContext ctx,
                    ChannelEvent e)

getActualUpstreamContext

private DefaultChannelPipeline.DefaultChannelHandlerContext getActualUpstreamContext(DefaultChannelPipeline.DefaultChannelHandlerContext ctx)

getActualDownstreamContext

private DefaultChannelPipeline.DefaultChannelHandlerContext getActualDownstreamContext(DefaultChannelPipeline.DefaultChannelHandlerContext ctx)

execute

public ChannelFuture execute(java.lang.Runnable task)

Description copied from interface: ChannelPipeline

Schedules the specified task to be executed in the I/O thread associated with this pipeline's Channel.

Specified by:

execute in interface ChannelPipeline

notifyHandlerException

protected void notifyHandlerException(ChannelEvent e,
                                      java.lang.Throwable t)

init

private void init(java.lang.String name,
                  ChannelHandler handler)

checkDuplicateName

private void checkDuplicateName(java.lang.String name)

getContextOrDie

private DefaultChannelPipeline.DefaultChannelHandlerContext getContextOrDie(java.lang.String name)

getContextOrDie

private DefaultChannelPipeline.DefaultChannelHandlerContext getContextOrDie(ChannelHandler handler)

getContextOrDie

private DefaultChannelPipeline.DefaultChannelHandlerContext getContextOrDie(java.lang.Class<? extends ChannelHandler> handlerType)