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

VLab Issue #4953 Run NWRWAVES script for both TCV and HLS.

Browse source 
Don't attempt to send TCV backup files in practice mode.

Change-Id: I70cc4a4014a0f1e34d8c2d3eab39a76289ca9daa

Former-commit-id: a1a11a4243 [formerly 57de590a3e] [formerly a1a11a4243 [formerly 57de590a3e] [formerly cd8f684a99 [formerly 3a60037251b7dd393d85a613c5685d5338927e61]]]
Former-commit-id: cd8f684a99
Former-commit-id: 9ee76233b9 [formerly 8565219ce8]
Former-commit-id: 7a30a7c73e
This commit is contained in:
Ron Anderson 2015-01-09 10:48:51 -06:00
parent 2851636c0c
commit e2d2cef4ee
1 changed files with 38 additions and 35 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

73
edexOsgi/com.raytheon.edex.plugin.gfe/src/com/raytheon/edex/plugin/gfe/watch/TPCWatchSrv.java
View file

@ -192,48 +192,47 @@ public final class TPCWatchSrv extends AbstractWatchNotifierSrv {
// if it's a TCV
if ("TCV".equals(pil)) {
super.handleWatch(warningRecs);
}
// if we are not in practice mode
if (!practiceMode) {
// if we are not in practice mode
if (!practiceMode) {
// if xxxId ends with a digit (i.e. its a national TCV)
String xxxId = record.getXxxid();
if (Character.isDigit(xxxId.charAt(xxxId.length() - 1))) {
// if xxxId ends with a digit (i.e. its a national TCV)
String xxxId = record.getXxxid();
if (Character.isDigit(xxxId.charAt(xxxId.length() - 1))) {
// build the full 9-letter PIL
String fullPil = SiteMap.getInstance().mapICAOToCCC(
issuingOffice)
+ pil + xxxId;
// build the full 9-letter PIL
String fullPil = SiteMap.getInstance().mapICAOToCCC(
issuingOffice)
+ pil + xxxId;
// build the command line for the NWRWAVES script
final String command = NWRWAVES_SCRIPT + fullPil;
// build the command line for the NWRWAVES script
final String command = NWRWAVES_SCRIPT + fullPil;
// Create a separate thread to run the script
Thread thread = new Thread(new Runnable() {
// Create a separate thread to run the script
Thread thread = new Thread(new Runnable() {
@Override
public void run() {
RunProcess proc;
try {
proc = RunProcess.getRunProcess().exec(command);
} catch (IOException e) {
statusHandler.error("Error executing "
+ command, e);
return;
}
int exitCode = proc.waitFor();
if (exitCode != 0) {
statusHandler
.error(command
+ " terminated abnormally with exit code: "
+ exitCode);
}
@Override
public void run() {
RunProcess proc;
try {
proc = RunProcess.getRunProcess().exec(command);
} catch (IOException e) {
statusHandler
.error("Error executing " + command, e);
return;
}
});
thread.start();
}
int exitCode = proc.waitFor();
if (exitCode != 0) {
statusHandler.error(command
+ " terminated abnormally with exit code: "
+ exitCode);
}
}
});
thread.start();
}
}
@ -296,7 +295,11 @@ public final class TPCWatchSrv extends AbstractWatchNotifierSrv {
statusHandler.error("Unable to delete " + pendingFile, e);
}
sendTCVFiles(siteId);
// if not practice mode
if (!practiceMode) {
// send TCV files to VTEC partner sites
sendTCVFiles(siteId);
}
}
}