public class ArchiveManager extends DAVAppBase
DAVAppBase.DisconnectHandler
applicationLabel, applicationName, argList, logger
Constructor and Description |
---|
ArchiveManager(String[] args) |
Modifier and Type | Method and Description |
---|---|
static long |
archiveTime() |
private void |
cleanUp()
Beendet alle Tasks, meldet App vom DAV ab.
|
void |
connectToDavQuit() |
int |
decreaseArchiveQueryCountForApplication(SystemObject application) |
private boolean |
executeSpecialModeNoDAV() |
private boolean |
executeSpecialModeWithDAV() |
ArchivConfig |
getArchivConfig() |
int |
getArchiveQueryCountForApplication(SystemObject application) |
DataIdentTree |
getDataIdentTree() |
InQueuesMgr |
getInQueuesMgr() |
int |
getMaximumQueriesPerApplication() |
List<String> |
getOriginalCommandLineArguments() |
PersistenceManager |
getPersMgr() |
SimulationManager |
getSimulationMgr() |
TaskScheduler |
getTaskScheduler() |
int |
increaseArchiveQueryCountForApplication(SystemObject application) |
static void |
main(String[] args)
Startpunkt des Archivsystems.
|
private void |
parseArguments(ArgumentList argLst) |
void |
quit()
Faehrt das ArS herunter und beendet die VM.
|
void |
quitError(String msg)
Faehrt das ArS mit einer Fehlermeldung herunter und beendet die VM.
|
void |
quitErrorNoExit(String msg)
Faehrt das ArS mit einer Fehlermeldung herunter.
|
void |
quitNoExit()
Faehrt das ArS herunter ohne die VM zu beenden (dies ist bei Fernsteuerung des ArS aus JUnit-Tests notwendig).
|
protected void |
reconnectHandler()
Diese Methode wird nach erfolgreichem Reconnect zum DAV aufgerufen.
|
void |
run() |
static void |
setSystemTimeOffset(long offsetSeconds)
Verstellt die Systemzeit um offset Sekunden.
|
boolean |
wasTerminated() |
close, connectToDav, disconnectFromDav, getAsp, getAsp, getAtg, getAtg, getConfigAuth, getDataModel, getDavCon, getDD, getObj, getObj, setDisconnectHandler
private static long SYS_TIME_OFFSET
public static long DATAINDEX_OFFSET
public static boolean ONLY_DATA
private static final int DEFAULT_CMD_PORT
private static final String P_PRINT_PARAMS
private static final String P_PRINT_PARAMS_FILE
private static final String P_PERS_PATH
private static final String P_CHECK_PERS_DIR
private static final String P_REMOTE_CONTROL
private static final String P_BACKUP
private static final String P_MAX_QUERIES_PER_APPLICATION
private static final int DEFAULT_MAX_QUERIES_PER_APPLICATION
public static final String P_CHECK_PERS_DIR_DIR
public static final String P_CHECK_PERS_DIR_HDR
public static final String P_CHECK_PERS_DIR_ALL
public static final String P_REMOTE_CONTROL_NORC
public static final String P_REMOTE_CONTROL_DEFAULT
private PersistenceManager persistenceMgr
private DataIdentTree dataIdentTree
private InQueuesMgr inQueuesMgr
private ArchivConfig archivConfig
private TaskScheduler taskScheduler
private SimulationManager simulationMgr
private boolean printParamsAndExit
private File printParamsFile
private String checkPersDirMode
private String archivePath
private String backupProps
private int maximumQueriesPerApplication
private int cmdPortNum
private boolean terminated
private boolean runningProperly
private Object _terminatedLock
private final TreeMap<SystemObject,Integer> _applicationToArchiveQueryCount
public boolean wasTerminated()
public static long archiveTime()
public static void setSystemTimeOffset(long offsetSeconds)
offsetSeconds
- Spanne in Sekundenprivate void parseArguments(ArgumentList argLst) throws Exception
Exception
public void connectToDavQuit()
protected void reconnectHandler()
de.bsvrz.sys.funclib.losb.DAVAppBase
super.reconnectHandler()
aufgerufen werden, weil hier der ConnectionManager
zurueckgesetzt wird.reconnectHandler
in class DAVAppBase
private boolean executeSpecialModeNoDAV()
private boolean executeSpecialModeWithDAV()
private void cleanUp()
public void quit()
public void quitNoExit()
public void quitError(String msg)
public void quitErrorNoExit(String msg)
public static void main(String[] args)
args
- Kommandozeilenparameterpublic ArchivConfig getArchivConfig()
public DataIdentTree getDataIdentTree()
public InQueuesMgr getInQueuesMgr()
public PersistenceManager getPersMgr()
public TaskScheduler getTaskScheduler()
public SimulationManager getSimulationMgr()
public int getMaximumQueriesPerApplication()
public List<String> getOriginalCommandLineArguments()
public int increaseArchiveQueryCountForApplication(SystemObject application)
public int decreaseArchiveQueryCountForApplication(SystemObject application)
public int getArchiveQueryCountForApplication(SystemObject application)