fix typos

This commit is contained in:
xtaci
2020-02-20 17:16:37 +08:00
parent 80072d9b5c
commit c6969d8a76
+1 -1
View File
@@ -392,7 +392,7 @@ func (s *Session) keepalive() {
s.notifyBucket() // force a signal to the recvLoop
case <-tickerTimeout.C:
if !atomic.CompareAndSwapInt32(&s.dataReady, 1, 0) {
// recvLoop main block on bucket == 0, in this case,
// recvLoop may block while bucket is 0, in this case,
// session should not be closed.
if atomic.LoadInt32(&s.bucket) > 0 {
s.Close()