org.apache.giraph.utils

Class PipelineUtils

java.lang.Object

org.apache.giraph.utils.PipelineUtils

public class PipelineUtils
extends Object

Utility class for ChannelPipeline

Method Summary

Modifier and Type	Method and Description
static void	addLastWithExecutorCheck(String handlerName, io.netty.channel.ChannelHandler handler, String compareTo, io.netty.util.concurrent.EventExecutorGroup executor, io.netty.channel.Channel channel) Add a handler to pipeline if it is not already added and configure the handler to use an executor group based on equality of compareTo and handlerName

Methods inherited from class java.lang.Object

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

Method Detail

addLastWithExecutorCheck

public static void addLastWithExecutorCheck(String handlerName,
                                            io.netty.channel.ChannelHandler handler,
                                            String compareTo,
                                            io.netty.util.concurrent.EventExecutorGroup executor,
                                            io.netty.channel.Channel channel)

Add a handler to pipeline if it is not already added and configure the handler to use an executor group based on equality of compareTo and handlerName

Parameters:

handlerName - string name of the handler

handler - channelhandler object

compareTo - string name to compare to for executorgroup usage check

executor - executorgroup instance

channel - netty channel