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.int
Gets the download threads count.Gets the MBean info.boolean
getPause()
Gets the pause.Gets the thread list.boolean
interruptAcquisitionFor
(Host host) Interrupt acquisition for.int
nextStep()
Next step.boolean
setAttribute
(String name, Object value) Sets the attribute.void
setPause
(boolean pause) Sets the pause.Methods inherited from class ecmwf.common.ecaccess.MBeanScheduler
close, getMonitorName, invoke, shutdown
Methods 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, 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
-
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:
getActivity
in classECaccessScheduler
- Returns:
- the activity
-
getThreadList
-
interruptAcquisitionFor
Interrupt acquisition for.- Parameters:
host
- the host- Returns:
- true, if successful
-
getMBeanInfo
Gets the MBean info.- Specified by:
getMBeanInfo
in interfaceMBeanService
- Overrides:
getMBeanInfo
in classMBeanScheduler
- Returns:
- the MBean info
-
getAttribute
Gets the attribute.- Specified by:
getAttribute
in interfaceMBeanService
- Overrides:
getAttribute
in 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:
setAttribute
in interfaceMBeanService
- Overrides:
setAttribute
in 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
-