Thread.State, Thread.UncaughtExceptionHandlerMAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY| Constructor and Description |
|---|
ImportEW()
Sets up all the standard private member variables, the logger and
instantiates a ConfigFile using configFilename.
|
ImportEW(String fn) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
addTraceBufToQueue(gov.usgs.earthworm.message.TraceBuf tb) |
static void |
consoleInputManager(ImportEW im)
Manage the console input.
|
protected void |
fatalError(String msg)
Logs a severe message and exits uncleanly.
|
static com.martiansoftware.jsap.JSAPResult |
getArguments(String[] args)
Find and parse the command line arguments.
|
protected Options |
getOptions(gov.usgs.earthworm.message.TraceBuf tb) |
void |
handleOutOfMemoryError(OutOfMemoryError e)
Try to recover from an
OutOfMemoryError by dropping all
TraceBufs from the processing queue. |
static void |
main(String[] args) |
protected TraceBufFilter |
matchFilter(gov.usgs.earthworm.message.TraceBuf tb)
Tests the TraceBuf against each filter, stopping at first match.
|
void |
printChannels(String s) |
static void |
printKeys() |
void |
printStatus() |
protected void |
processConfigFile()
Processes logger, import and winston config, plus options, default
options and filters.
|
protected void |
processDefaultOptions() |
protected void |
processFilters() |
protected void |
processImportConfig()
Extracts generalised configuration information.
|
protected void |
processLoggerConfig()
Extracts logging configuration information.
|
protected void |
processOptions() |
protected void |
processWinstonConfig()
Extracts configuration information specific to Winston DB and
instantiates a Winston DB connection.
|
void |
quit() |
void |
run() |
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yieldpublic static final String DEFAULT_CONFIG_FILENAME
public static final String DEFAULT_HOST
public static final int DEFAULT_PORT
public static final int DEFAULT_TIMEOUT
public static final int DEFAULT_HEARTBEAT_INTERVAL
public static final int DEFAULT_EXPECTED_HEARTBEAT_INTERVAL
public static final int DEFAULT_STATUS_INTERVAL
public static final String DEFAULT_RECEIVE_ID
public static final String DEFAULT_SEND_ID
public static final String DEFAULT_DRIVER
public static final String DEFAULT_TABLE_ENGINE
public static final int DEFAULT_MAX_DAYS
public static final int DEFAULT_MAX_BACKLOG
public static final String DEFAULT_LOG_LEVEL
public static final String DEFAULT_LOG_FILE
public static final int DEFAULT_LOG_NUM_FILES
public static final int DEFAULT_LOG_FILE_SIZE
public static final boolean DEFAULT_ENABLE_VALARM_VIEW
public static final double DEFAULT_TIME_THRESHOLD
public static final int DEFAULT_BACKLOG_THRESHOLD
public static final boolean DEFAULT_RSAM_ENABLE
public static final int DEFAULT_RSAM_DELTA
public static final int DEFAULT_RSAM_DURATION
public static final int DEFAULT_DROP_TABLE_DELAY
public static final int DEFAULT_REPAIR_RETRY_INTERVAL
public static String JSAP_PROGRAM_NAME
public static String JSAP_EXPLANATION_PREFACE
protected String configFilename
protected gov.usgs.volcanoes.core.configfile.ConfigFile config
protected gov.usgs.earthworm.ImportGeneric importGeneric
protected String logFile
protected int logNumFiles
protected int logSize
protected final gov.usgs.volcanoes.core.CodeTimer inputTimer
protected int totalTraceBufsWritten
protected int totalTraceBufs
protected int totalTraceBufsDropped
protected int totalTraceBufsAccepted
protected int totalTraceBufsRejected
protected int totalTraceBufsFailed
protected final Map<String,ChannelStatus> channelStatus
protected final Date importStartTime
protected final DateFormat dateFormat
protected final DateFormat winstonDateFormat
protected int dropTableDelay
protected boolean enableValarmView
protected Options defaultOptions
protected List<TraceBufFilter> traceBufFilters
protected List<OptionsFilter> optionFilters
public ImportEW(String fn)
public ImportEW()
public void handleOutOfMemoryError(OutOfMemoryError e)
OutOfMemoryError by dropping all
TraceBufs from the processing queue. Ideally,
OutOfMemoryErrors should be prevented by aggressive tuning; this
is a last-gasp effort to allow the program to continue running.protected void fatalError(String msg)
protected void processConfigFile()
protected void processLoggerConfig()
protected void processImportConfig()
protected void processWinstonConfig()
protected void processDefaultOptions()
protected void processOptions()
protected void processFilters()
protected TraceBufFilter matchFilter(gov.usgs.earthworm.message.TraceBuf tb)
tb - the TraceBuf to testprotected void addTraceBufToQueue(gov.usgs.earthworm.message.TraceBuf tb)
protected Options getOptions(gov.usgs.earthworm.message.TraceBuf tb)
public void quit()
public void printStatus()
public void printChannels(String s)
public static com.martiansoftware.jsap.JSAPResult getArguments(String[] args)
args - The command line arguments.public static void printKeys()
public static void consoleInputManager(ImportEW im)
im - The Winston importer.public static void main(String[] args) throws IOException
IOExceptionCopyright © 2017. All rights reserved.