com.ptc.wvs.server.cadagent
Class Worker

java.lang.Object
  com.ptc.wvs.server.cadagent.Worker

All Implemented Interfaces:

Cloneable

public class Worker

extends Object

implements Cloneable

Field Summary

private int	autoBusyStop
private boolean	autoErrorStop
private int	autoIdleStop
private boolean	autoStart
private String	availableTime
private Vector	availableTimes
private boolean	busy
private boolean	connected
private boolean	dca
private Worker	dcaWorker
private String	displayName
private boolean	distAutoStart
private String	distExe
private String	distLogDirectory
private int	distMaxInstances
private int	distPort
private boolean	distributed
private DistributedMessages	distributedMessage
private String	distRule
private int	distStarttime
private String	distTransferPath
private boolean	enabled
private String	exe
private String[]	fileFilter
(package private) boolean	ftpEnabled
private String	host
private String	hostType
private long	idleStart
private int	instance
private String	job
private int	jobNumber
private long	jobStart
private long	jobStop
private String	localPath
private Log	log
private boolean	logShown
private int	maxInstances
private int	maxStartAttempts
private JCheckBoxMenuItem	menuEntry
private Monitor	monitor
private boolean	noAutoStart
private boolean	offline
private boolean	offlineUnderManualControl
private boolean	olonlyFilter
private boolean	onThisMachine
private String	password
private int	port
private String	prompt
private boolean	pseudoWorker
private Vector	pseudoWorkers
private int	psWorkerCount
private String	remotePath
private String	reply
private String	replyDir
private Socket	socket
private int	startAttempts
private boolean	starting
private int	starttime
private boolean	state
private String	subDir
private boolean	talking
private int	time
private long	timeOut
private String	type
private ArrayList	typeList
private boolean	Unix
private String	username
private boolean	workerToBeStopped
private WorkOrder	workOrder

Constructor Summary

Worker(String type)

Method Summary

