com.nt.udc.ei.transport

Class InputFileProcessor

java.lang.Object

com.nt.udc.ei.transport.InputFileProcessor

All Implemented Interfaces:

InputFileProcessorIfc

public abstract class InputFileProcessor
extends java.lang.Object
implements InputFileProcessorIfc

Field Summary

Fields

Modifier and Type	Field and Description
protected InputStatisticsMonitorIfc	inputCount
protected LoggerIfc	logger Represents the logging facility for the EI node using this object.
protected EINode	node
protected boolean	running Number of bytes having been read so far.

Constructor Summary

Constructors

Constructor and Description
InputFileProcessor(EINode einode)

Method Summary

Modifier and Type	Method and Description
protected long	getLength(java.io.File file) Returns the length stored in the scratch file.
RecoveryInformation	getRecoveryInformation()
protected void	incrementIn()
boolean	postProcessInputData(OpenFileInputStream inputStream, java.io.File fileToProcess, java.io.File scratchFile)
boolean	preProcessInputData(OpenFileInputStream inputStream, java.io.File fileToProcess, java.io.File scratchFile)
boolean	processInputData(OpenFileInputStream inputStream, DataReceiverIfc dataReceiver)
void	shutdown() Specifies actions needed to shut down the thread in which this object runs.
protected void	writeLength(java.io.File scratchfile, long len) Record a long in a file - used to write a length in a scratch file to keep track of how much of a file has been processed.

Methods inherited from class java.lang.Object

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

Field Detail

running

protected boolean running

Number of bytes having been read so far.

logger

protected LoggerIfc logger

Represents the logging facility for the EI node using this object.

node

protected EINode node

inputCount

protected InputStatisticsMonitorIfc inputCount

Constructor Detail

InputFileProcessor

public InputFileProcessor(EINode einode)

Method Detail

preProcessInputData

public boolean preProcessInputData(OpenFileInputStream inputStream,
                                   java.io.File fileToProcess,
                                   java.io.File scratchFile)
                            throws java.lang.Exception

Specified by:

preProcessInputData in interface InputFileProcessorIfc

Throws:

java.lang.Exception

processInputData

public boolean processInputData(OpenFileInputStream inputStream,
                                DataReceiverIfc dataReceiver)
                         throws java.lang.Exception

Specified by:

processInputData in interface InputFileProcessorIfc

Throws:

java.lang.Exception

postProcessInputData

public boolean postProcessInputData(OpenFileInputStream inputStream,
                                    java.io.File fileToProcess,
                                    java.io.File scratchFile)
                             throws java.lang.Exception

Specified by:

postProcessInputData in interface InputFileProcessorIfc

Throws:

java.lang.Exception

shutdown

public void shutdown()

Specifies actions needed to shut down the thread in which this object runs.

Specified by:

shutdown in interface InputFileProcessorIfc

writeLength

protected void writeLength(java.io.File scratchfile,
                           long len)

Record a long in a file - used to write a length in a scratch file to keep track of how much of a file has been processed. Used for recovering when the node is shut down prematurely (or crashes or dies unexpectedly). To use this, call it from the appropriate place in your version of the "processFiles" method.

getLength

protected long getLength(java.io.File file)

Returns the length stored in the scratch file. Used to keep track of how much of a file has been processed.

Parameters:

file - Specifies the scratch file.

Returns:

number of bytes that have already been read and processed.

getRecoveryInformation

public RecoveryInformation getRecoveryInformation()

Specified by:

getRecoveryInformation in interface InputFileProcessorIfc

incrementIn

protected void incrementIn()