lastWrite time.Time = time.Now()
keepAliveTimer *time.Timer
)
+ cn.mu.Lock()
+ defer cn.mu.Unlock()
keepAliveTimer = time.AfterFunc(keepAliveTimeout, func() {
cn.mu.Lock()
defer cn.mu.Unlock()
}
keepAliveTimer.Reset(keepAliveTimeout)
})
- cn.mu.Lock()
- defer cn.mu.Unlock()
defer keepAliveTimer.Stop()
frontBuf := new(bytes.Buffer)
for {