void	associateWorker(Worker worker)
Object	clone()
String	copyAllFiles(String from, String to)
String	copyFile(String from, String to)
String	createTransferDirectory(String path)
String	deleteAllTrash(String path)
String	getAllFiles(String from, String to)
int	getAutoBusyStop()
int	getAutoIdleStop()
String	getAvailableTime()
Vector	getAvailableTimes()
Date	getDate()
Worker	getDcaWorker()
String	getDisplayName()
boolean	getDistAutoStart()
String	getDistExe()
String	getDistLogDirectory()
int	getDistMaxInstances()
int	getDistPort()
DistributedMessages	getDistributedMessage()
String	getDistRule()
int	getDistStarttime()
String	getDistTransferPath()
String	getExe()
String	getHost()
String	getHostType()
long	getIdleStart()
int	getInstance()
String	getJob()
String	getJobLogName(String text)
int	getJobNumber()
long	getJobStart()
long	getJobStop()
String	getLatestLogContents()
String	getLocalPath()
Log	getLog()
LogPane	getLogPane()
int	getMaxInstances()
int	getMaxStartAttempts()
JCheckBoxMenuItem	getMenuEntry()
Monitor	getMonitor()
String	getPassword()
int	getPort()
String	getPrompt()
String	getRemotePath()
String	getReply()
String	getReplyDir()
Socket	getSocket()
int	getStartAttempts()
String	getStartPseudoWorkerCommand()
int	getStarttime()
boolean	getState()
String	getStopPseudoWorkerCommand()
String	getSubDir()
int	getTime()
long	getTimeOut()
String	getType()
String	getUsername()
WorkOrder	getWorkOrder()
void	init()
boolean	isAutoErrorStop()
boolean	isAutoStart()
boolean	isBusy()
boolean	isConnected()
boolean	isDCA()
boolean	isDistributed()
boolean	isEnabled()
boolean	isFailedToStart()
boolean	isFtpEnabled()
boolean	isLogShown()
boolean	isNoAutoStart()
boolean	isNt()
boolean	isOffLine()
boolean	isOffLineUnderManualControl()
boolean	isOnThisMachine()
boolean	isPseudoWorker()
boolean	isStarting()
boolean	isTalking()
boolean	isTimeOutExceeded()
boolean	isUnix()
boolean	isWorkerConnected()
boolean	isWorkerToBeStopped()
private void	send(Socket socket, String message)
void	sendConfiguration()
void	sendDmStartedWorker()
void	sendDmStoppedWorker()
void	sendReply()
void	sendReply(String message)
void	setAutoBusyStop(int autoBusyStop)
void	setAutoErrorStop(boolean autoErrorStop)
void	setAutoIdleStop(int autoIdleStop)
void	setAutoStart(boolean autoStart)
void	setAvailableTime(String atme)
void	setBusy(boolean busy)
void	setConnected(boolean connected)
void	setDCA(boolean dca)
void	setDcaWorker(Worker dcaWorker)
void	setDisplayName(String displayName)
void	setDistAutoStart(boolean distAutoStart)
void	setDistExe(String distExe)
void	setDistLogDirectory(String distLogDirectory)
void	setDistMaxInstances(int distMaxInstances)
void	setDistPort(int distPort)
void	setDistributed(boolean distributed)
void	setDistributedMessage(DistributedMessages distributedMessage)
void	setDistRule(String distRule)
void	setDistStarttime(int distStarttime)
void	setDistTransferPath(String distTransferPath)
void	setEnabled(boolean state)
void	setExe(String exe)
void	setHost(String host)
void	setHostType(String hostType)
void	setIdleStart(long idleStart)
void	setInstance(int instance)
void	setJob(String job)
void	setJobNumber(int jobNumber)
void	setJobStart(long jobStart)
void	setJobStop(long jobStop)
void	setLocalPath(String localPath)
void	setLog(Log log)
void	setLogShown(boolean logShown)
void	setMaxInstances(int maxInstances)
void	setMaxStartAttempts(int maxStartAttempts)
void	setMenuEntry(JCheckBoxMenuItem menuEntry)
void	setMonitor(Monitor m)
void	setNoAutoStart(boolean noAutoStart)
void	setOffLine(boolean state)
void	setPassword(String password)
void	setPort(int port)
void	setPrompt(String prompt)
void	setPseudoWorker(boolean inpseudoWorker)
void	setRemotePath(String remotePath)
void	setReply(String reply)
void	setReplyDir(String replyDir)
void	setReturnFileFilter(boolean olonly, String path)
void	setSocket(Socket socket)
void	setStartAttempts(int startAttempts)
void	setStarting(boolean starting)
void	setStarttime(int starttime)
void	setState(boolean state)
void	setSubDir(String subDir)
void	setTalking(boolean talking)
void	setTime(int time)
void	setTimeOut(long timeOut)
void	setUsername(String username)
void	setWorkerToBeStopped(boolean stop)
void	setWorkOrder(WorkOrder workOrder)
void	shutdown()
void	stopIdleWorker()
void	toggleOffLineUnderManualControl()

Methods inherited from class java.lang.Object

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

Field Detail

host

private String host

type

private String type

displayName

private String displayName

reply

private String reply

job

private String job

state

private boolean state

enabled

private boolean enabled

offline

private boolean offline

offlineUnderManualControl

private boolean offlineUnderManualControl

availableTime

private String availableTime

availableTimes

private Vector availableTimes

distributed

private boolean distributed

distExe

private String distExe

distRule

private String distRule

distLogDirectory

private String distLogDirectory

distPort

private int distPort

distStarttime

private int distStarttime

distAutoStart

private boolean distAutoStart

distTransferPath

private String distTransferPath

ftpEnabled

boolean ftpEnabled

localPath

private String localPath

remotePath

private String remotePath

hostType

private String hostType

exe

private String exe

port

private int port

prompt

private String prompt

username

private String username

password

private String password

starttime

private int starttime

autoStart

private boolean autoStart

noAutoStart

private boolean noAutoStart

autoIdleStop

private int autoIdleStop

autoBusyStop

private int autoBusyStop

autoErrorStop

private boolean autoErrorStop

maxInstances

private int maxInstances

distMaxInstances

private int distMaxInstances

instance

private int instance

startAttempts

private int startAttempts

maxStartAttempts

private int maxStartAttempts

subDir

private String subDir

replyDir

private String replyDir

onThisMachine

private boolean onThisMachine

Unix

private boolean Unix

workOrder

private WorkOrder workOrder

monitor

private Monitor monitor

socket

private Socket socket

menuEntry

private JCheckBoxMenuItem menuEntry

log

