From 6faec50ab2ef4a75470e5d19ce02af17e497e631 Mon Sep 17 00:00:00 2001 From: "joy.zhou" Date: Thu, 1 Aug 2019 13:48:48 +0800 Subject: [PATCH] update --- broker/client.go | 28 ++++++++++++---------------- 1 file changed, 12 insertions(+), 16 deletions(-) diff --git a/broker/client.go b/broker/client.go index 0ec7515..a582c77 100644 --- a/broker/client.go +++ b/broker/client.go @@ -44,22 +44,18 @@ var ( ) type client struct { - typ int - mu sync.Mutex - broker *Broker - conn net.Conn - info info - route route - status int - ctx context.Context - cancelFunc context.CancelFunc - session *sessions.Session - subMap map[string]*subscription - topicsMgr *topics.Manager - subs []interface{} - qoss []byte - rmsgs []*packets.PublishPacket - routeSubMap map[string]uint64 + typ int + mu sync.Mutex + broker *Broker + conn net.Conn + info info + status int + ctx context.Context + cancelFunc context.CancelFunc + session *sessions.Session + subMap map[string]*subscription + topicsMgr *topics.Manager + rmsgs []*packets.PublishPacket } type subscription struct {