Class TransferScheduler.DestinationThread

java.lang.Object

ecmwf.common.technical.ThreadService.ConfigurableRunnable

ecmwf.common.technical.WakeupThread

ecmwf.common.ecaccess.ECaccessScheduler

ecmwf.common.ecaccess.MBeanScheduler

ecmwf.common.ecaccess.MBeanRepository<DataTransfer>

ecmwf.ecpds.master.transfer.TransferScheduler.DestinationThread

All Implemented Interfaces:

MBeanService, MonitorCallback, Closeable, AutoCloseable, Runnable

Enclosing class:

TransferScheduler

public final class TransferScheduler.DestinationThread
extends MBeanRepository<DataTransfer>

The Class DestinationThread.

Field Summary

Fields inherited from class ecmwf.common.ecaccess.ECaccessScheduler

NEXT_STEP_ABORT, NEXT_STEP_CONTINUE, NEXT_STEP_DELAY, NEXT_STEP_INIT, SCHEDULER_STATE_CLOSING, SCHEDULER_STATE_JAMMED, SCHEDULER_STATE_OFFLINE, SCHEDULER_STATE_ONHOLD, SCHEDULER_STATE_ONLINE, SCHEDULER_STATE_OPENING, states, steps

Method Summary

Modifier and Type	Method	Description
String	getActivity()	Gets the activity.
Object	getAttribute(String attributeName)	Gets the attribute.
int	getDestinationStep()	Gets the destination step.
String	getKey(DataTransfer transfer)	Gets the key.
DataTransfer	getLastFailedTransfer()	Gets the last failed transfer.
DataTransfer	getLastTransfer()	Gets the last transfer.
MBeanInfo	getMBeanInfo()	Gets the MBean info.
DataTransfer	getNextTransfer()	Gets the next transfer.
int	getPerformed()	Gets the performed.
int	getSelected()	Gets the selected.
String	getStatus(DataTransfer transfer)	Gets the status.
void	initialize()	Initialize.
void	loadPendingDataTransfers()	Load pending data transfers.
int	nextStep()	Next step.
void	reset()	Reset.
void	shutdown()	Shutdown.
void	shutdown(long timeout, boolean reset, String comment)	Shutdown.
boolean	toBeReseted()	Signal is should be reset.

Methods inherited from class ecmwf.common.ecaccess.MBeanRepository

clear, containsKey, containsValue, getComparator, getList, getList, getSize, getStatus, getValue, getWakeup, invoke, put, removeKey, removeValue, setComparator, setMaxAuthorisedSize, setWakeup, sort

Methods inherited from class ecmwf.common.ecaccess.MBeanScheduler

close, getMonitorName, setAttribute

Methods inherited from class ecmwf.common.ecaccess.ECaccessScheduler

configurableRun, deactivateMonitor, getDelay, getJammedTimeout, getLastStepTime, getMonitorManager, getNextStep, getSchedulerState, getStartDate, getStepTime, isInitialized, isJammed, isOnHold, isRunning, onHold, setDelay, setJammedTimeout, setOnhold, setTimeRanges, start, wakeup

Methods inherited from class ecmwf.common.technical.WakeupThread

isSleeping, waitFor

Methods inherited from class ecmwf.common.technical.ThreadService.ConfigurableRunnable

execute, execute, getContextClassLoader, getPriority, getThreadName, interrupt, interrupted, isAlive, isStarted, join, join, run, setContextClassLoader, setForceCookie, setInheritCookie, setPriority, setThreadNameAndCookie

Methods inherited from class java.lang.Object

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

Method Details

getKey

public String getKey(DataTransfer transfer)

Gets the key.

Overrides:

getKey in class MBeanRepository<DataTransfer>

Parameters:

transfer - the transfer

Returns:

the key

getLastTransfer

public DataTransfer getLastTransfer()

Gets the last transfer.

Returns:

the last transfer

getNextTransfer

public DataTransfer getNextTransfer()

Gets the next transfer.

Returns:

the next transfer

getLastFailedTransfer

public DataTransfer getLastFailedTransfer()

Gets the last failed transfer.

Returns:

the last failed transfer

getStatus

public String getStatus(DataTransfer transfer)

Gets the status.

Overrides:

getStatus in class MBeanRepository<DataTransfer>

Parameters:

transfer - the transfer

Returns:

the status

shutdown

public void shutdown()

Shutdown.

Overrides:

shutdown in class MBeanScheduler

shutdown

public void shutdown(long timeout,
 boolean reset,
 String comment)

Shutdown.

Parameters:

timeout - the timeout

reset - the reset

comment - the comment

getActivity

public String getActivity()

Gets the activity.

Overrides:

getActivity in class ECaccessScheduler

Returns:

the activity

getDestinationStep

public int getDestinationStep()

Gets the destination step.

Returns:

the destination step

toBeReseted

public boolean toBeReseted()

Signal is should be reset.

Returns:

true, if successful

reset

public void reset()

Reset.

loadPendingDataTransfers

public void loadPendingDataTransfers()

Load pending data transfers.

initialize

public void initialize()

Initialize.

Overrides:

initialize in class ECaccessScheduler

nextStep

public int nextStep()

Next step.

Specified by:

nextStep in class ECaccessScheduler

Returns:

the int

getPerformed

public int getPerformed()

Gets the performed.

Returns:

the performed

getSelected

public int getSelected()

Gets the selected.

Returns:

the selected

getMBeanInfo

public MBeanInfo getMBeanInfo()

Gets the MBean info.

Specified by:

getMBeanInfo in interface MBeanService

Overrides:

getMBeanInfo in class MBeanRepository<DataTransfer>

Returns:

the MBean info

getAttribute

public Object getAttribute(String attributeName)
                    throws AttributeNotFoundException,
MBeanException

Gets the attribute.

Specified by:

getAttribute in interface MBeanService

Overrides:

getAttribute in class MBeanRepository<DataTransfer>

Parameters:

attributeName - the attribute name

Returns:

the attribute

Throws:

AttributeNotFoundException - the attribute not found exception

MBeanException - the MBean exception