Skip to content

Commit

Permalink
Temporary files for processes are now stored in WorkSpace rather than…
Browse files Browse the repository at this point in the history
… tmpdir.

* also removed auto-generated licence header
  • Loading branch information
jiwalker-usgs committed Feb 21, 2014
1 parent ddea73d commit 508e8f7
Show file tree
Hide file tree
Showing 9 changed files with 19 additions and 15 deletions.
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package gov.usgs.cida.gdp.wps.algorithm;

import gov.usgs.cida.gdp.constants.AppConstant;
import gov.usgs.cida.gdp.coreprocessing.Delimiter;
import gov.usgs.cida.gdp.coreprocessing.analysis.grid.FeatureCategoricalGridCoverage;
import gov.usgs.cida.gdp.wps.binding.CSVFileBinding;
Expand Down Expand Up @@ -110,7 +111,7 @@ public void process() {

try {

output = File.createTempFile(getClass().getSimpleName(), delimiter.extension);
output = File.createTempFile(getClass().getSimpleName(), delimiter.extension, new File(AppConstant.WORK_LOCATION.getValue()));
writer = new BufferedWriter(new FileWriter(output));

for (String currentDatasetId : datasetId) {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package gov.usgs.cida.gdp.wps.algorithm;

import gov.usgs.cida.gdp.constants.AppConstant;
import gov.usgs.cida.gdp.wps.binding.GMLStreamingFeatureCollectionBinding;
import gov.usgs.cida.gdp.wps.binding.NetCDFFileBinding;
import java.io.File;
Expand Down Expand Up @@ -104,7 +105,7 @@ public void process() {
GridDataset gridDataSet = null;
try {
gridDataSet = GDPAlgorithmUtil.generateGridDataSet(datasetURI);
output = File.createTempFile(getClass().getSimpleName(), ".nc");
output = File.createTempFile(getClass().getSimpleName(), ".nc", new File(AppConstant.WORK_LOCATION.getValue()));
NetCDFGridWriter.makeFile(
output.getAbsolutePath(),
gridDataSet,
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package gov.usgs.cida.gdp.wps.algorithm;

import gov.usgs.cida.gdp.constants.AppConstant;
import gov.usgs.cida.gdp.coreprocessing.Delimiter;
import gov.usgs.cida.gdp.coreprocessing.analysis.grid.FeatureCoverageGridStatistics;
import gov.usgs.cida.gdp.coreprocessing.analysis.grid.Statistics1DWriter.GroupBy;
Expand Down Expand Up @@ -182,7 +183,7 @@ public void process() {
return;
}

output = File.createTempFile(getClass().getSimpleName(), delimiter.extension);
output = File.createTempFile(getClass().getSimpleName(), delimiter.extension, new File(AppConstant.WORK_LOCATION.getValue()));
writer = new BufferedWriter(new FileWriter(output));

for (String currentDatasetId : datasetId) {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package gov.usgs.cida.gdp.wps.algorithm;

import gov.usgs.cida.gdp.constants.AppConstant;
import gov.usgs.cida.gdp.coreprocessing.Delimiter;
import gov.usgs.cida.gdp.coreprocessing.analysis.grid.FeatureCoverageWeightedGridStatistics;
import gov.usgs.cida.gdp.coreprocessing.analysis.grid.Statistics1DWriter.GroupBy;
Expand Down Expand Up @@ -181,7 +182,7 @@ public void process() {
addError("Attribute " + featureAttributeName + " not found in feature collection");
return;
}
output = File.createTempFile(getClass().getSimpleName(), delimiter.extension);
output = File.createTempFile(getClass().getSimpleName(), delimiter.extension, new File(AppConstant.WORK_LOCATION.getValue()));
writer = new BufferedWriter(new FileWriter(output));

for (String currentDatasetId : datasetId) {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,7 +1,3 @@
/*
* To change this template, choose Tools | Templates
* and open the template in the editor.
*/
package gov.usgs.cida.gdp.wps.algorithm;

/**
Expand Down
Original file line number Diff line number Diff line change
@@ -1,6 +1,7 @@
package gov.usgs.cida.gdp.wps.algorithm;

import com.google.common.base.Joiner;
import gov.usgs.cida.gdp.constants.AppConstant;
import gov.usgs.cida.gdp.coreprocessing.Delimiter;
import gov.usgs.cida.gdp.coreprocessing.analysis.grid.FeatureCoverageWeightedGridStatistics;
import gov.usgs.cida.gdp.coreprocessing.analysis.grid.Statistics1DWriter.GroupBy;
Expand Down Expand Up @@ -244,8 +245,8 @@ public void process() {
addError("Attribute " + featureAttributeName + " is not Numeric type, unable to properly index HRU");
}

prmsParamFile = File.createTempFile(getClass().getSimpleName(), ".param");
prmsDataFile = File.createTempFile(getClass().getSimpleName(), ".data");
prmsParamFile = File.createTempFile(getClass().getSimpleName(), ".param", new File(AppConstant.WORK_LOCATION.getValue()));
prmsDataFile = File.createTempFile(getClass().getSimpleName(), ".data", new File(AppConstant.WORK_LOCATION.getValue()));

prmsParamWriter = new BufferedWriter(new FileWriter(prmsParamFile));
prmsDataWriter = new BufferedWriter(new FileWriter(prmsDataFile));
Expand All @@ -267,7 +268,7 @@ public void process() {
timeEnd);

// TODO: all I/O instances need try/finally cleanup
csvFileList.add(File.createTempFile(getClass().getSimpleName(), ".temp.csv"));
csvFileList.add(File.createTempFile(getClass().getSimpleName(), ".temp.csv", new File(AppConstant.WORK_LOCATION.getValue())));
BufferedWriter csvWriter = null;
try {
csvWriter = new BufferedWriter(new FileWriter(csvFileList.get(inputIndex)));
Expand Down Expand Up @@ -320,7 +321,7 @@ public void process() {
FileInputStream prmsParamsInputStream = null;
FileInputStream prmsDataInputStream = null;
try {
output = File.createTempFile(getClass().getName(), ".zip");
output = File.createTempFile(getClass().getName(), ".zip", new File(AppConstant.WORK_LOCATION.getValue()));
zipOutputStream = new ZipOutputStream(
new FileOutputStream(output));
prmsParamsInputStream = new FileInputStream(prmsParamFile);
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package gov.usgs.cida.gdp.wps.parser;

import gov.usgs.cida.gdp.constants.AppConstant;
import gov.usgs.cida.gdp.wps.binding.GMLStreamingFeatureCollectionBinding;
import java.io.File;
import java.io.IOException;
Expand All @@ -16,7 +17,7 @@ public GMLStreamingParser() {
@Override
public GMLStreamingFeatureCollectionBinding parse(InputStream input, String mimeType, String schema) {
try {
File tempFile = File.createTempFile(getClass().getSimpleName(), ".xml");
File tempFile = File.createTempFile(getClass().getSimpleName(), ".xml", new File(AppConstant.WORK_LOCATION.getValue()));
FileUtils.copyInputStreamToFile(input, tempFile);
return new GMLStreamingFeatureCollectionBinding(new GMLStreamingFeatureCollection(tempFile));
} catch (IOException e) {
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package gov.usgs.cida.gdp.wps.parser;

import gov.usgs.cida.gdp.constants.AppConstant;
import gov.usgs.cida.gdp.wps.binding.GeoTIFFFileBinding;
import gov.usgs.cida.gdp.wps.util.GeoTIFFUtil;
import gov.usgs.cida.gdp.wps.util.MIMEMultipartStream;
Expand Down Expand Up @@ -35,7 +36,7 @@ public GeoTIFFFileBinding parse(InputStream inputStream, String mimeType, String

try {

tempFile = File.createTempFile(getClass().getSimpleName(), ".tmp");
tempFile = File.createTempFile(getClass().getSimpleName(), ".tmp", new File(AppConstant.WORK_LOCATION.getValue()));
FileUtils.copyInputStreamToFile(inputStream, tempFile);

ByteBuffer buffer = ByteBuffer.allocate(4 + MIMEMultipartStream.MAX_BOUNDARY_LENGTH);
Expand Down
Original file line number Diff line number Diff line change
@@ -1,5 +1,6 @@
package gov.usgs.cida.gdp.wps.util;

import gov.usgs.cida.gdp.constants.AppConstant;
import gov.usgs.cida.gdp.dataaccess.CoverageMetaData;
import java.io.BufferedOutputStream;
import java.io.File;
Expand Down Expand Up @@ -309,7 +310,7 @@ public static File generateTIFFFile(URI wcsURI, String wcsIdentifier, Referenced
if (GeoTIFFUtil.isAllowedMimeType(contentType)) {
String contentTransferEncoding = headerMap.get("Content-Transfer-Encoding");
if (contentTransferEncoding != null) {
tiffFile = File.createTempFile("gdp", ".tiff");
tiffFile = File.createTempFile("gdp", ".tiff", new File(AppConstant.WORK_LOCATION.getValue()));
OutputStream tiffOutputStream = new BufferedOutputStream(new FileOutputStream(tiffFile));
mimeMultipartStream.readBodyData(tiffOutputStream, contentTransferEncoding);
tiffOutputStream.close();
Expand Down

0 comments on commit 508e8f7

Please sign in to comment.