[incubator-inlong] 04/12: nitpick

[gosonzhang]

This is an automated email from the ASF dual-hosted git repository.

gosonzhang pushed a commit to branch INLONG-25
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git

commit 96b5728c33e7d6e840502456eb5ae750df8f062b
Author: Zijie Lu <wslz...@gmail.com>
AuthorDate: Fri Apr 30 17:07:21 2021 +0800

    nitpick
    
    Signed-off-by: Zijie Lu <wslz...@gmail.com>
---
 tubemq-client-twins/tubemq-client-go/multiplexed/multiplexed.go | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/tubemq-client-twins/tubemq-client-go/multiplexed/multiplexed.go 
b/tubemq-client-twins/tubemq-client-go/multiplexed/multiplexed.go
index 050b608..3792035 100644
--- a/tubemq-client-twins/tubemq-client-go/multiplexed/multiplexed.go
+++ b/tubemq-client-twins/tubemq-client-go/multiplexed/multiplexed.go
@@ -65,7 +65,6 @@ func NewPool() *Pool {
        return m
 }
 
-
 func (p *Pool) Get(ctx context.Context, address string, serialNo uint32) 
(*MultiplexedConnection, error) {
        select {
        case <-ctx.Done():
@@ -185,7 +184,7 @@ type Connection struct {
        buffer      *writerBuffer
        dialOpts    *DialOptions
        state       int
-       multiplexed *Pool
+       pool        *Pool
 }
 
 func (c *Connection) new(ctx context.Context, serialNo uint32) 
(*MultiplexedConnection, error) {
@@ -240,7 +239,7 @@ func (c *Connection) close(lastErr error, done chan 
struct{}) {
        if err != nil {
                c.state = Closed
                close(c.mDone)
-               c.multiplexed.connections.Delete(c)
+               c.pool.connections.Delete(c)
        }
 }