org.waarp.openr66.protocol.utils

Class ChannelUtils

java.lang.Object

java.lang.Thread

org.waarp.openr66.protocol.utils.ChannelUtils

All Implemented Interfaces:

Runnable

public class ChannelUtils
extends Thread

Channel Utils

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field and Description
static Integer	NOCHANNEL

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ChannelUtils()

Method Summary

Modifier and Type	Method and Description
static void	exit() Exit global ChannelFactory
static InetAddress	getLocalInetAddress(io.netty.channel.Channel channel) Get the Local InetAddress
static InetSocketAddress	getLocalInetSocketAddress(io.netty.channel.Channel channel) Get the Local InetSocketAddress
static InetAddress	getRemoteInetAddress(io.netty.channel.Channel channel) Get the Remote InetAddress
static InetSocketAddress	getRemoteInetSocketAddress(io.netty.channel.Channel channel) Get the Remote InetSocketAddress
static int	nbCommandChannels(Configuration configuration) Return the current number of network connections
void	run() This function is the top function to be called when the server is to be shutdown.
static void	startShutdown() Start Shutdown
static void	stopLogger()
static io.netty.channel.ChannelFuture	writeAbstractLocalPacket(LocalChannelReference localChannelReference, AbstractLocalPacket packet, boolean wait) Write an AbstractLocalPacket to the network Channel
static io.netty.channel.ChannelFuture	writeBackDataBlock(LocalChannelReference localChannelReference, DataBlock block)
static void	writeEndTransfer(LocalChannelReference localChannelReference) Write the EndTransfer
static void	writeEndTransfer(LocalChannelReference localChannelReference, String hash) Write the EndTransfer plus Global Hash

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

NOCHANNEL

public static final Integer NOCHANNEL

Constructor Detail

ChannelUtils

public ChannelUtils()

Method Detail

getRemoteInetAddress

public static final InetAddress getRemoteInetAddress(io.netty.channel.Channel channel)

Get the Remote InetAddress

Parameters:

channel -

Returns:

the remote InetAddress

getLocalInetAddress

public static final InetAddress getLocalInetAddress(io.netty.channel.Channel channel)

Get the Local InetAddress

Parameters:

channel -

Returns:

the local InetAddress

getRemoteInetSocketAddress

public static final InetSocketAddress getRemoteInetSocketAddress(io.netty.channel.Channel channel)

Get the Remote InetSocketAddress

Parameters:

channel -

Returns:

the remote InetSocketAddress

getLocalInetSocketAddress

public static final InetSocketAddress getLocalInetSocketAddress(io.netty.channel.Channel channel)

Get the Local InetSocketAddress

Parameters:

channel -

Returns:

the local InetSocketAddress

nbCommandChannels

public static final int nbCommandChannels(Configuration configuration)

Return the current number of network connections

Parameters:

configuration -

Returns:

the current number of network connections

writeBackDataBlock

public static io.netty.channel.ChannelFuture writeBackDataBlock(LocalChannelReference localChannelReference,
                                                                DataBlock block)
                                                         throws OpenR66ProtocolPacketException

Parameters:

localChannelReference -

block -

Returns:

the ChannelFuture of this write operation

Throws:

OpenR66ProtocolPacketException

writeEndTransfer

public static final void writeEndTransfer(LocalChannelReference localChannelReference)
                                   throws OpenR66ProtocolPacketException

Write the EndTransfer

Parameters:

localChannelReference -

Throws:

OpenR66ProtocolPacketException

writeEndTransfer

public static final void writeEndTransfer(LocalChannelReference localChannelReference,
                                          String hash)
                                   throws OpenR66ProtocolPacketException

Write the EndTransfer plus Global Hash

Parameters:

localChannelReference -

hash -

Throws:

OpenR66ProtocolPacketException

writeAbstractLocalPacket

public static io.netty.channel.ChannelFuture writeAbstractLocalPacket(LocalChannelReference localChannelReference,
                                                                      AbstractLocalPacket packet,
                                                                      boolean wait)
                                                               throws OpenR66ProtocolPacketException

Write an AbstractLocalPacket to the network Channel

Parameters:

localChannelReference -

packet -

wait -

Returns:

the ChannelFuture on write operation

Throws:

OpenR66ProtocolPacketException

exit

public static void exit()

Exit global ChannelFactory

stopLogger

public static final void stopLogger()

run

public void run()

This function is the top function to be called when the server is to be shutdown.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

startShutdown

public static final void startShutdown()

Start Shutdown