diff --git a/cluster/cluster_impl/failover_cluster_invoker.go b/cluster/cluster_impl/failover_cluster_invoker.go index 50519f5d3af5951d255ce8193dc9228cc8e6612a..23de1ee6377162810c0c2ed002d515801a4f8dec 100644 --- a/cluster/cluster_impl/failover_cluster_invoker.go +++ b/cluster/cluster_impl/failover_cluster_invoker.go @@ -40,7 +40,7 @@ func newFailoverClusterInvoker(directory cluster.Directory) protocol.Invoker { func (invoker *failoverClusterInvoker) Invoke(invocation protocol.Invocation) protocol.Result { - invokers, _ := invoker.directory.List(invocation) + invokers := invoker.directory.List(invocation) err := invoker.checkInvokers(invokers, invocation) if err != nil { @@ -70,7 +70,7 @@ func (invoker *failoverClusterInvoker) Invoke(invocation protocol.Invocation) pr if err != nil { return &protocol.RPCResult{Err: err} } - invokers, _ = invoker.directory.List(invocation) + invokers := invoker.directory.List(invocation) err = invoker.checkInvokers(invokers, invocation) if err != nil { return &protocol.RPCResult{Err: err} diff --git a/cluster/cluster_impl/registry_aware_cluster_invoker.go b/cluster/cluster_impl/registry_aware_cluster_invoker.go index 02891856877914ea16032e5ca0aef1103519915a..5785c02489f95168d5419f0087f38b07c851a4a3 100644 --- a/cluster/cluster_impl/registry_aware_cluster_invoker.go +++ b/cluster/cluster_impl/registry_aware_cluster_invoker.go @@ -34,7 +34,7 @@ func newRegistryAwareClusterInvoker(directory cluster.Directory) protocol.Invoke } func (invoker *registryAwareClusterInvoker) Invoke(invocation protocol.Invocation) protocol.Result { - invokers, _ := invoker.directory.List(invocation) + invokers := invoker.directory.List(invocation) //First, pick the invoker (XXXClusterInvoker) that comes from the local registry, distinguish by a 'default' key. for _, invoker := range invokers { if invoker.IsAvailable() && invoker.GetUrl().GetParam(constant.REGISTRY_DEFAULT_KEY, "false") == "true" { diff --git a/cluster/directory/static_directory_test.go b/cluster/directory/static_directory_test.go index 76beebc944145274f07f99b7151ca5655f23a1a5..89d0e24ee7c3b2829b9e61635f813e59792756f7 100644 --- a/cluster/directory/static_directory_test.go +++ b/cluster/directory/static_directory_test.go @@ -41,7 +41,7 @@ func Test_StaticDirList(t *testing.T) { } staticDir := NewStaticDirectory(invokers) - list, _ := staticDir.List(&invocation.RPCInvocation{}) + list := staticDir.List(&invocation.RPCInvocation{}) assert.Len(t, list, 10) }