org.waarp.openr66.context

Class R66Session

java.lang.Object

org.waarp.openr66.context.R66Session

All Implemented Interfaces:

SessionInterface

public class R66Session
extends Object
implements SessionInterface

The global object session in OpenR66, a session by local channel

Constructor Summary

Constructors

Constructor and Description
R66Session() Create the session

Method Summary

Modifier and Type	Method and Description
boolean	addError()
void	clear() Clean the session
R66Auth	getAuth()
int	getBlockSize()
R66BusinessInterface	getBusinessObject()
R66Dir	getDir()
HashMap<String,R66Dir>	getDirsFromSession()
boolean	getExtendedProtocol()
R66File	getFile()
FilesystemBasedFileParameterImpl	getFileParameter()
SocketAddress	getLocalAddress()
LocalChannelReference	getLocalChannelReference()
SocketAddress	getRemoteAddress()
R66Restart	getRestart()
DbTaskRunner	getRunner()
R66FiniteDualStates	getState()
String	getUniqueExtension()
boolean	isAuthenticated()
boolean	isReady()
void	newState(R66FiniteDualStates desiredstate) Propose a new State
void	partialClear()
void	renameReceiverFile(String newFilename) Rename the current receive file from the very beginning since the sender has a post action that changes its name
void	setBadRunner(DbTaskRunner runner, ErrorCode code) To be used when a request comes with a bad code so it cannot be set normally
void	setBlockSize(int blocksize)
void	setBusinessObject(R66BusinessInterface businessObject)
void	setErrorState()
void	setFileAfterPreRunner(boolean createFile) Set the File from the runner once PRE operation are done
void	setFileBeforePreRunner() Set the File from the runner before PRE operation are done
void	setFinalizeTransfer(boolean status, R66Result finalValue) Finalize the transfer step by running the error or post operation according to the status.
void	setLocalChannelReference(LocalChannelReference localChannelReference)
void	setNoSessionRunner(DbTaskRunner runner, LocalChannelReference localChannelReference) To be called in case of No Session not from a valid LocalChannelHandler
void	setReady(boolean isReady)
void	setRunner(DbTaskRunner runner) Set the runner, and setup the directory first.
void	setStatus(int stat) Debugging purpose (trace)
void	startup(boolean checkNotExternal) START from the PreTask if necessary, and prepare the file
String	toString()
void	tryFinalizeRequest(R66Result errorValue) Try to finalize the request if possible

Methods inherited from class java.lang.Object

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

Constructor Detail

R66Session

public R66Session()

Create the session

Method Detail

getExtendedProtocol

public boolean getExtendedProtocol()

Returns:

extendedProtocol

getBusinessObject

public R66BusinessInterface getBusinessObject()

Returns:

the businessObject

setBusinessObject

public void setBusinessObject(R66BusinessInterface businessObject)

Parameters:

businessObject - the businessObject to set

newState

public void newState(R66FiniteDualStates desiredstate)

Propose a new State

Parameters:

desiredstate -

Throws:

IllegalFiniteStateException - if the new status if not ok

setErrorState

public void setErrorState()

getState

public R66FiniteDualStates getState()

Returns:

the current state in the finite state machine

setStatus

public void setStatus(int stat)

Debugging purpose (trace)

Parameters:

stat -

clear

public void clear()

Description copied from interface: SessionInterface

Clean the session

Specified by:

clear in interface SessionInterface

partialClear

public void partialClear()

getAuth

public R66Auth getAuth()

Specified by:

getAuth in interface SessionInterface

Returns:

the AuthInterface

getBlockSize

public int getBlockSize()

Specified by:

getBlockSize in interface SessionInterface

Returns:

the BlockSize to use in FileInterface operations

setBlockSize

public void setBlockSize(int blocksize)

Parameters:

blocksize - the blocksize to set

getDir

public R66Dir getDir()

Specified by:

getDir in interface SessionInterface

Returns:

the DirInterface

getFileParameter

public FilesystemBasedFileParameterImpl getFileParameter()

