org.waarp.openr66.protocol.networkhandler

Class NetworkTransaction

java.lang.Object

org.waarp.openr66.protocol.networkhandler.NetworkTransaction

public class NetworkTransaction
extends Object

This class handles Network Transaction connections

Constructor Summary

Constructors

Constructor and Description
NetworkTransaction()

Method Summary

Modifier and Type	Method and Description
static void	addClient(NetworkChannelReference networkChannelReference, String requester) Add a requester channel
static NetworkChannelReference	addNetworkChannel(io.netty.channel.Channel channel, boolean isSsl) Add a new NetworkChannel from connection
static int	checkClosingNetworkChannel(NetworkChannelReference networkChannelReference, LocalChannelReference localChannelReference) Check if closing of the localChannel will bring future closing of NetworkChannel
void	closeAll() Close all Network Ttransaction
void	closeAll(boolean quickShutdown) Close all Network Ttransaction
static void	closedNetworkChannel(NetworkChannelReference networkChannelReference) Force remove of NetworkChannelReference when it is closed
static void	closedNetworkChannel(SocketAddress address) Force remove of NetworkChannelReference when it is closed
static LocalChannelReference	createConnectionFromNetworkChannelStartup(NetworkChannelReference networkChannelReference, NetworkPacket startupPacket, boolean fromSsl) Create the LocalChannelReference when a remote local channel starts its connection
LocalChannelReference	createConnectionWithRetry(SocketAddress socketAddress, boolean isSSL, R66Future futureRequest) Create a connection to the specified socketAddress with multiple retries
LocalChannelReference	createConnectionWithRetryWithAuthenticationException(SocketAddress socketAddress, boolean isSSL, R66Future futureRequest) Create a connection to the specified socketAddress with multiple retries
static NetworkChannelReference	getImmediateNetworkChannel(io.netty.channel.Channel channel)
static int	getNumberClients(String requester)
static int	getRetrieveRunnerActive()
static String	hashStatus()
static boolean	isBlacklisted(io.netty.channel.Channel channel)
static boolean	isShuttingdownNetworkChannel(SocketAddress address)
static int	nbAttachedConnection(SocketAddress address, String host)
static void	normalEndRetrieve(LocalChannelReference localChannelReference) Normal end of a Retrieve Operation
static void	proposeShutdownNetworkChannel(SocketAddress socketAddress, boolean isSSL) To be called when a remote server seems to be down for a while, so to not retry immediately
static void	runRetrieve(R66Session session) Start retrieve operation
static void	shuttingDownNetworkChannel(NetworkChannelReference networkChannelReference) Shutdown one Network Channel
static boolean	shuttingDownNetworkChannelBlackList(NetworkChannelReference networkChannelReference) Shutdown a NetworkChannel and add it to BlaclList
static boolean	shuttingdownNetworkChannelsPerHostID(String requester) Shutdown NetworkChannelReference as client
static void	stopAllEndRetrieve()
static void	stopRetrieve(LocalChannelReference localChannelReference) Stop a retrieve operation

Methods inherited from class java.lang.Object

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

Constructor Detail

NetworkTransaction

public NetworkTransaction()

Method Detail

hashStatus

public static String hashStatus()

createConnectionWithRetry

public LocalChannelReference createConnectionWithRetry(SocketAddress socketAddress,
                                                       boolean isSSL,
                                                       R66Future futureRequest)

Create a connection to the specified socketAddress with multiple retries

Parameters:

socketAddress -

isSSL -

futureRequest -

Returns:

the LocalChannelReference

createConnectionWithRetryWithAuthenticationException

public LocalChannelReference createConnectionWithRetryWithAuthenticationException(SocketAddress socketAddress,
                                                                                  boolean isSSL,
                                                                                  R66Future futureRequest)
                                                                           throws OpenR66ProtocolNotAuthenticatedException

Create a connection to the specified socketAddress with multiple retries

Parameters:

socketAddress -

isSSL -

futureRequest -

Returns:

the LocalChannelReference

Throws:

OpenR66ProtocolNotAuthenticatedException

createConnectionFromNetworkChannelStartup

