logger: pc.logger,
w: pc.w,
keepAlive: func() bool {
- pc.locker().Lock()
- defer pc.locker().Unlock()
+ pc.locker().RLock()
+ defer pc.locker().RUnlock()
return pc.useful()
},
writeBuffer: new(bytes.Buffer),
if err == nil && n != len(next) {
panic("expected full write")
}
+ if err != nil {
+ break
+ }
}
if err != nil {
cn.logger.WithDefaultLevel(log.Debug).Printf("error writing: %v", err)