From 24848e65a5aa2f9c7d6c04affc487699b8a122db Mon Sep 17 00:00:00 2001
From: Francis Dong <dxfeng10@gmail.com>
Date: Thu, 27 Jan 2022 10:08:37 +0800
Subject: [PATCH] change default timeout of aggregation to 10 seconds #399

---
 .../src/main/java/we/fizz/input/extension/dubbo/DubboInput.java | 2 +-
 .../src/main/java/we/fizz/input/extension/grpc/GrpcInput.java   | 2 +-
 .../main/java/we/fizz/input/extension/request/RequestInput.java | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/fizz-core/src/main/java/we/fizz/input/extension/dubbo/DubboInput.java b/fizz-core/src/main/java/we/fizz/input/extension/dubbo/DubboInput.java
index 93e2679..181e295 100644
--- a/fizz-core/src/main/java/we/fizz/input/extension/dubbo/DubboInput.java
+++ b/fizz-core/src/main/java/we/fizz/input/extension/dubbo/DubboInput.java
@@ -64,7 +64,7 @@ public class DubboInput extends RPCInput {
 	protected Mono<RPCResponse> getClientSpecFromContext(InputConfig aConfig, InputContext inputContext) {
 		DubboInputConfig config = (DubboInputConfig) aConfig;
 
-		int timeout = config.getTimeout() < 1 ? 3000 : config.getTimeout() > 10000 ? 10000 : config.getTimeout();
+		int timeout = config.getTimeout() < 1 ? 10000 : config.getTimeout() > 30000 ? 30000 : config.getTimeout();
 		long numRetries = config.getNumRetries() > 0 ? config.getNumRetries() : 0;
 		long retryInterval = config.getRetryInterval() > 0 ? config.getRetryInterval() : 0;
 		Map<String, String> attachments = (Map<String, String>) request.get("attachments");
diff --git a/fizz-core/src/main/java/we/fizz/input/extension/grpc/GrpcInput.java b/fizz-core/src/main/java/we/fizz/input/extension/grpc/GrpcInput.java
index d56b617..6569268 100644
--- a/fizz-core/src/main/java/we/fizz/input/extension/grpc/GrpcInput.java
+++ b/fizz-core/src/main/java/we/fizz/input/extension/grpc/GrpcInput.java
@@ -58,7 +58,7 @@ public class GrpcInput extends RPCInput implements IInput {
 	protected Mono<RPCResponse> getClientSpecFromContext(InputConfig aConfig, InputContext inputContext) {
 		GrpcInputConfig config = (GrpcInputConfig) aConfig;
 
-		int timeout = config.getTimeout() < 1 ? 3000 : config.getTimeout() > 10000 ? 10000 : config.getTimeout();
+		int timeout = config.getTimeout() < 1 ? 10000 : config.getTimeout() > 30000 ? 30000 : config.getTimeout();
 		long numRetries = config.getNumRetries() > 0 ? config.getNumRetries() : 0;
 		long retryInterval = config.getRetryInterval() > 0 ? config.getRetryInterval() : 0;
 		Map<String, String> attachments = (Map<String, String>) request.get("attachments");
diff --git a/fizz-core/src/main/java/we/fizz/input/extension/request/RequestInput.java b/fizz-core/src/main/java/we/fizz/input/extension/request/RequestInput.java
index 3ea9ecb..1964a5d 100644
--- a/fizz-core/src/main/java/we/fizz/input/extension/request/RequestInput.java
+++ b/fizz-core/src/main/java/we/fizz/input/extension/request/RequestInput.java
@@ -336,7 +336,7 @@ public class RequestInput extends RPCInput implements IInput{
 	protected Mono<RPCResponse> getClientSpecFromContext(InputConfig aConfig, InputContext inputContext) {
 		RequestInputConfig config = (RequestInputConfig) aConfig;
 		
-		int timeout = config.getTimeout() < 1 ? 3000 : config.getTimeout() > 10000 ? 10000 : config.getTimeout();
+		int timeout = config.getTimeout() < 1 ? 10000 : config.getTimeout() > 30000 ? 30000 : config.getTimeout();
 		long numRetries = config.getNumRetries() > 0 ? config.getNumRetries() : 0;
 		long retryInterval = config.getRetryInterval() > 0 ? config.getRetryInterval() : 0;