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 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 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, FilesystemBasedDigest digestGlobal, DataBlock block, FilesystemBasedDigest digestBlock)
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

nbCommandChannels

public static 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,
                                                                FilesystemBasedDigest digestGlobal,
                                                                DataBlock block,
                                                                FilesystemBasedDigest digestBlock)
                                                         throws OpenR66ProtocolPacketException

Parameters:

localChannelReference -

digestGlobal -

block -

Returns:

the ChannelFuture of this write operation

Throws:

OpenR66ProtocolPacketException

writeEndTransfer

public static void writeEndTransfer(LocalChannelReference localChannelReference)
                             throws OpenR66ProtocolPacketException

Write the EndTransfer

Parameters:

localChannelReference -

Throws:

OpenR66ProtocolPacketException

writeEndTransfer

public static 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

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 void startShutdown()

Start Shutdown