Specified by:

getFileParameter in interface SessionInterface

Returns:

the configuration

getRestart

public R66Restart getRestart()

Specified by:

getRestart in interface SessionInterface

Returns:

the Restart

isAuthenticated

public boolean isAuthenticated()

Returns:

True if the connection is currently authenticated

isReady

public boolean isReady()

Returns:

True if the Channel is ready to accept transfer

setReady

public void setReady(boolean isReady)

Parameters:

isReady - the isReady for transfer to set

getRunner

public DbTaskRunner getRunner()

Returns:

the runner

setLocalChannelReference

public void setLocalChannelReference(LocalChannelReference localChannelReference)

Parameters:

localChannelReference - the localChannelReference to set

getRemoteAddress

public SocketAddress getRemoteAddress()

Returns:

the remote SocketAddress

getLocalAddress

public SocketAddress getLocalAddress()

Returns:

the local SocketAddress

getLocalChannelReference

public LocalChannelReference getLocalChannelReference()

Returns:

the localChannelReference

setNoSessionRunner

public void setNoSessionRunner(DbTaskRunner runner,
                               LocalChannelReference localChannelReference)

To be called in case of No Session not from a valid LocalChannelHandler

Parameters:

runner -

localChannelReference -

setFileBeforePreRunner

public void setFileBeforePreRunner()
                            throws OpenR66RunnerErrorException

Set the File from the runner before PRE operation are done

Throws:

OpenR66RunnerErrorException

setFileAfterPreRunner

public void setFileAfterPreRunner(boolean createFile)
                           throws OpenR66RunnerErrorException,
                                  CommandAbstractException

Set the File from the runner once PRE operation are done

Parameters:

createFile - When True, the file can be newly created if needed. If False, no new file will be created, thus having an Exception.

Throws:

OpenR66RunnerErrorException

CommandAbstractException - only when new received created file cannot be created

setBadRunner

public void setBadRunner(DbTaskRunner runner,
                         ErrorCode code)

To be used when a request comes with a bad code so it cannot be set normally

Parameters:

runner -

code -

setRunner

public void setRunner(DbTaskRunner runner)
               throws OpenR66RunnerErrorException

Set the runner, and setup the directory first.

This call should be followed by a startup() call.

Parameters:

runner - the runner to set

Throws:

OpenR66RunnerErrorException

startup

public void startup(boolean checkNotExternal)
             throws OpenR66RunnerErrorException

START from the PreTask if necessary, and prepare the file

Parameters:

checkNotExternal - if True, the file as Sender should not be external to current directory

Throws:

OpenR66RunnerErrorException

renameReceiverFile

public void renameReceiverFile(String newFilename)
                        throws OpenR66RunnerErrorException

Rename the current receive file from the very beginning since the sender has a post action that changes its name

Parameters:

newFilename -

Throws:

OpenR66RunnerErrorException

setFinalizeTransfer

public void setFinalizeTransfer(boolean status,
                                R66Result finalValue)
                         throws OpenR66RunnerErrorException,
                                OpenR66ProtocolSystemException

Finalize the transfer step by running the error or post operation according to the status.

Parameters:

status -

finalValue -

Throws:

OpenR66RunnerErrorException

OpenR66ProtocolSystemException

tryFinalizeRequest

public void tryFinalizeRequest(R66Result errorValue)
                        throws OpenR66RunnerErrorException,
                               OpenR66ProtocolSystemException

Try to finalize the request if possible

Parameters:

errorValue -

Throws:

OpenR66RunnerErrorException

OpenR66ProtocolSystemException

getFile

public R66File getFile()

Returns:

the file

addError

public boolean addError()

Returns:

True if the number of Error is still acceptable

toString

public String toString()

Overrides:

toString in class Object

getUniqueExtension

public String getUniqueExtension()

Specified by:

getUniqueExtension in interface SessionInterface

Returns:

the extension to give to Unique File (STOU)

getDirsFromSession

public HashMap<String,R66Dir> getDirsFromSession()

Returns:

the dirsFromSession