private Log log

busy

private boolean busy

starting

private boolean starting

workerToBeStopped

private boolean workerToBeStopped

connected

private boolean connected

talking

private boolean talking

logShown

private boolean logShown

idleStart

private long idleStart

jobStart

private long jobStart

jobStop

private long jobStop

jobNumber

private int jobNumber

fileFilter

private String[] fileFilter

olonlyFilter

private boolean olonlyFilter

typeList

private ArrayList typeList

pseudoWorkers

private Vector pseudoWorkers

pseudoWorker

private boolean pseudoWorker

psWorkerCount

private int psWorkerCount

dca

private boolean dca

distributedMessage

private DistributedMessages distributedMessage

dcaWorker

private Worker dcaWorker

time

private int time

timeOut

private long timeOut

Constructor Detail

Worker

public Worker(String type)

Method Detail

init

public void init()

setTime

public void setTime(int time)

getTime

public int getTime()

setTimeOut

public void setTimeOut(long timeOut)

getTimeOut

public long getTimeOut()

isTimeOutExceeded

public boolean isTimeOutExceeded()

associateWorker

public void associateWorker(Worker worker)

isDCA

public boolean isDCA()

setDcaWorker

public void setDcaWorker(Worker dcaWorker)

getDcaWorker

public Worker getDcaWorker()

setMonitor

public void setMonitor(Monitor m)

getMonitor

public Monitor getMonitor()

setDCA

public void setDCA(boolean dca)

clone

public Object clone()

setPseudoWorker

public void setPseudoWorker(boolean inpseudoWorker)

isPseudoWorker

public boolean isPseudoWorker()

setNoAutoStart

public void setNoAutoStart(boolean noAutoStart)

isNoAutoStart

public boolean isNoAutoStart()

setJob

public void setJob(String job)

setHost

public void setHost(String host)

setEnabled

public void setEnabled(boolean state)

isEnabled

public boolean isEnabled()

toggleOffLineUnderManualControl

public void toggleOffLineUnderManualControl()

isOffLineUnderManualControl

public boolean isOffLineUnderManualControl()

setOffLine

public void setOffLine(boolean state)

isOffLine

public boolean isOffLine()

setAvailableTime

public void setAvailableTime(String atme)

getAvailableTime

public String getAvailableTime()

getAvailableTimes

public Vector getAvailableTimes()

setState

public void setState(boolean state)

getState

public boolean getState()

setDisplayName

public void setDisplayName(String displayName)

setReply

public void setReply(String reply)

setLocalPath

public void setLocalPath(String localPath)

setRemotePath

public void setRemotePath(String remotePath)

setHostType

public void setHostType(String hostType)

setExe

public void setExe(String exe)

setPort

public void setPort(int port)

setStartAttempts

public void setStartAttempts(int startAttempts)

setMaxStartAttempts

public void setMaxStartAttempts(int maxStartAttempts)

setPrompt

public void setPrompt(String prompt)

setUsername

public void setUsername(String username)

setPassword

public void setPassword(String password)

setStarttime

public void setStarttime(int starttime)

setAutoStart

public void setAutoStart(boolean autoStart)

setAutoIdleStop

public void setAutoIdleStop(int autoIdleStop)

setAutoBusyStop

public void setAutoBusyStop(int autoBusyStop)

setAutoErrorStop

public void setAutoErrorStop(boolean autoErrorStop)

setMaxInstances

public void setMaxInstances(int maxInstances)

setDistributed

public void setDistributed(boolean distributed)

isDistributed

public boolean isDistributed()

setDistributedMessage

public void setDistributedMessage(DistributedMessages distributedMessage)

getDistributedMessage

public DistributedMessages getDistributedMessage()

setDistMaxInstances

public void setDistMaxInstances(int distMaxInstances)

setDistExe

public void setDistExe(String distExe)

setDistRule

public void setDistRule(String distRule)

setDistLogDirectory

public void setDistLogDirectory(String distLogDirectory)

getDistMaxInstances

public int getDistMaxInstances()

getDistExe

public String getDistExe()

getDistRule

public String getDistRule()

getDistLogDirectory

public String getDistLogDirectory()

setDistPort

public void setDistPort(int distPort)

getDistPort

public int getDistPort()

setDistAutoStart

public void setDistAutoStart(boolean distAutoStart)