public static LocalChannelReference createConnectionFromNetworkChannelStartup(NetworkChannelReference networkChannelReference,
                                                                              NetworkPacket startupPacket,
                                                                              boolean fromSsl)

Create the LocalChannelReference when a remote local channel starts its connection

Parameters:

networkChannelReference -

startupPacket -

Returns:

TransferReference

addNetworkChannel

public static NetworkChannelReference addNetworkChannel(io.netty.channel.Channel channel,
                                                        boolean isSsl)
                                                 throws OpenR66ProtocolRemoteShutdownException

Add a new NetworkChannel from connection

Parameters:

channel -

isSsl -

Throws:

OpenR66ProtocolRemoteShutdownException

proposeShutdownNetworkChannel

public static void proposeShutdownNetworkChannel(SocketAddress socketAddress,
                                                 boolean isSSL)

To be called when a remote server seems to be down for a while, so to not retry immediately

Parameters:

socketAddress -

shuttingDownNetworkChannel

public static void shuttingDownNetworkChannel(NetworkChannelReference networkChannelReference)

Shutdown one Network Channel

Parameters:

networkChannelReference -

shuttingDownNetworkChannelBlackList

public static boolean shuttingDownNetworkChannelBlackList(NetworkChannelReference networkChannelReference)

Shutdown a NetworkChannel and add it to BlaclList

Parameters:

networkChannelReference -

Returns:

True if this channel is now blacklisted for a while

isBlacklisted

public static boolean isBlacklisted(io.netty.channel.Channel channel)

Parameters:

channel -

Returns:

True if this channel is blacklisted

isShuttingdownNetworkChannel

public static boolean isShuttingdownNetworkChannel(SocketAddress address)

Parameters:

address -

Returns:

True if this address (associated channel) is currently in shutdown (or if this channel is not valid)

shuttingdownNetworkChannelsPerHostID

public static boolean shuttingdownNetworkChannelsPerHostID(String requester)

Shutdown NetworkChannelReference as client

Parameters:

requester -

Returns:

True if shutdown occurs

addClient

public static void addClient(NetworkChannelReference networkChannelReference,
                             String requester)

Add a requester channel

Parameters:

networkChannelReference -

requester -

getNumberClients

public static int getNumberClients(String requester)

Parameters:

requester -

Returns:

The number of NetworkChannels associated with this requester

closedNetworkChannel

public static void closedNetworkChannel(NetworkChannelReference networkChannelReference)

Force remove of NetworkChannelReference when it is closed

Parameters:

networkChannelReference -

closedNetworkChannel

public static void closedNetworkChannel(SocketAddress address)

Force remove of NetworkChannelReference when it is closed

Parameters:

address -

checkClosingNetworkChannel

public static int checkClosingNetworkChannel(NetworkChannelReference networkChannelReference,
                                             LocalChannelReference localChannelReference)

Check if closing of the localChannel will bring future closing of NetworkChannel

Parameters:

networkChannelReference -

localChannelReference -

Returns:

the number of local channel still connected to this channel

nbAttachedConnection

public static int nbAttachedConnection(SocketAddress address,
                                       String host)

Parameters:

address -

host -

Returns:

a number > 0 if a connection is still active on this socket or for this host

getImmediateNetworkChannel

public static final NetworkChannelReference getImmediateNetworkChannel(io.netty.channel.Channel channel)

Parameters:

channel -

Returns:

the associated NetworkChannelReference immediately (if known)

getRetrieveRunnerActive

public static int getRetrieveRunnerActive()

Returns:

the current number of active RetrieveRunner

runRetrieve

public static void runRetrieve(R66Session session)

Start retrieve operation

Parameters:

session -

stopRetrieve

public static void stopRetrieve(LocalChannelReference localChannelReference)

Stop a retrieve operation

Parameters:

localChannelReference -

normalEndRetrieve

public static void normalEndRetrieve(LocalChannelReference localChannelReference)

Normal end of a Retrieve Operation

Parameters:

localChannelReference -

closeAll

public void closeAll()

Close all Network Ttransaction

closeAll

public void closeAll(boolean quickShutdown)

Close all Network Ttransaction

stopAllEndRetrieve

public static void stopAllEndRetrieve()