Increase RPC timeout for list archived workflow API (#449)

Author: yycptt

.gitignore

@@ -9,4 +9,8 @@ target
 /out
 dummy
 $buildDir
-src/main/idls/*
+src/main/idls/*
+/bin
+.classpath
+.project
+.settings

src/main/java/com/uber/cadence/internal/sync/TestActivityEnvironmentInternal.java

@@ -726,7 +726,9 @@ public void ListWorkflowExecutions(
     @Override
     public void ListArchivedWorkflowExecutions(
         ListArchivedWorkflowExecutionsRequest listRequest, AsyncMethodCallback resultHandler)
-        throws TException {}
+        throws TException {
+      impl.ListArchivedWorkflowExecutions(listRequest, resultHandler);
+    }
 
     @Override
     public void ScanWorkflowExecutions(

src/main/java/com/uber/cadence/internal/sync/TestWorkflowEnvironmentInternal.java

@@ -578,7 +578,9 @@ public void ListWorkflowExecutions(
     @Override
     public void ListArchivedWorkflowExecutions(
         ListArchivedWorkflowExecutionsRequest listRequest, AsyncMethodCallback resultHandler)
-        throws TException {}
+        throws TException {
+      impl.ListArchivedWorkflowExecutions(listRequest, resultHandler);
+    }
 
     @Override
     public void ScanWorkflowExecutions(

src/main/java/com/uber/cadence/serviceclient/WorkflowServiceTChannel.java

@@ -128,7 +128,10 @@ public class WorkflowServiceTChannel implements IWorkflowService {
   private static final long DEFAULT_POLL_RPC_TIMEOUT_MILLIS = 121 * 1000;
 
   /** Default RPC timeout for QueryWorkflow */
-  private static final long DEFAULT_QUERY_RPC_TIMEOUT_MILLIS = 10000;
+  private static final long DEFAULT_QUERY_RPC_TIMEOUT_MILLIS = 10 * 1000;
+
+  /** Default RPC timeout for ListArchivedWorkflow */
+  private static final long DEFAULT_LIST_ARCHIVED_WORKFLOW_TIMEOUT_MILLIS = 180 * 1000;
 
   private static final String DEFAULT_CLIENT_APP_NAME = "cadence-client";
 
@@ -148,6 +151,9 @@ public static class ClientOptions {
     /** The tChannel timeout for query workflow call in milliseconds */
     private final long rpcQueryTimeoutMillis;
 
+    /** The tChannel timeout for list archived workflow call in milliseconds */
+    private final long rpcListArchivedWorkflowTimeoutMillis;
+
     /** TChannel service name that the Cadence service was started with. */
     private final String serviceName;
 
@@ -177,6 +183,7 @@ private ClientOptions(Builder builder) {
       }
       this.rpcLongPollTimeoutMillis = builder.rpcLongPollTimeoutMillis;
       this.rpcQueryTimeoutMillis = builder.rpcQueryTimeoutMillis;
+      this.rpcListArchivedWorkflowTimeoutMillis = builder.rpcListArchivedWorkflowTimeoutMillis;
       if (builder.metricsScope == null) {
         builder.metricsScope = NoopScope.getInstance();
       }
@@ -209,6 +216,11 @@ public long getRpcQueryTimeoutMillis() {
       return rpcQueryTimeoutMillis;
     }
 
+    /** @return Returns the rpc timout for list archived workflow requests in millis. */
+    public long getRpcListArchivedWorkflowTimeoutMillis() {
+      return rpcListArchivedWorkflowTimeoutMillis;
+    }
+
     /** Returns the client application name. */
     public String getClientAppName() {
       return this.clientAppName;
@@ -242,6 +254,8 @@ public static class Builder {
       private long rpcTimeoutMillis = DEFAULT_RPC_TIMEOUT_MILLIS;
       private long rpcLongPollTimeoutMillis = DEFAULT_POLL_RPC_TIMEOUT_MILLIS;
       public long rpcQueryTimeoutMillis = DEFAULT_QUERY_RPC_TIMEOUT_MILLIS;
+      public long rpcListArchivedWorkflowTimeoutMillis =
+          DEFAULT_LIST_ARCHIVED_WORKFLOW_TIMEOUT_MILLIS;
       public String serviceName;
       private Scope metricsScope;
       private Map<String, String> transportHeaders;
@@ -279,6 +293,16 @@ public Builder setQueryRpcTimeout(long timeoutMillis) {
         return this;
       }
 
+      /**
+       * Sets the rpc timeout value for query calls. Default is 180000.
+       *
+       * @param timeoutMillis timeout, in millis.
+       */
+      public Builder setListArchivedWorkflowRpcTimeout(long timeoutMillis) {
+        this.rpcListArchivedWorkflowTimeoutMillis = timeoutMillis;
+        return this;
+      }
+
       /**
        * Sets the client application name.
        *
@@ -1717,7 +1741,8 @@ private ListArchivedWorkflowExecutionsResponse listArchivedWorkflowExecutions(
       ThriftRequest<WorkflowService.ListArchivedWorkflowExecutions_args> request =
           buildThriftRequest(
               "ListArchivedWorkflowExecutions",
-              new WorkflowService.ListArchivedWorkflowExecutions_args(listRequest));
+              new WorkflowService.ListArchivedWorkflowExecutions_args(listRequest),
+              options.getRpcListArchivedWorkflowTimeoutMillis());
       response = doRemoteCall(request);
       WorkflowService.ListArchivedWorkflowExecutions_result result =
           response.getBody(WorkflowService.ListArchivedWorkflowExecutions_result.class);
@@ -2340,7 +2365,9 @@ public void ListWorkflowExecutions(
   @Override
   public void ListArchivedWorkflowExecutions(
       ListArchivedWorkflowExecutionsRequest listRequest, AsyncMethodCallback resultHandler)
-      throws TException {}
+      throws TException {
+    throw new UnsupportedOperationException("not implemented");
+  }
 
   @Override
   public void ScanWorkflowExecutions(