getDistAutoStart

public boolean getDistAutoStart()

setDistStarttime

public void setDistStarttime(int distStarttime)

getDistStarttime

public int getDistStarttime()

setDistTransferPath

public void setDistTransferPath(String distTransferPath)

getDistTransferPath

public String getDistTransferPath()

setJobNumber

public void setJobNumber(int jobNumber)

setInstance

public void setInstance(int instance)

setSubDir

public void setSubDir(String subDir)

setReplyDir

public void setReplyDir(String replyDir)

setSocket

public void setSocket(Socket socket)

setWorkOrder

public void setWorkOrder(WorkOrder workOrder)

setMenuEntry

public void setMenuEntry(JCheckBoxMenuItem menuEntry)

setLog

public void setLog(Log log)

setWorkerToBeStopped

public void setWorkerToBeStopped(boolean stop)

setStarting

public void setStarting(boolean starting)

setBusy

public void setBusy(boolean busy)

setTalking

public void setTalking(boolean talking)

setConnected

public void setConnected(boolean connected)

setLogShown

public void setLogShown(boolean logShown)

setIdleStart

public void setIdleStart(long idleStart)

setJobStart

public void setJobStart(long jobStart)

setJobStop

public void setJobStop(long jobStop)

getJob

public String getJob()

getHost

public String getHost()

getType

public String getType()

getDisplayName

public String getDisplayName()

getReply

public String getReply()

getLocalPath

public String getLocalPath()

getRemotePath

public String getRemotePath()

getHostType

public String getHostType()

getExe

public String getExe()

getPort

public int getPort()

getStartAttempts

public int getStartAttempts()

getMaxStartAttempts

public int getMaxStartAttempts()

isFailedToStart

public boolean isFailedToStart()

getPrompt

public String getPrompt()

getUsername

public String getUsername()

getPassword

public String getPassword()

getStarttime

public int getStarttime()

isAutoStart

public boolean isAutoStart()

getAutoIdleStop

public int getAutoIdleStop()

getAutoBusyStop

public int getAutoBusyStop()

isAutoErrorStop

public boolean isAutoErrorStop()

getMaxInstances

public int getMaxInstances()

getJobNumber

public int getJobNumber()

getJobLogName

public String getJobLogName(String text)

getInstance

public int getInstance()

getSubDir

public String getSubDir()

getReplyDir

public String getReplyDir()

getSocket

public Socket getSocket()

getWorkOrder

public WorkOrder getWorkOrder()

getMenuEntry

public JCheckBoxMenuItem getMenuEntry()

getLog

public Log getLog()

getLogPane

public LogPane getLogPane()

getIdleStart

public long getIdleStart()

getDate

public Date getDate()

getJobStart

public long getJobStart()

getJobStop

public long getJobStop()

isOnThisMachine

public boolean isOnThisMachine()

isUnix

public boolean isUnix()

isNt

public boolean isNt()

isWorkerToBeStopped

public boolean isWorkerToBeStopped()

stopIdleWorker

public void stopIdleWorker()

isBusy

public boolean isBusy()

isStarting

public boolean isStarting()

isConnected

public boolean isConnected()

isTalking

public boolean isTalking()

isWorkerConnected

public boolean isWorkerConnected()

isLogShown

public boolean isLogShown()

isFtpEnabled

public boolean isFtpEnabled()

shutdown

public void shutdown()

createTransferDirectory

public String createTransferDirectory(String path)

getAllFiles

public String getAllFiles(String from,
                          String to)

copyAllFiles

public String copyAllFiles(String from,
                           String to)

copyFile

public String copyFile(String from,
                       String to)

deleteAllTrash

public String deleteAllTrash(String path)

setReturnFileFilter

public void setReturnFileFilter(boolean olonly,
                                String path)

getLatestLogContents

public String getLatestLogContents()

sendReply

public void sendReply()

sendReply

public void sendReply(String message)

sendConfiguration

public void sendConfiguration()

sendDmStartedWorker

public void sendDmStartedWorker()

sendDmStoppedWorker

public void sendDmStoppedWorker()

getStartPseudoWorkerCommand

public String getStartPseudoWorkerCommand()

getStopPseudoWorkerCommand

public String getStopPseudoWorkerCommand()

send

private void send(Socket socket,
                  String message)