aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/tools/remote_worker
diff options
context:
space:
mode:
authorGravatar Janak Ramakrishnan <janakr@google.com>2016-08-18 08:47:26 +0000
committerGravatar Philipp Wollermann <philwo@google.com>2016-08-18 17:25:08 +0000
commit452def0c6d0689e90e63ae3f4dab509718102fc5 (patch)
tree08f6b9924e6d95d51f5d1977e89a34c0ef513d5e /src/tools/remote_worker
parenteff2535cc02dcabef5d401ff1750fb85f34e5595 (diff)
Stop catching InterruptedException in remote execution.
If the user interrupts the build, they probably don't want local fallback to happen. Also clean up an unused method and parameter. -- Change-Id: I6bf80fa110bbba911b0743f24c25240c208c98d1 Reviewed-on: https://bazel-review.googlesource.com/5470 MOS_MIGRATED_REVID=130612791
Diffstat (limited to 'src/tools/remote_worker')
-rw-r--r--src/tools/remote_worker/src/main/java/com/google/devtools/build/remote/RemoteWorker.java8
1 files changed, 5 insertions, 3 deletions
diff --git a/src/tools/remote_worker/src/main/java/com/google/devtools/build/remote/RemoteWorker.java b/src/tools/remote_worker/src/main/java/com/google/devtools/build/remote/RemoteWorker.java
index 69d2716705..414737a810 100644
--- a/src/tools/remote_worker/src/main/java/com/google/devtools/build/remote/RemoteWorker.java
+++ b/src/tools/remote_worker/src/main/java/com/google/devtools/build/remote/RemoteWorker.java
@@ -69,8 +69,7 @@ public class RemoteWorker extends RemoteWorkImplBase {
Path tempRoot = workPath.getRelative("build-" + UUID.randomUUID().toString());
try {
FileSystemUtils.createDirectoryAndParents(tempRoot);
- final ConcurrentMapActionCache actionCache =
- new ConcurrentMapActionCache(tempRoot, remoteOptions, cache);
+ final ConcurrentMapActionCache actionCache = new ConcurrentMapActionCache(tempRoot, cache);
final MemcacheWorkExecutor workExecutor =
MemcacheWorkExecutor.createLocalWorkExecutor(actionCache, tempRoot);
if (LOG_FINER) {
@@ -96,10 +95,13 @@ public class RemoteWorker extends RemoteWorkImplBase {
} else {
LOG.warning("Preserving work directory " + tempRoot.toString() + ".");
}
- } catch (IOException e) {
+ } catch (IOException | InterruptedException e) {
RemoteWorkResponse.Builder response = RemoteWorkResponse.newBuilder();
response.setSuccess(false).setOut("").setErr("").setException(e.toString());
responseObserver.onNext(response.build());
+ if (e instanceof InterruptedException) {
+ Thread.currentThread().interrupt();
+ }
} finally {
responseObserver.onCompleted();
}