modify log

_config.yml

@@ -1 +0,0 @@
-theme: jekyll-theme-slate

broker/client.go

@@ -459,7 +459,7 @@ func (c *client) Close() {
 		return
 	}
 	//wait for message complete
-	time.Sleep(time.Second)
+	time.Sleep(10 * time.Second)
 
 	c.smu.Lock()
 	c.status = Disconnected

broker/dispatcher.go

@@ -1,9 +1,5 @@
 package broker
 
-// const (
-// 	WorkNum = 4096
-// )
-
 var WorkNum int
 
 type Dispatcher struct {

broker/sublist.go

@@ -241,7 +241,6 @@ func (s *Sublist) Match(topic string) *SublistResult {
 	}
 
 	s.Unlock()
-	// log.Info("SublistResult: ", result)
 	return result
 }
 
@@ -294,7 +293,6 @@ func removeSubFromList(sub *subscription, sl []*subscription) ([]*subscription,
 			sl[i] = sl[last]
 			sl[last] = nil
 			sl = sl[:last]
-			// log.Info("removeSubFromList success")
 			return shrinkAsNeeded(sl), true
 		}
 	}