diff --git a/protocol/dubbo/pool.go b/protocol/dubbo/pool.go index cdd2a10a471dd906fc77d165991752cc7d7e266b..c1762c8c1814c44dba5830f3c3828327e72ca101 100644 --- a/protocol/dubbo/pool.go +++ b/protocol/dubbo/pool.go @@ -39,7 +39,7 @@ type gettyRPCClient struct { once sync.Once protocol string addr string - created int64 // zero, not create or be destroyed + active int64 // zero, not create or be destroyed pool *gettyRPCClientPool @@ -85,11 +85,11 @@ func newGettyRPCClientConn(pool *gettyRPCClientPool, protocol, addr string) (*ge } func (c *gettyRPCClient) updateActive(active int64) { - atomic.StoreInt64(&c.created, active) + atomic.StoreInt64(&c.active, active) } func (c *gettyRPCClient) getActive() int64 { - return atomic.LoadInt64(&c.created) + return atomic.LoadInt64(&c.active) } func (c *gettyRPCClient) newSession(session getty.Session) error { @@ -305,7 +305,7 @@ func (p *gettyRPCClientPool) getGettyRpcClient(protocol, addr string) (*gettyRPC } continue } - conn.updateActive(now) //update created time + conn.updateActive(now) //update active time return conn, nil }