Skip to content
Snippets Groups Projects
Commit 627cc3ba authored by Clayton, Brandon Scott's avatar Clayton, Brandon Scott
Browse files

test

parent b963f119
No related branches found
No related tags found
1 merge request!806AWS Lambda
package gov.usgs.earthquake.nshmp.www; package gov.usgs.earthquake.nshmp.www;
import java.net.URI;
import java.net.URL;
import java.nio.file.FileSystem;
import java.nio.file.FileSystemNotFoundException;
import java.nio.file.FileSystems;
import java.nio.file.Path; import java.nio.file.Path;
import java.nio.file.Paths;
import java.util.HashMap;
import java.util.Optional; import java.util.Optional;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import java.util.logging.Logger; import java.util.logging.Logger;
...@@ -51,10 +44,10 @@ public class PrimingResource implements OrderedResource { ...@@ -51,10 +44,10 @@ public class PrimingResource implements OrderedResource {
// log.info("Test location"); // log.info("Test location");
// if (location.isPresent()) { // if (location.isPresent()) {
// log.info("Location: " + location.get()); // log.info("Location: " + location.get());
// handler.handleRequest( // handler.handleRequest(
// getAwsProxyRequest(contextPath + "/hazard" + location.get()), // getAwsProxyRequest(contextPath + "/hazard" + location.get()),
// new MockLambdaContext()); // new MockLambdaContext());
// } // }
// handler.handleRequest( // handler.handleRequest(
...@@ -83,7 +76,8 @@ public class PrimingResource implements OrderedResource { ...@@ -83,7 +76,8 @@ public class PrimingResource implements OrderedResource {
public void afterRestore(Context<? extends Resource> context) throws Exception { public void afterRestore(Context<? extends Resource> context) throws Exception {
ServletUtil.CALC_EXECUTOR.shutdown(); ServletUtil.CALC_EXECUTOR.shutdown();
ServletUtil.TASK_EXECUTOR.shutdown(); ServletUtil.TASK_EXECUTOR.shutdown();
ServletUtil.CALC_EXECUTOR = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(ServletUtil.THREAD_COUNT)); ServletUtil.CALC_EXECUTOR =
MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(ServletUtil.THREAD_COUNT));
ServletUtil.TASK_EXECUTOR = Executors.newSingleThreadExecutor(); ServletUtil.TASK_EXECUTOR = Executors.newSingleThreadExecutor();
} }
......
...@@ -16,7 +16,6 @@ import java.util.concurrent.ExecutorService; ...@@ -16,7 +16,6 @@ import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors; import java.util.concurrent.Executors;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.google.common.base.Stopwatch; import com.google.common.base.Stopwatch;
import com.google.common.util.concurrent.ListeningExecutorService; import com.google.common.util.concurrent.ListeningExecutorService;
...@@ -63,7 +62,8 @@ public class ServletUtil { ...@@ -63,7 +62,8 @@ public class ServletUtil {
private static HazardModel HAZARD_MODEL; private static HazardModel HAZARD_MODEL;
private static Optional<String> awsRuntime = Optional.ofNullable(System.getenv("AWS_LAMBDA_RUNTIME_API")); private static Optional<String> awsRuntime =
Optional.ofNullable(System.getenv("AWS_LAMBDA_RUNTIME_API"));
static { static {
THREAD_COUNT = getRuntime().availableProcessors(); THREAD_COUNT = getRuntime().availableProcessors();
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment