public abstract class OSANode extends java.lang.Object implements OSARemoteAdminIfc
Modifier and Type | Field and Description |
---|---|
protected java.io.File |
backupDir |
protected Config |
config |
protected java.io.File |
configDir |
protected java.io.File |
configFile |
protected java.io.File |
inputDir |
protected java.io.File |
logDir |
protected Logger |
logger |
protected OSARFileMngr |
narRouter |
protected java.lang.String |
nodeid |
static java.lang.String |
NODEINIT |
static java.lang.String |
NODERECONFIG |
protected java.io.File |
outputDir |
protected long |
processingInterval |
protected java.io.File |
scratchDir |
protected boolean |
shutdown |
Constructor and Description |
---|
OSANode(java.lang.String[] args) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
checkInputDir() |
void |
clearStatus()
Clears the status table for this node
|
void |
clearStatus(StatusMessage sm) |
protected boolean |
deleteOSARs() |
ReadOnlyStatisticsMonitorIfc |
getAndResetRecordStatistics()
Retrieves record statistics for this node.
|
protected OSAR[] |
getOSARs() |
DCNodePerformanceIfc |
getPerformanceMetrics()
Returns
null |
StatusMessage |
getStatus()
Retrieves the most recent, worst status for this node
|
void |
initialize() |
boolean |
isReconfigPending() |
protected boolean |
isShutdown() |
void |
reconfig() |
void |
reconfigure()
Calls
OSARemoteAdminIfc.reconfig() |
void |
shutdown()
Stops node processing
|
protected void |
shuttingDown() |
void |
startup()
Call that starts a node.
|
protected boolean |
storeOSAR(OSAR osar) |
protected boolean |
storeOSARs(OSAR[] osars) |
protected Logger logger
protected Config config
protected OSARFileMngr narRouter
protected long processingInterval
protected java.io.File configFile
protected java.io.File configDir
protected java.io.File inputDir
protected java.io.File outputDir
protected java.io.File scratchDir
protected java.io.File backupDir
protected java.io.File logDir
protected java.lang.String nodeid
protected boolean shutdown
public static final java.lang.String NODEINIT
public static final java.lang.String NODERECONFIG
public OSANode(java.lang.String[] args) throws NodeStartException
NodeStartException
public void initialize()
initialize
in interface AdminIfc
protected boolean isShutdown()
protected OSAR[] getOSARs()
protected boolean deleteOSARs()
protected boolean storeOSAR(OSAR osar)
protected boolean storeOSARs(OSAR[] osars)
public void shutdown()
AdminIfc
shutdown
in interface AdminIfc
shutdown
in interface OSARemoteAdminIfc
protected void shuttingDown()
public void clearStatus(StatusMessage sm)
public void clearStatus()
AdminIfc
clearStatus
in interface AdminIfc
clearStatus
in interface OSARemoteAdminIfc
public StatusMessage getStatus()
AdminIfc
getStatus
in interface AdminIfc
getStatus
in interface OSARemoteAdminIfc
protected boolean checkInputDir()
public void reconfig()
reconfig
in interface OSARemoteAdminIfc
public boolean isReconfigPending()
isReconfigPending
in interface OSARemoteAdminIfc
public void reconfigure() throws NodeStartException
OSARemoteAdminIfc.reconfig()
reconfigure
in interface AdminIfc
NodeStartException
public void startup() throws NodeStartException
startup
in interface AdminIfc
NodeStartException
public DCNodePerformanceIfc getPerformanceMetrics()
null
getPerformanceMetrics
in interface AdminIfc
public ReadOnlyStatisticsMonitorIfc getAndResetRecordStatistics()
AdminIfc
getAndResetRecordStatistics
in interface AdminIfc