debug log

cluster/directory/static_directory.go

@@ -18,6 +18,7 @@
 package directory
 
 import (
+	"fmt"
 	"github.com/apache/dubbo-go/common"
 	"github.com/apache/dubbo-go/common/constant"
 	"github.com/apache/dubbo-go/protocol"
@@ -57,6 +58,7 @@ func (dir *staticDirectory) IsAvailable() bool {
 func (dir *staticDirectory) List(invocation protocol.Invocation) []protocol.Invoker {
 	invokers := dir.invokers
 	localRouters := dir.routers
+	fmt.Println("========", len(localRouters))
 	if len(localRouters) > 0 {
 		for _, router := range localRouters {
 			if reflect.ValueOf(router.Url()).IsNil() || router.Url().GetParamBool(constant.RUNTIME_KEY, false) {

registry/directory/directory.go

@@ -18,6 +18,7 @@
 package directory
 
 import (
+	"fmt"
 	"reflect"
 	"strings"
 	"sync"
@@ -235,6 +236,7 @@ func (dir *registryDirectory) cacheInvoker(url common.URL) {
 func (dir *registryDirectory) List(invocation protocol.Invocation) []protocol.Invoker {
 	invokers := dir.cacheInvokers
 	localRouters := dir.Routers()
+	fmt.Println("========", len(localRouters))
 	if len(localRouters) > 0 {
 		for _, router := range localRouters {
 			if reflect.ValueOf(router.Url()).IsValid() || router.Url().GetParamBool(constant.RUNTIME_KEY, false) {