xan/awips2
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Issue #2627 harden static initialization on edex main thread

Browse source 
Change-Id: Icff0a2fd60bec882ac96fc218deb88b16eaeaaff

Former-commit-id: b989b7240c [formerly bb838950a2979703ae6ab8f486fc4460789c3f1b]
Former-commit-id: 660998ac72
This commit is contained in:
Nate Jensen 2014-03-04 17:19:24 -06:00
parent ddf96ad45b
commit 81a6675a14
1 changed files with 24 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

36
edexOsgi/com.raytheon.uf.edex.esb.camel/src/com/raytheon/uf/edex/esb/camel/ProcessUtil.java
View file

@ -51,6 +51,7 @@ import com.raytheon.uf.edex.core.props.PropertiesFactory;
* Feb 05, 2013 1580 mpduff EventBus refactor.
* Feb 12, 2013 1615 bgonzale Changed ProcessEvent pluginName to dataType.
* Jan 21, 2014 2627 njensen Added logFailedData() and logFailureAsInfo()
* Mar 04, 2014 2627 njensen Harden static initialization
*
* </pre>
*
@ -79,19 +80,30 @@ public class ProcessUtil {
protected static final boolean RETAIN_FAILED_DATA;
static {
// this will probably only ever be true on a testbed
RETAIN_FAILED_DATA = Boolean.getBoolean("retain.failed.data");
if (RETAIN_FAILED_DATA) {
FAILED_DIR = PropertiesFactory.getInstance().getEnvProperties()
.getEnvValue("DEFAULTDATADIR")
+ File.separator + "failed";
File file = new File(FAILED_DIR);
if (!file.exists()) {
file.mkdir();
boolean retain = false;
String dir = null;
try {
/*
* this will probably only ever be true on a testbed because sites
* typically keep multiple days of raw data
*/
retain = Boolean.getBoolean("retain.failed.data");
if (retain) {
dir = PropertiesFactory.getInstance().getEnvProperties()
.getEnvValue("DEFAULTDATADIR")
+ File.separator + "failed";
File file = new File(dir);
if (!file.exists()) {
file.mkdirs();
}
}
} else {
FAILED_DIR = null;
} catch (Throwable t) {
dir = null;
retain = false;
handler.error("Error validating retain.failed.data settings", t);
}
FAILED_DIR = dir;
RETAIN_FAILED_DATA = retain;
}
/**
@ -235,7 +247,7 @@ public class ProcessUtil {
String fullpath = getHeaderProperty(headers, ("ingestFileName"));
handler.error("Failed to ingest " + fullpath, e);
if (RETAIN_FAILED_DATA) {
if (RETAIN_FAILED_DATA && FAILED_DIR != null) {
File badfile = new File(fullpath);
if (badfile.exists()) {
String filename = badfile.getName();