org.apache.giraph.comm.netty

Class ChannelRotater

java.lang.Object

org.apache.giraph.comm.netty.ChannelRotater

public class ChannelRotater
extends Object

Maintains multiple channels and rotates between them. This is thread-safe.

Constructor Summary

Constructors

Constructor and Description
ChannelRotater(Integer taskId, InetSocketAddress address) Constructor

Method Summary

Modifier and Type	Method and Description
void	addChannel(io.netty.channel.Channel channel) Add a channel to the rotation
void	closeChannels(io.netty.channel.ChannelFutureListener channelFutureListener) Close the channels
Iterable<io.netty.channel.Channel>	getChannels() Get a copy of the channels
Integer	getTaskId()
io.netty.channel.Channel	nextChannel() Get the next channel
boolean	removeChannel(io.netty.channel.Channel channel) Remove the a channel
int	size() Get the number of channels in this object

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelRotater

public ChannelRotater(Integer taskId,
                      InetSocketAddress address)

Constructor

Parameters:

taskId - Id of the task these channels as associated with

address - Address these channels are associated with

Method Detail

getTaskId

public Integer getTaskId()

addChannel

public void addChannel(io.netty.channel.Channel channel)

Add a channel to the rotation

Parameters:

channel - Channel to add

nextChannel

public io.netty.channel.Channel nextChannel()

Get the next channel

Returns:

Next channel

removeChannel

public boolean removeChannel(io.netty.channel.Channel channel)

Remove the a channel

Parameters:

channel - Channel to remove

Returns:

Return true if successful, false otherwise

size

public int size()

Get the number of channels in this object

Returns:

Number of channels

closeChannels

public void closeChannels(io.netty.channel.ChannelFutureListener channelFutureListener)

Close the channels

Parameters:

channelFutureListener - If desired, pass in a channel future listener

getChannels

public Iterable<io.netty.channel.Channel> getChannels()

Get a copy of the channels

Returns:

Copy of the channels