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.

Methods inherited from class java.lang.Object

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

Constructor Details

MgmtRuntimeState

public MgmtRuntimeState(ConfigService configService)

Method Details

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