Package com.nt.udc.nar

Class NARFileManagerMT

java.lang.Object

com.nt.udc.nar.NARStreamHandler

com.nt.udc.nar.NARFileManager

com.nt.udc.nar.NARFileManagerMT

All Implemented Interfaces:

DataProviderIfc, DataReceiverIfc, DCStreamHandler, FileDataProviderIfc, FileDataReceiverIfc

public class NARFileManagerMT
extends NARFileManager

Field Summary

Fields inherited from class com.nt.udc.nar.NARFileManager

dataProvider, dataReceiver, fileDataProvider, fileDataReceiver

Fields inherited from class com.nt.udc.nar.NARStreamHandler

inputShutdown, narsIn, narsOut, np, outputShutdown

Constructor Summary

Constructors

Constructor	Description
NARFileManagerMT(DCNode node)	Default Constructor

Method Summary

Modifier and Type	Method	Description
DCFieldContainer[]	getBulkData()	This is called by FieldProcessors (when set to use bulk processing).
DCFieldContainer	getData()	This is called by Field Processors when processing a single NAR This method has been synchronized
DataProviderIfc	getDataProvider()	Dummy Method to notify me if something calls this function
DataReceiverIfc	getDataReceiver()	Dummy Method just to notify me if something calls this function
void	processData(DCFieldContainer nar)	This is called by Field Processors when they have completed processing a single NAR.
void	processData(DCFieldContainer[] nars)	This is called by Field Processors when they have completed processing a set of NARs
void	setDataProvider(DataProviderIfc provider)	This method will "add" the data provider to the list of data providers
void	setDataReceiver(DataReceiverIfc receiver)	This method will "add" this data receiver object tot the list

Methods inherited from class com.nt.udc.nar.NARFileManager

addProcessedFileInWriterMap, checkInput, cleanup, createNewCacheFile, dataIsAvailable, fileDataIsAvailable, getCurrArchFile, getData, getFileBulkData, getFileData, getFileDataProvider, getFileDataReceiver, getFilenameGenerator, getNodeID, getProcessedArchFile, getProcessedFileList, getRealNarsIn, handleRejectOfFile, isDataAvailable, isEndOfFile, isFileDataAvailable, isStartOfFile, moveToReadyToOut, openInputFile, processEndOfFileData, processFileData, processFileData, processRejectFile, processStartOfFileData, readBulkData, readData, readNAR, readNAR, readNARs, readNARsFromFile, rejectFile, removeProcessedFile, setFileDataProvider, setFileDataReceiver, setFilenameGenerator, setProcessedArchFile, setTransactionID, shutdown, shutdownInput, shutdownOutput, signalBatchCompletion, storeNAR, storeNARs, validOIMinorType

Methods inherited from class com.nt.udc.nar.NARStreamHandler

getPerformanceMetrics, writeData, writeData

Methods inherited from class java.lang.Object

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

Constructor Details

NARFileManagerMT

public NARFileManagerMT(DCNode node)

Default Constructor

Parameters:

node - The cartridge for which this NARFileManagerMT object will be created

Method Details

getBulkData

public DCFieldContainer[] getBulkData()

This is called by FieldProcessors (when set to use bulk processing). If this method does happen to get called, it will only return a single NAR however

Specified by:

getBulkData in interface DataProviderIfc

Overrides:

getBulkData in class NARFileManager

Returns:

A set of NARs

processData

public void processData(DCFieldContainer[] nars)

This is called by Field Processors when they have completed processing a set of NARs

Specified by:

processData in interface DataReceiverIfc

Overrides:

processData in class NARFileManager

Parameters:

nars - An array of processed NARs

processData

public void processData(DCFieldContainer nar)

This is called by Field Processors when they have completed processing a single NAR. This method has been synchronized as there could be many threads calling this method at the same time

Specified by:

processData in interface DataReceiverIfc

Overrides:

processData in class NARFileManager

Parameters:

nar - The nar that was processed

getData

public DCFieldContainer getData()

This is called by Field Processors when processing a single NAR This method has been synchronized

Specified by:

getData in interface DataProviderIfc

Overrides:

getData in class NARFileManager

Returns:

A single NAR to process

setDataProvider

public void setDataProvider(DataProviderIfc provider)

This method will "add" the data provider to the list of data providers

Specified by:

setDataProvider in interface DataReceiverIfc

Overrides:

setDataProvider in class NARFileManager

Parameters:

provider - DataProvider of this receiver

dataprovider - The data provider to add

getDataProvider

public DataProviderIfc getDataProvider()

Dummy Method to notify me if something calls this function

Specified by:

getDataProvider in interface DataReceiverIfc

Overrides:

getDataProvider in class NARFileManager

Returns:

null

setDataReceiver

public void setDataReceiver(DataReceiverIfc receiver)

This method will "add" this data receiver object tot the list

Specified by:

setDataReceiver in interface DataProviderIfc

Overrides:

setDataReceiver in class NARFileManager

Parameters:

receiver - Object which will receive data from this provider

datareceiver - The data receiver to add

getDataReceiver

public DataReceiverIfc getDataReceiver()

Dummy Method just to notify me if something calls this function

Specified by:

getDataReceiver in interface DataProviderIfc

Overrides:

getDataReceiver in class NARFileManager

Returns:

null