Package org.epics.archiverappliance.mgmt
Class MgmtRuntimeState
- java.lang.Object
-
- org.epics.archiverappliance.mgmt.MgmtRuntimeState
-
public class MgmtRuntimeState extends Object
Runtime state for the mgmt app.- Author:
- mshankar
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
MgmtRuntimeState.NeverConnectedRequestState
-
Constructor Summary
Constructors Constructor Description MgmtRuntimeState(ConfigService configService)
-
Method Summary
Modifier and Type Method Description void
abortAllAndRestartArchiveRequestsThread()
Abort all pending PV requests and then restart the thread.boolean
abortPVWorkflow(String pvName)
void
componentStartedUp(ConfigService.WAR_FILE component)
void
computeMetaInfo(PubSubEvent pubSubEvent)
void
finishedPVWorkflow(String pvName)
int
getArchivePVWorkflowBatchSize()
Get the batch size for PV archive requests workflow.List<MgmtRuntimeState.NeverConnectedRequestState>
getNeverConnectedRequests()
int
getPVsPendingInWorkflow()
boolean
haveChildComponentsStartedUp()
boolean
isPVInWorkflow(String pvName)
Is the specified PV in the mgmt workflow?void
startPVWorkflow(String pvName)
Initiate archive PV workflow for PV.
-
-
-
Constructor Detail
-
MgmtRuntimeState
public MgmtRuntimeState(ConfigService configService)
-
-
Method Detail
-
startPVWorkflow
public void startPVWorkflow(String pvName) throws IOException
Initiate archive PV workflow for PV.- Parameters:
pvName
- The name of PV.- Throws:
IOException
-
-
abortPVWorkflow
public boolean abortPVWorkflow(String pvName) throws IOException
- Throws:
IOException
-
finishedPVWorkflow
public void finishedPVWorkflow(String pvName) throws IOException
- Throws:
IOException
-
getNeverConnectedRequests
public List<MgmtRuntimeState.NeverConnectedRequestState> getNeverConnectedRequests()
-
getPVsPendingInWorkflow
public int getPVsPendingInWorkflow()
-
computeMetaInfo
public void computeMetaInfo(PubSubEvent pubSubEvent)
-
componentStartedUp
public void componentStartedUp(ConfigService.WAR_FILE component)
-
abortAllAndRestartArchiveRequestsThread
public void abortAllAndRestartArchiveRequestsThread() throws IOException
Abort all pending PV requests and then restart the thread. Use only if your main archive thread seems to be stuck.- Throws:
IOException
-
haveChildComponentsStartedUp
public boolean haveChildComponentsStartedUp()
-
isPVInWorkflow
public boolean isPVInWorkflow(String pvName)
Is the specified PV in the mgmt workflow?- Parameters:
pvName
- The name of PV.- Returns:
- boolean True or False
-
getArchivePVWorkflowBatchSize
public int getArchivePVWorkflowBatchSize()
Get the batch size for PV archive requests workflow. We throttle the archive PV workflow to this many PV's at a time to conserve resources and prevent CA storms. This can be configured using a property in archappl.properties.- Returns:
- archivePVWorkflowBatchSize
-
-