com.metasolv.nm.collector.file

Class FtpEIManager

java.lang.Object

com.metasolv.nm.collector.file.FtpEIManager

public class FtpEIManager
extends java.lang.Object

This class is based on the FtpEITransportHandler class. The FtpEIManager class is responsible for initializing and managing a set of FTP threads. It will parse the node's configuration object to determine how many FTP servers were configured, and it will start one FtpEIThread thread for each of them. It will also instantiate the FtpFileTracker object that is used by the threads in order keep track of the files that they have retrieved from the remote servers. An example of the required ftp config file is: # # Comment lines begin with '#'... # NumberOfHosts 2 DelayTime 1 DelayTimeUnits Hours DeleteFiles false RenameFiles false ### Host0 ### FtpType0 Regular RemoteHost0 132.l23.204.39 RemoteDir0 /SYSTEM/DCLOG/ Mode0 simple Prefix0 Suffix0 .txt RegularExpression0 Login0 someUsername Password0 somePassword ### Host1 ### FtpType1 Regular RemoteHost1 132.l23.204.40 RemoteDir1 /tmp Mode1 regularexpression Prefix1 Suffix1 RegularExpression1 .+\.txt Login1 someUsername Password1 somePassword Use the '/' as the path separator, as this is the path separator recognized by FTP servers regardless of the operating system.

Field Summary

Fields

Modifier and Type	Field and Description
protected ConfigIfc	config
java.lang.String	DAYS
static java.lang.String	DAYS_TO_TRACK
protected static int	DAYS2SECS
protected int	delayTime
protected boolean	deleteFlag
protected SynchronizedDirectory	dir
protected DCNode	einode
protected int	FTP_DEFAULT_DELAY_TIME
protected Config	ftpConfig
protected FtpFileTracker	ftpFileTracker
protected FtpEIThread[]	ftpThreads
protected java.lang.String[]	ftpType
protected java.lang.String[]	hosts
protected static int	HOURS2SECS
java.lang.String	HR
protected int	INTERRUPT_TIME_DELAY
protected int	interruptTimeDelay
protected SMGLock	ioLock
protected boolean	isBinaryTransferMode
protected java.lang.String	localSuffix
protected LoggerIfc	logger
protected java.lang.String[]	loginStrs
java.lang.String	MIN
protected static int	MINUTES2SECS
protected java.lang.String[]	modes
protected java.lang.String[]	prefixes
protected java.lang.String[]	pwStrs
protected java.lang.String[]	regExps
protected java.lang.String[]	remoteFileDirs
protected boolean	renameFlag
protected java.lang.String[]	suffixes
protected int	totalHosts

Constructor Summary

Constructors

Constructor and Description
FtpEIManager(SynchronizedDirectory localDir, java.lang.String lSuffix, DCNode node)
FtpEIManager(SynchronizedDirectory localDir, java.lang.String lSuffix, DCNode node, FtpFileTracker tracker)

Method Summary

Modifier and Type	Method and Description
protected void	getFtpConfig()
int	getInterruptTimeDelay()
boolean	isHealthy()
void	setBinaryTransferMode(boolean isBinaryTransferMode)
void	setInterruptTimeDelay(int interruptTimeDelay)
void	setIOLock(SMGLock lock)
void	shutdown()
void	startRetrieval()

Methods inherited from class java.lang.Object

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

Field Detail

MIN

public final java.lang.String MIN

HR

public final java.lang.String HR

DAYS

public final java.lang.String DAYS

DAYS_TO_TRACK

public static final java.lang.String DAYS_TO_TRACK

See Also:

Constant Field Values

MINUTES2SECS

protected static final int MINUTES2SECS

See Also:

Constant Field Values

HOURS2SECS

protected static final int HOURS2SECS

See Also:

Constant Field Values

DAYS2SECS

protected static final int DAYS2SECS

See Also:

Constant Field Values

FTP_DEFAULT_DELAY_TIME

protected final int FTP_DEFAULT_DELAY_TIME

See Also:

Constant Field Values

INTERRUPT_TIME_DELAY

protected final int INTERRUPT_TIME_DELAY

See Also:

Constant Field Values

dir

protected SynchronizedDirectory dir

einode

protected DCNode einode

config

protected ConfigIfc config

logger

protected LoggerIfc logger

localSuffix

protected java.lang.String localSuffix

isBinaryTransferMode

protected boolean isBinaryTransferMode

totalHosts

protected int totalHosts

delayTime

protected int delayTime

deleteFlag

protected boolean deleteFlag

renameFlag

protected boolean renameFlag

ftpType

protected java.lang.String[] ftpType

hosts

protected java.lang.String[] hosts

remoteFileDirs

protected java.lang.String[] remoteFileDirs

modes

protected java.lang.String[] modes

prefixes

protected java.lang.String[] prefixes

suffixes

protected java.lang.String[] suffixes

regExps

protected java.lang.String[] regExps

loginStrs

protected java.lang.String[] loginStrs

pwStrs

protected java.lang.String[] pwStrs

ftpConfig

protected Config ftpConfig

ftpFileTracker

protected FtpFileTracker ftpFileTracker

ftpThreads

protected FtpEIThread[] ftpThreads

interruptTimeDelay

protected int interruptTimeDelay

ioLock

protected SMGLock ioLock

Constructor Detail

FtpEIManager

public FtpEIManager(SynchronizedDirectory localDir,
                    java.lang.String lSuffix,
                    DCNode node)
             throws NodeStartException

Throws:

NodeStartException

FtpEIManager

public FtpEIManager(SynchronizedDirectory localDir,
                    java.lang.String lSuffix,
                    DCNode node,
                    FtpFileTracker tracker)
             throws NodeStartException

Throws:

NodeStartException

Method Detail

setBinaryTransferMode

public void setBinaryTransferMode(boolean isBinaryTransferMode)

getFtpConfig

protected void getFtpConfig()
                     throws NodeStartException

Throws:

NodeStartException

startRetrieval

public void startRetrieval()

shutdown

public void shutdown()

isHealthy

public boolean isHealthy()

getInterruptTimeDelay

public int getInterruptTimeDelay()

setInterruptTimeDelay

public void setInterruptTimeDelay(int interruptTimeDelay)

setIOLock

public void setIOLock(SMGLock lock)