diff --git a/protocol/invoker.go b/protocol/invoker.go index 3ca370479cbe2255f26628b855b11b07396f1b6d..91814e27e634a8be0a58bc6811bb68dd9861fd8d 100644 --- a/protocol/invoker.go +++ b/protocol/invoker.go @@ -26,7 +26,7 @@ import ( "github.com/apache/dubbo-go/common/logger" ) -// Invoker ... +// Invoker the service invocation interface for the consumer //go:generate mockgen -source invoker.go -destination mock/mock_invoker.go -self_package github.com/apache/dubbo-go/protocol/mock --package mock Invoker // Extension - Invoker type Invoker interface { diff --git a/remoting/getty/pool.go b/remoting/getty/pool.go index 464cff956e0b4667944942be1c4721a05845bd33..813aacba7f50a12ab0c0b95efd3b8ef64228e9a3 100644 --- a/remoting/getty/pool.go +++ b/remoting/getty/pool.go @@ -93,7 +93,7 @@ func newGettyRPCClientConn(pool *gettyRPCClientPool, addr string) (*gettyRPCClie c.gettyClient.Close() return nil, perrors.New(fmt.Sprintf("failed to create client connection to %s in %f seconds", addr, float32(times)/1000)) } - time.Sleep(1e6) + time.Sleep(time.Millisecond * time.Duration(times)) } logger.Debug("client init ok") c.updateActive(time.Now().Unix())