From d673e642bfd18cf831a57f5501abfdc10cba1292 Mon Sep 17 00:00:00 2001
From: xujianhai666 <zero.xu@bytedance.com>
Date: Sun, 18 Aug 2019 23:33:45 +0800
Subject: [PATCH] add error info
---
cluster/cluster_impl/forking_cluster_invoker.go | 6 +++++-
config/testdata/consumer_config.yml | 1 +
2 files changed, 6 insertions(+), 1 deletion(-)
diff --git a/cluster/cluster_impl/forking_cluster_invoker.go b/cluster/cluster_impl/forking_cluster_invoker.go
index c4a59a799..d6cf2f4b8 100644
--- a/cluster/cluster_impl/forking_cluster_invoker.go
+++ b/cluster/cluster_impl/forking_cluster_invoker.go
@@ -30,6 +30,7 @@ import (
import (
"github.com/apache/dubbo-go/cluster"
"github.com/apache/dubbo-go/common/constant"
+ "github.com/apache/dubbo-go/common/logger"
"github.com/apache/dubbo-go/protocol"
)
@@ -75,7 +76,10 @@ func (invoker *forkingClusterInvoker) Invoke(invocation protocol.Invocation) pro
for _, ivk := range selected {
go func(k protocol.Invoker) {
result := k.Invoke(invocation)
- resultQ.Put(result)
+ err := resultQ.Put(result)
+ if err != nil {
+ logger.Errorf("resultQ put failed with exception: %v.\n", err)
+ }
}(ivk)
}
diff --git a/config/testdata/consumer_config.yml b/config/testdata/consumer_config.yml
index 373871dcc..372873abb 100644
--- a/config/testdata/consumer_config.yml
+++ b/config/testdata/consumer_config.yml
@@ -47,6 +47,7 @@ references:
params:
"serviceid":
"soa.com.ikurento.user.UserProvider"
+ "forks": 5
protocol_conf:
dubbo:
--
GitLab