Class StorageLifecycleScheduler

java.lang.Object

ecmwf.common.technical.ThreadService.ConfigurableRunnable

ecmwf.common.technical.WakeupThread

ecmwf.common.ecaccess.ECaccessScheduler

ecmwf.common.ecaccess.MBeanScheduler

ecmwf.ecpds.master.storage.StorageLifecycleScheduler

All Implemented Interfaces:

MBeanService, MonitorCallback, Closeable, AutoCloseable, Runnable

public final class StorageLifecycleScheduler
extends MBeanScheduler

Only removes redundant copies. Normal expiry remains the sole owner of original-file removal.

Field Summary

Fields inherited from class 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

Constructor Summary

Constructors

Constructor	Description
StorageLifecycleScheduler(MasterServer master)

Method Summary

Modifier and Type	Method	Description
Map<String,String>	describe(long id)
boolean	enabled()
String	getActivity()	Gets the activity.
Object	getAttribute(String name)	Gets the attribute.
MBeanInfo	getMBeanInfo()	Gets the MBean info.
int	nextStep()	Next step.
void	pin(long id, long until, String reason, String user)
String	replicationSource(DataTransfer transfer, String preferred)
Map<String, Map<String,String>>	report()
List<TransferServer>	retrievalOrder(DataTransfer transfer, List<TransferServer> servers)
boolean	shouldReplicate(DataTransfer transfer)	Any eager/expiry-only policy, operator hold or unhealthy original defeats deferral.

Methods inherited from class MBeanScheduler

close, getMonitorName, invoke, setAttribute, shutdown

Methods inherited from class ECaccessScheduler

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

Methods inherited from class WakeupThread

isSleeping, waitFor

Methods inherited from class ThreadService.ConfigurableRunnable

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

Methods inherited from class Object

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

Constructor Details

StorageLifecycleScheduler

public StorageLifecycleScheduler(MasterServer master)

Method Details

enabled

public boolean enabled()

nextStep

public int nextStep()

Description copied from class: ECaccessScheduler

Next step.

Specified by:

nextStep in class ECaccessScheduler

Returns:

the int

shouldReplicate

public boolean shouldReplicate(DataTransfer transfer)

Any eager/expiry-only policy, operator hold or unhealthy original defeats deferral.

retrievalOrder

public List<TransferServer> retrievalOrder(DataTransfer transfer,
 List<TransferServer> servers)

replicationSource

public String replicationSource(DataTransfer transfer,
 String preferred)

describe

public Map<String,String> describe(long id)
                            throws Exception

Throws:

Exception

pin

public void pin(long id,
 long until,
 String reason,
 String user)
         throws Exception

Throws:

Exception

report

public Map<String, Map<String,String>> report()
                                       throws Exception

Throws:

Exception

getActivity

public String getActivity()

Description copied from class: ECaccessScheduler

Gets the activity.

Overrides:

getActivity in class ECaccessScheduler

Returns:

the activity

getMBeanInfo

public MBeanInfo getMBeanInfo()

Description copied from class: MBeanScheduler

Gets the MBean info. Gets the MBean info.

Specified by:

getMBeanInfo in interface MBeanService

Overrides:

getMBeanInfo in class MBeanScheduler

Returns:

the MBean info

getAttribute

public Object getAttribute(String name)
                    throws AttributeNotFoundException,
MBeanException

Description copied from class: MBeanScheduler

Gets the attribute. Gets the attribute.

Specified by:

getAttribute in interface MBeanService

Overrides:

getAttribute in class MBeanScheduler

Parameters:

name - the attribute name

Returns:

the attribute

Throws:

AttributeNotFoundException - the attribute not found exception

MBeanException - the MBean exception