Skip to content
Snippets Groups Projects
Commit ec066c38 authored by 邹毅贤's avatar 邹毅贤
Browse files

fix problems

parent e843e1f0
No related branches found
No related tags found
No related merge requests found
......@@ -31,11 +31,8 @@ import (
"github.com/apache/dubbo-go/common"
"github.com/apache/dubbo-go/common/constant"
"github.com/apache/dubbo-go/common/extension"
gxset "github.com/dubbogo/gost/container/set"
)
var routerURLSet = gxset.NewSet()
// BaseDirectory ...
type BaseDirectory struct {
url *common.URL
......@@ -53,10 +50,6 @@ func (dir *BaseDirectory) SetRouterChain(routerChain router.Chain) {
dir.routerChain = routerChain
}
func GetRouterURLSet() *gxset.HashSet {
return routerURLSet
}
// NewBaseDirectory ...
func NewBaseDirectory(url *common.URL) BaseDirectory {
return BaseDirectory{
......
......@@ -58,7 +58,6 @@ func RouterInit(confRouterFile string) error {
}
logger.Debugf("router config{%#v}\n", routerConfig)
directory.GetRouterURLSet().Add(initRouterUrl())
return nil
}
......
......@@ -105,6 +105,7 @@ func Load() {
ref.Refer(rpcService)
ref.Implement(rpcService)
}
//wait for invoker is available, if wait over default 3s, then panic
var count int
checkok := true
......
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment