Class MasterServer.AcquisitionScheduler
java.lang.Object
ecmwf.common.technical.ThreadService.ConfigurableRunnable
ecmwf.common.technical.WakeupThread
ecmwf.common.ecaccess.ECaccessScheduler
ecmwf.common.ecaccess.MBeanScheduler
ecmwf.ecpds.master.MasterServer.AcquisitionScheduler
- All Implemented Interfaces:
MBeanService,MonitorCallback,Closeable,AutoCloseable,Runnable
- Enclosing class:
MasterServer
The Class AcquisitionScheduler.
-
Field Summary
FieldsFields 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 -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionGets the activity.getAttribute(String attributeName) Gets the attribute.intGets the download threads count.Gets the MBean info.booleangetPause()Gets the pause.Gets the thread list.booleaninterruptAcquisitionFor(Host host) Interrupt acquisition for.intnextStep()Next step.booleansetAttribute(String name, Object value) Sets the attribute.voidsetPause(boolean pause) Sets the pause.Methods inherited from class ecmwf.common.ecaccess.MBeanScheduler
close, getMonitorName, invoke, shutdownMethods inherited from class ecmwf.common.ecaccess.ECaccessScheduler
configurableRun, deactivateMonitor, getDelay, getJammedTimeout, getLastStepTime, getMonitorManager, getNextStep, getSchedulerState, getStartDate, getStepTime, initialize, isInitialized, isJammed, isOnHold, isRunning, onHold, setDelay, setJammedTimeout, setOnhold, setTimeRanges, start, wakeupMethods inherited from class ecmwf.common.technical.WakeupThread
isSleeping, waitForMethods 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
-
Field Details
-
_interruptSlow
public boolean _interruptSlowThe _interrupt slow.
-
-
Constructor Details
-
AcquisitionScheduler
Instantiates a new acquisition scheduler.- Parameters:
name- the name
-
-
Method Details
-
getDownloadThreadsCount
public int getDownloadThreadsCount()Gets the download threads count.- Returns:
- the download threads count
-
getActivity
Gets the activity.- Overrides:
getActivityin classECaccessScheduler- Returns:
- the activity
-
getThreadList
-
interruptAcquisitionFor
Interrupt acquisition for.- Parameters:
host- the host- Returns:
- true, if successful
-
getMBeanInfo
Gets the MBean info.- Specified by:
getMBeanInfoin interfaceMBeanService- Overrides:
getMBeanInfoin classMBeanScheduler- Returns:
- the MBean info
-
getAttribute
Gets the attribute.- Specified by:
getAttributein interfaceMBeanService- Overrides:
getAttributein classMBeanScheduler- Parameters:
attributeName- the attribute name- Returns:
- the attribute
- Throws:
AttributeNotFoundException- the attribute not found exceptionMBeanException- the MBean exception
-
setAttribute
public boolean setAttribute(String name, Object value) throws InvalidAttributeValueException, MBeanException Sets the attribute.- Specified by:
setAttributein interfaceMBeanService- Overrides:
setAttributein classMBeanScheduler- Parameters:
name- the namevalue- the value- Returns:
- true, if successful
- Throws:
InvalidAttributeValueException- the invalid attribute value exceptionMBeanException- the MBean exception
-
setPause
public void setPause(boolean pause) Sets the pause.- Parameters:
pause- the new pause
-
getPause
public boolean getPause()Gets the pause.- Returns:
- the pause
-
nextStep
-