public abstract class DCNode extends java.lang.Object implements AdminIfc, ConfigIfc, LoggerIfc, NodeHealthIfc, PropertyIfc, NodeStateManagementIfc
Modifier and Type | Field and Description |
---|---|
protected java.io.File |
backupDir |
protected ConfigIfc |
config
An instance of a ConfigIfc class.
|
protected java.lang.String |
configClass |
protected java.io.File |
configDir |
protected java.io.File |
configFile |
protected java.lang.String |
configGUIClass |
protected java.util.ArrayList<DCStreamHandler> |
dcHandls |
static long |
DEFAULT_PROCESSING_INTERVAL |
protected DCStreamHandler |
fileMngr
The DCStreamHandler class manages all access to all streams/files that
are used to transfer data between nodes.
|
protected java.util.Timer |
generalMonitoringTimer |
protected boolean |
inputMonitoringAlarmRaised |
protected boolean |
inputMonitoringEnabled |
protected NARStreamHandler |
inputMonitoringNARFileMgr |
protected long |
inputMonitoringPollingInterval |
protected long |
inputMonitoringPreviousCount |
protected long |
inputMonitoringSilenceCounter |
protected long |
inputMonitoringSilenceInterval |
protected java.lang.String |
inputMonitoringSilenceIntervalText |
protected java.io.File |
logDir |
protected Logger |
logger
An instance of a LoggerIfc class that will be used to write data to the
log file.
|
protected java.lang.String |
majorType |
protected java.lang.String |
minorType |
protected DCNodePerformance |
node_pm |
protected java.lang.String |
nodeid |
static java.lang.String |
NODEINIT |
static java.lang.String |
NODERECONFIG |
protected long |
nodeStartTime
Time in millis that the node started
|
protected static java.lang.String |
nodeStateFileName |
protected long |
processingInterval
Time interval at which the node will check for data.
|
protected boolean |
reconfiguring
Indicates whether the node is being reconfigured
|
protected boolean |
savingStateOn |
protected java.io.File |
scratchDir |
protected boolean |
shutdown
Indicates whether the node is running
|
protected StateManager |
stateManager |
protected java.io.File |
suspenseDir |
static java.lang.String |
TRANSACTION_NAR_ID |
protected java.io.File |
udcHome |
FC_CONFIGURATION, FC_CONNECTIVITY, FC_INITIALIZATION, FC_INTERNALERROR, FC_INVALIDDATA, FC_NODE_CONTROL, FC_RESOURCES, FC_SECURITY, FC_SERVER_CONTROL, FC_UNDEFINED, SF_CONF_CHANGE_ERROR, SF_CONF_CONFIG_FAIL, SF_CONF_ERR_NODE_CONF, SF_CONF_INV_FTP_CONF, SF_CONF_INV_NODE_CONF, SF_CONF_INV_PARAM, SF_CONF_INV_PARAM_VAL, SF_CONF_INV_REM_DIR, SF_CONF_MISSING_PARM, SF_CONF_MISSING_PARM2, SF_CONF_NM_CONF_ERROR, SF_CONF_NO_CONFIG, SF_CONF_NO_FTP_INT, SF_CONF_NODE_CREATION, SF_CONF_NODE_START, SF_CONF_NPL_CRITICAL, SF_CONF_NPL_ERROR, SF_CONF_READ_ERROR, SF_CONF_READ_PROPS, SF_CONF_SAVE_ERROR, SF_CONF_SOCKET_INIT, SF_CONF_VER_VALIDATION, SF_CONN_DB_CON_ERR, SF_CONN_DB_CON_LOST, SF_CONN_DEGRADED_ERR, SF_CONN_ECE_CON_ERR, SF_CONN_ERR_NODEINFO, SF_CONN_ERR_RCV_DATA, SF_CONN_ERR_SEND_ACK, SF_CONN_ERROR_TACHYON_USAGE, SF_CONN_FAILED_TO_RECEIVE_RESPONSE, SF_CONN_FILE_READ_ERR, SF_CONN_FTP_ERROR, SF_CONN_FTP_ERROR2, SF_CONN_FTP_LOGIN, SF_CONN_INTERFACING_CON_ERR, SF_CONN_INVALID_TACHYON_RECORD, SF_CONN_LDAP_CONNECT, SF_CONN_LOST_NM, SF_CONN_NM_API_ERR, SF_CONN_PDU_NULL, SF_CONN_POLL_ERR, SF_CONN_SNMP_SESS_OPEN_FAIL, SF_DATA_AGGR_ERROR, SF_DATA_ATTR_CREATE, SF_DATA_ATTR_PARSE, SF_DATA_ATTR_SHIFT, SF_DATA_CANNOT_ENCODE, SF_DATA_CANT_ACK, SF_DATA_CANT_ENCODE, SF_DATA_CONV_STR_TO_N, SF_DATA_CONV_TO_STR, SF_DATA_CONVERT_ATTR, SF_DATA_DATA_EXPIRED, SF_DATA_DATA_MISSING, SF_DATA_DATA_PROC_ERR, SF_DATA_ENCODE_ERR, SF_DATA_ERR_CREATE, SF_DATA_ERR_SEND_ACK, SF_DATA_ERROR_IN_NPL, SF_DATA_ERROR_ON_ACK, SF_DATA_FILE_DATA, SF_DATA_FILE_PROC_ERR, SF_DATA_FORMAT_ERROR, SF_DATA_IE_INVALID, SF_DATA_IE_MISSING, SF_DATA_INPUT_INVALID, SF_DATA_INV_ATT_TYPE, SF_DATA_INV_ATTR_NPL, SF_DATA_INV_RECORD, SF_DATA_INV_TRAF_VOL, SF_DATA_JDBC_DRIVER_ERR, SF_DATA_KEY_CREATE, SF_DATA_MISSING_ATTRS, SF_DATA_MSG_TOO_SMALL, SF_DATA_MSG_TYPE, SF_DATA_NAR_IS_NULL, SF_DATA_NO_DATA_FILE, SF_DATA_NO_OPT_IE, SF_DATA_REC_INCOMP, SF_DATA_RECORD_PROC, SF_DATA_RECORD_SAVE, SF_DATA_SRC_READ_ERR, SF_DATA_UNABLE_COMPLETE, SF_DATA_UNEXP_NAR, SF_DATA_UNEXPECTED, SF_DATA_VAL_NOT_FOUND, SF_DATA_WRONG_DECODER, SF_INIT_DB_CON_ERR, SF_INIT_DIR_CON_ERR, SF_INIT_IO_ERR, SF_INIT_LDM, SF_INIT_LDM_RUN, SF_INIT_NODE_CONFIG, SF_INIT_NODE_CREATION, SF_INIT_NODE_INIT, SF_INIT_NODE_START, SF_INIT_RDM, SF_INIT_RDM_RUN, SF_INIT_REG_ERROR, SF_INIT_RULE_LOAD_ERR, SF_INIT_SOCKET_CREATE, SF_INIT_SOCKET_INIT, SF_INT_ERR_ETRACE, SF_INT_ERR_EXCEPTION, SF_INT_ERR_EXPIRE_ERR, SF_INT_ERR_FIELD_NULL, SF_INT_ERR_PROC_ERR, SF_INT_ERR_SHUTDOWN, SF_NC_ERR_IN_NODE, SF_NC_ERR_MNG_SERVER, SF_NC_ERR_NODE_STATE, SF_NC_ERR_PROC_DATA, SF_NC_ERR_RESTARTING, SF_NC_ERR_STARTING, SF_NC_ERR_STOPPING, SF_NC_ERR_UNHEALTHY, SF_NC_NODE_CONF_ERROR, SF_NC_NODE_SHUTDOWN, SF_RES_CPU_MAJOR, SF_RES_CPU_MINOR, SF_RES_CPU_USAGE_ERR, SF_RES_DISK_CRITICAL, SF_RES_DISK_MINOR, SF_RES_DISK_STATUS, SF_RES_DISK_USAGE, SF_RES_ERR_DATA_READ, SF_RES_ERR_DATA_REM, SF_RES_ERR_DB_CLOSE, SF_RES_ERR_DB_OP, SF_RES_ERR_DEL_ENTRY, SF_RES_ERR_DIR_CLOSE, SF_RES_ERR_DIR_CREATE, SF_RES_ERR_DIR_DELETE, SF_RES_ERR_DIR_OPEN, SF_RES_ERR_DIR_PROC, SF_RES_ERR_DIR_READ, SF_RES_ERR_DIR_WRITE, SF_RES_ERR_ENT_CREATE, SF_RES_ERR_FILE_CLOSE, SF_RES_ERR_FILE_CREAT, SF_RES_ERR_FILE_DEL, SF_RES_ERR_FILE_MOVE, SF_RES_ERR_FILE_NAME, SF_RES_ERR_FILE_OPEN, SF_RES_ERR_FILE_PROC, SF_RES_ERR_FILE_READ, SF_RES_ERR_FILE_REN, SF_RES_ERR_FILE_WRITE, SF_RES_ERR_IN_TRANS, SF_RES_ERR_INST_CLASS, SF_RES_ERR_INST_REC, SF_RES_ERR_IO_ERR, SF_RES_ERR_OPEN_TRANS, SF_RES_ERR_READ_DU, SF_RES_ERR_SOCK_CLOSE, SF_RES_ERR_SOCK_CREAT, SF_RES_ERR_SOCK_OPEN, SF_RES_ERR_SOCK_WRITE, SF_RES_ERR_TABLE_ACC, SF_RES_ERR_TABLE_CLOS, SF_RES_ERR_TABLE_OPEN, SF_RES_ERR_TIMER_SCHED, SF_RES_ERR_USING_Q, SF_RES_IS_NULL, SF_RES_MEM_MAJOR, SF_RES_MEM_WARNING, SF_RES_NO_LICENSE, SF_RES_NODE_STATE_R, SF_RES_NODE_STATE_W, SF_SEC_NO_USER_AUTH, SF_SEC_USER_AUTH_FAIL, SF_SEC_USER_CFG_FAIL, SF_SRV_CNTRL, SF_UND_INTERRUPTED, SF_UND_SHUTDOWN_ERR
ENVIRONMENT, RUNTIME
Constructor and Description |
---|
DCNode()
Default Constructor; instantiates objects necessary to define the
DCNodeTypeIfc methods.
|
DCNode(java.lang.String[] args) |
Modifier and Type | Method and Description |
---|---|
void |
addNodeEventListener(NodeEventListener nodeEventListener) |
void |
backup()
Empty implementation
|
void |
clearStatus()
Clears the status table for the node
|
void |
clearStatus(StatusMessage sm)
RMI method that clears the worst status currently in existence for the
node.
|
void |
clearStatus(java.lang.String faultCategory,
java.lang.String specificFault)
Clears all log messages with a given fault category, and specific fault
type.
|
void |
createCounters(java.lang.String nodeID)
Constructor for the class used to instantiate all objects needed by this
node.
|
ReadOnlyStatisticsMonitorIfc |
getAndResetRecordStatistics()
Retrieves record statistics for this node.
|
java.io.File |
getBackupDir()
Returns the node's backup directory.
|
ConfigIfc |
getConfig()
Returns the node's configuration Object.
|
java.lang.String |
getConfigDataClass() |
abstract java.lang.String |
getConfigDataGuiClass() |
java.io.File |
getConfigDir()
Returns the node's configuration directory.
|
java.io.File |
getConfigFile()
Returns the node's configuration file.
|
DCNodeTypeIfc |
getDCNodeType() |
DCStreamHandler |
getDCStreamHandler()
Returns the DCStreamHandler object that this node is using for inter-node
communication.
|
DCStreamHandler |
getDCStreamHandler(int i) |
DiscardedStatisticsMonitorIfc |
getDiscardedStatsProcessor() |
java.lang.String |
getDisplayString() |
DuplicateStatisticsMonitorIfc |
getDuplicateStatsProcessor() |
java.io.File |
getHomeDir()
Returns the node's home directory.
|
InputStatisticsMonitorIfc |
getInputStatsProcessor()
Get the input record Statistics Monitor.
|
java.lang.String |
getItem(java.lang.String key)
Retreives a configuration value for this node for the given key
|
java.io.File |
getLogDir()
Returns the node's log directory.
|
LoggerIfc |
getLogger()
Returns the node's logger.
|
abstract java.lang.String |
getMajorType() |
abstract java.lang.String |
getMinorType() |
java.lang.String |
getNodeClass() |
java.util.List |
getNodeEventListeners() |
java.lang.String |
getNodeId()
Returns Node's ID
|
StateManager |
getNodeStateManager()
Returns the Node's StateManager object.
|
OutputStatisticsMonitorIfc |
getOutputStatsProcessor()
Get the output record Statistics Monitor.
|
DCNodePerformanceIfc |
getPerformanceMetrics()
Returns the stream handler's node performance object
|
java.lang.String |
getProperty(java.lang.String type,
java.lang.String key)
Retrieves the property value for the specified type and key.
|
java.lang.String[] |
getPropertyKeys(java.lang.String type)
Retrieve a list of 'property keys' for the given type subset.
|
java.lang.String[] |
getPropertyTypes()
Retrieve a list of 'property type' subsets.
|
java.lang.String |
getRejectTransactionId() |
java.io.File |
getScratchDir()
Returns the node's scratch directory.
|
StateManagementType |
getStateManagementType()
Returns the type of state management this node is using.
|
StateManager |
getStateManager()
Returns the Node's StateManager object.
|
StatusMessage |
getStatus()
RMI call that returns the most recent worst status that currently exists
for the node.
|
StoredStatisticsMonitorIfc |
getStoredStatsProcessor() |
DCStreamHandler |
getStreamHandler()
Returns the node's stream handler.
|
DCStreamHandler |
getStreamHandler(int i) |
java.io.File |
getSuspenseDir()
Returns the node's suspense directory.
|
void |
initialize() |
void |
inputMonitoringCallback()
Default behaviour is to check the NARFileManager's input to see if
anything has changed, and either raise or clear the Silent Input alarm.
|
long |
inputMonitoringPollInputCounter() |
boolean |
isDebugEnabled() |
boolean |
isHealthy()
This method is part of the NodeHealthIfc interface.
|
boolean |
isInfoEnabled() |
boolean |
isNodeStateImplemented()
Returns whether the derived node can save and restore its state.
|
boolean |
isNodeStateUsed()
Returns whether the node state is used (and whether the node can be
recovered.)
|
boolean |
isReconfigPending()
RMI call that indicates if a reconfigure operation is pending in an DC
process.
|
protected boolean |
isReconfiguring()
Indicates whether the node is being reconfigured for warm restart.
|
boolean |
isRejectTransaction() |
protected boolean |
isShutdown()
Indicates whether the node is running, by returning the value of
shutdown |
boolean |
isStateUsed()
Returns whether the node state is used (and whether the node can be
recovered.)
|
void |
logCritical(java.lang.String faultCategory,
java.lang.String specificFault,
java.lang.String additionalFaultText,
java.lang.Exception exception)
Logs a Critical Error message (which is indicated with a red alarm) with
the given text.
|
void |
logDebug(java.lang.String message,
java.lang.Exception exception) |
void |
logError(java.lang.String message,
boolean autoClear,
java.lang.Exception exception)
Do NOT use this method for Release 3.3 or later.
|
void |
logInfo(java.lang.String message,
java.lang.Exception exception)
Logs an informational message (no alarm is generated)
|
void |
logMajor(java.lang.String faultCategory,
java.lang.String specificFault,
java.lang.String additionalFaultText,
java.lang.Exception exception)
Logs a Major Error message (which is indicated with a Orange alarm) with
the given text.
|
void |
logMinor(java.lang.String faultCategory,
java.lang.String specificFault,
java.lang.String additionalFaultText,
java.lang.Exception exception)
Logs a Minor Error message (which is indicated with a yellow alarm) with
the given text.
|
void |
logTrace(java.lang.String message,
java.lang.Exception exception)
Logs a trace message (no alarm is generated).
|
void |
logWarning(java.lang.String message,
boolean autoClear,
java.lang.Exception exception)
Do NOT use this method for Release 3.3 or later.
|
void |
logWarning(java.lang.String faultCategory,
java.lang.String specificFault,
java.lang.String additionalFaultText,
java.lang.Exception exception)
Logs a Warning message (which is indicated with a blue alarm) with the
given text.
|
void |
reconfigure()
Call that reconfigures a DC node process.
|
void |
registerThreadForHealthMonitoring(java.lang.Thread t)
This method is part of the NodeHealthIfc interface.
|
void |
rejectTransaction(java.lang.String transactionId) |
void |
restoreState()
Tells the Node to restore its state from disk.
|
void |
saveState()
Tells the Node to save its state to disk.
|
void |
saveState(Callback stateFinishedCallback)
Tells the Node to save its state to disk.
|
void |
setConfig(ConfigIfc c)
Sets the node's configuration Object.
|
void |
setDCStreamHandler(DCStreamHandler handler)
Sets the DCStreamHandler object that this node is using for inter-node
communication.
|
void |
setDCStreamHandler(DCStreamHandler handler,
int i) |
protected void |
setIsReconfiguringFlag(boolean value)
Set value of
reconfiguring flag to true or false. |
void |
setItem(java.lang.String key,
java.lang.String value)
Sets a configuration value for this node with the given key
|
void |
setProperty(java.lang.String type,
java.lang.String key,
java.lang.String value)
Set the property value for the specified type and key.
|
protected void |
setSNMPTrapGenerator(SnmpTrapSenderIfc stg)
This method allows the node to set it's SNMP Trap Generator, so that when
severe messages are sent to the logger they can be sent to SNMP Trap
Hosts that are listening.
|
void |
setStreamHandler(DCStreamHandler sh)
Sets the node's stream handler.
|
void |
setStreamHandler(DCStreamHandler sh,
int i) |
void |
shutdown()
Performs all necessary functions to stop this node and any processes that
it has created.
|
protected void |
shutdownDCStreamHandler()
Shutdown the DCStreamHandler.
|
protected void |
shuttingDown()
This method is should be overridden if a particular derived node needs to
do some processing just prior to the node being shut down.
|
void |
startup()
Call that starts a node.
|
void |
unregisterThreadFromHealthMonitoring(java.lang.Thread t)
This method is part of the NodeHealthIfc interface.
|
boolean |
warmRestartImplemented() |
public static final long DEFAULT_PROCESSING_INTERVAL
protected Logger logger
protected ConfigIfc config
protected DCStreamHandler fileMngr
protected java.util.ArrayList<DCStreamHandler> dcHandls
protected long processingInterval
protected java.io.File udcHome
protected java.io.File configFile
protected java.io.File configDir
protected java.io.File scratchDir
protected java.io.File backupDir
protected java.io.File logDir
protected java.io.File suspenseDir
protected java.lang.String nodeid
protected java.lang.String majorType
protected java.lang.String minorType
protected java.lang.String configClass
protected java.lang.String configGUIClass
protected boolean shutdown
protected long nodeStartTime
protected boolean reconfiguring
protected DCNodePerformance node_pm
public static final java.lang.String NODEINIT
public static final java.lang.String NODERECONFIG
protected boolean savingStateOn
protected StateManager stateManager
protected static java.lang.String nodeStateFileName
protected boolean inputMonitoringEnabled
protected long inputMonitoringSilenceInterval
protected java.util.Timer generalMonitoringTimer
protected boolean inputMonitoringAlarmRaised
protected long inputMonitoringPreviousCount
protected NARStreamHandler inputMonitoringNARFileMgr
protected long inputMonitoringPollingInterval
protected long inputMonitoringSilenceCounter
protected java.lang.String inputMonitoringSilenceIntervalText
public static final java.lang.String TRANSACTION_NAR_ID
public DCNode()
public DCNode(java.lang.String[] args) throws NodeStartException
NodeStartException
public void createCounters(java.lang.String nodeID)
udcHome
: args
- Values are as follows:
arg[0] Numeric identifier for this node.
arg[1] Directory location for the UDC
installation (udcHome).
All sub-directories created for
the node will reside below this
directory.
arg[2] Location of this node's
Configuration file
public void initialize() throws NodeStartException
initialize
in interface AdminIfc
NodeStartException
public void addNodeEventListener(NodeEventListener nodeEventListener)
public java.util.List getNodeEventListeners()
public DCNodeTypeIfc getDCNodeType()
public LoggerIfc getLogger()
public void setConfig(ConfigIfc c)
public ConfigIfc getConfig()
public void setStreamHandler(DCStreamHandler sh)
public void setStreamHandler(DCStreamHandler sh, int i)
public DCStreamHandler getStreamHandler()
public DCStreamHandler getStreamHandler(int i)
public java.io.File getHomeDir()
public java.io.File getConfigFile()
public java.io.File getConfigDir()
public java.io.File getScratchDir()
public java.io.File getBackupDir()
public java.io.File getSuspenseDir()
public java.io.File getLogDir()
public void backup()
public java.lang.String getNodeId()
null
public DCNodePerformanceIfc getPerformanceMetrics()
getPerformanceMetrics
in interface AdminIfc
public void shutdown()
public void clearStatus()
clearStatus
in interface AdminIfc
clearStatus
in interface LoggerIfc
public void clearStatus(StatusMessage sm)
public StatusMessage getStatus()
public void reconfigure() throws NodeStartException
reconfigure()
and then call this method from there. This
method sets a flag indicating this node is in the reconfiguration state.
The most derived class should use the setIsReconfiguringFlag
method just before returning from its reconfigure()
method
to set the reconfiguration state to false.reconfigure
in interface AdminIfc
NodeStartException
public void startup() throws NodeStartException
startup()
and then call
this method first from there.startup
in interface AdminIfc
NodeStartException
public boolean isReconfigPending()
false
public java.lang.String getItem(java.lang.String key)
public void setItem(java.lang.String key, java.lang.String value)
public java.lang.String getProperty(java.lang.String type, java.lang.String key)
getProperty
in interface PropertyIfc
type
- A String indicating the subset to which the property belongs
(i.e. environment, runtime, etc.)key
- A String indicating the specific property to be retrievednull
if the
property has not been setpublic java.lang.String[] getPropertyTypes()
getPropertyTypes
in interface PropertyIfc
public java.lang.String[] getPropertyKeys(java.lang.String type)
getPropertyKeys
in interface PropertyIfc
public void setProperty(java.lang.String type, java.lang.String key, java.lang.String value) throws java.lang.IllegalArgumentException
setProperty
in interface PropertyIfc
type
- A String indicating the subset the property to which the
property belongs (i.e. init, runtime, etc.)key
- A String indicating the specific property to be setvalue
- The value of the property to be set. A null
value
will cause the current property to be unset.java.lang.IllegalArgumentException
- if type or key is nullpublic void logError(java.lang.String message, boolean autoClear, java.lang.Exception exception)
LoggerIfc
logError
in interface LoggerIfc
autoClear
- if true
, this message will clear any previous
alarm in the system, otherwise a red alarm and an error
message will be logged.exception
- The exception which causes this alarm.message
- Desired text for the error message to be written into the log
file.LoggerIfc.logCritical(java.lang.String, java.lang.String, java.lang.String, java.lang.Exception)
,
LoggerIfc.logMajor(java.lang.String, java.lang.String, java.lang.String, java.lang.Exception)
public void logWarning(java.lang.String message, boolean autoClear, java.lang.Exception exception)
LoggerIfc
logWarning
in interface LoggerIfc
autoClear
- if true
, this message will clear any previous
alarm in the system, otherwise a yellow alarm and an warning
message will be logged.exception
- The exception which causes this alarm.message
- Desired text for the error message to be written into the log
file.LoggerIfc.logMinor(java.lang.String, java.lang.String, java.lang.String, java.lang.Exception)
,
LoggerIfc.logWarning(java.lang.String, java.lang.String, java.lang.String, java.lang.Exception)
public void logInfo(java.lang.String message, java.lang.Exception exception)
LoggerIfc
public boolean isDebugEnabled()
isDebugEnabled
in interface LoggerIfc
public boolean isInfoEnabled()
isInfoEnabled
in interface LoggerIfc
public void logDebug(java.lang.String message, java.lang.Exception exception)
public void logTrace(java.lang.String message, java.lang.Exception exception)
LoggerIfc
public void logCritical(java.lang.String faultCategory, java.lang.String specificFault, java.lang.String additionalFaultText, java.lang.Exception exception)
LoggerIfc
logCritical
in interface LoggerIfc
faultCategory
- A general category of the error. One of Initialization,
Configuration, Connectivity Invalid data, Resources, Internal
ErrorspecificFault
- A clearly worded description of this fault condition, with NO
variable component (i.e. node names, port numbers, time
stamps, etc.).additionalFaultText
- Any desirable additional text. The variable information.exception
- exception which causes this critical issue.public void logMajor(java.lang.String faultCategory, java.lang.String specificFault, java.lang.String additionalFaultText, java.lang.Exception exception)
LoggerIfc
logMajor
in interface LoggerIfc
faultCategory
- A general category of the error. One of Initialization,
Configuration, Connectivity Invalid data, Resources, Internal
ErrorspecificFault
- A clearly worded description of this fault condition, with NO
variable component (i.e. node names, port numbers, time
stamps, etc.).additionalFaultText
- Any desirable additional text. The variable information.exception
- Exception which causes this major issue.public void logMinor(java.lang.String faultCategory, java.lang.String specificFault, java.lang.String additionalFaultText, java.lang.Exception exception)
LoggerIfc
logMinor
in interface LoggerIfc
faultCategory
- A general category of the error. One of Initialization,
Configuration, Connectivity Invalid data, Resources, Internal
ErrorspecificFault
- A clearly worded description of this fault condition, with NO
variable component (i.e. node names, port numbers, time
stamps, etc.).additionalFaultText
- Any desirable additional text. The variable information.exception
- Exception which causes this minor issuepublic void logWarning(java.lang.String faultCategory, java.lang.String specificFault, java.lang.String additionalFaultText, java.lang.Exception exception)
LoggerIfc
logWarning
in interface LoggerIfc
faultCategory
- A general category of the error. One of Initialization,
Configuration, Connectivity Invalid data, Resources, Internal
ErrorspecificFault
- A clearly worded description of this fault condition, with NO
variable component (i.e. node names, port numbers, time
stamps, etc.).additionalFaultText
- Any desirable additional text. The variable information.exception
- Exception which causes this warningpublic void clearStatus(java.lang.String faultCategory, java.lang.String specificFault)
LoggerIfc
clearStatus
in interface LoggerIfc
public abstract java.lang.String getMajorType()
public abstract java.lang.String getMinorType()
public abstract java.lang.String getConfigDataGuiClass()
public java.lang.String getConfigDataClass()
com.nt.udc.ndk.gui.DCNodeConfigData
"public final java.lang.String getDisplayString()
getMajorType()
and
getMinorType()
separated by a colon.public final java.lang.String getNodeClass()
getClass().getName()
public boolean warmRestartImplemented()
public void setDCStreamHandler(DCStreamHandler handler)
handler
- DCStreamHandler that this node should usepublic void setDCStreamHandler(DCStreamHandler handler, int i)
public DCStreamHandler getDCStreamHandler()
public DCStreamHandler getDCStreamHandler(int i)
public void saveState(Callback stateFinishedCallback)
saveState
in interface StateManagementIfc
stateFinishedCallback
- An Object to notify when
the state has been successfully
saved.public void saveState()
saveState
in interface StateManagementIfc
public void restoreState()
restoreState
in interface StateManagementIfc
public boolean isNodeStateUsed()
isNodeStateUsed
in interface NodeStateManagementIfc
public boolean isStateUsed()
isStateUsed
in interface StateManagementIfc
public StateManagementType getStateManagementType()
getStateManagementType
in interface StateManagementIfc
public StateManager getNodeStateManager()
getNodeStateManager
in interface NodeStateManagementIfc
public StateManager getStateManager()
getStateManager
in interface StateManagementIfc
public boolean isNodeStateImplemented()
protected boolean isShutdown()
shutdown
protected void shuttingDown()
protected void setSNMPTrapGenerator(SnmpTrapSenderIfc stg)
stg
- The Snmp_Trap_APIInterface implementation that is
being used to send SNMP traps.
protected boolean isReconfiguring()
protected void setIsReconfiguringFlag(boolean value)
reconfiguring
flag to true or false. This
method is provided to allow derived classes to have control over when the
node is in the state of being reconfigured.protected void shutdownDCStreamHandler()
public boolean isHealthy()
isHealthy
in interface NodeHealthIfc
public void registerThreadForHealthMonitoring(java.lang.Thread t)
registerThreadForHealthMonitoring
in interface NodeHealthIfc
public void unregisterThreadFromHealthMonitoring(java.lang.Thread t)
unregisterThreadFromHealthMonitoring
in interface NodeHealthIfc
public void inputMonitoringCallback()
public long inputMonitoringPollInputCounter()
public InputStatisticsMonitorIfc getInputStatsProcessor()
public OutputStatisticsMonitorIfc getOutputStatsProcessor()
public StoredStatisticsMonitorIfc getStoredStatsProcessor()
public DuplicateStatisticsMonitorIfc getDuplicateStatsProcessor()
public DiscardedStatisticsMonitorIfc getDiscardedStatsProcessor()
public ReadOnlyStatisticsMonitorIfc getAndResetRecordStatistics()
AdminIfc
getAndResetRecordStatistics
in interface AdminIfc
public void rejectTransaction(java.lang.String transactionId)
public boolean isRejectTransaction()
public java.lang.String getRejectTransactionId()