aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/main/java/com/google/devtools/build/lib/remote/RemoteWorkExecutor.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/google/devtools/build/lib/remote/RemoteWorkExecutor.java')
-rw-r--r--src/main/java/com/google/devtools/build/lib/remote/RemoteWorkExecutor.java6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/main/java/com/google/devtools/build/lib/remote/RemoteWorkExecutor.java b/src/main/java/com/google/devtools/build/lib/remote/RemoteWorkExecutor.java
index 9cb080b402..3635ab7def 100644
--- a/src/main/java/com/google/devtools/build/lib/remote/RemoteWorkExecutor.java
+++ b/src/main/java/com/google/devtools/build/lib/remote/RemoteWorkExecutor.java
@@ -29,11 +29,11 @@ import java.util.concurrent.TimeUnit;
public class RemoteWorkExecutor {
/** Channel over which to send work to run remotely. */
private final ManagedChannel channel;
- private final int grpcTimeoutSeconds;
+ private final RemoteOptions options;
public RemoteWorkExecutor(RemoteOptions options) throws InvalidConfigurationException {
+ this.options = options;
channel = RemoteUtils.createChannel(options.remoteWorker);
- grpcTimeoutSeconds = options.grpcTimeoutSeconds;
}
public static boolean isRemoteExecutionOptions(RemoteOptions options) {
@@ -44,7 +44,7 @@ public class RemoteWorkExecutor {
ExecuteServiceBlockingStub stub =
ExecuteServiceGrpc.newBlockingStub(channel)
.withDeadlineAfter(
- grpcTimeoutSeconds + request.getTimeoutMillis() / 1000, TimeUnit.SECONDS);
+ options.grpcTimeoutSeconds + request.getTimeoutMillis() / 1000, TimeUnit.SECONDS);
Iterator<ExecuteReply> replies = stub.execute(request);
ExecuteReply reply = null;
while (replies.hasNext()) {