@@ -203,15 +203,15 @@ func (c *Conn) readLoop(ctx context.Context) (header, error) {
203
203
func (c * Conn ) readFrameHeader (ctx context.Context ) (header , error ) {
204
204
select {
205
205
case <- c .closed :
206
- return header {}, c . closeErr
206
+ return header {}, errClosed
207
207
case c .readTimeout <- ctx :
208
208
}
209
209
210
210
h , err := readFrameHeader (c .br , c .readHeaderBuf [:])
211
211
if err != nil {
212
212
select {
213
213
case <- c .closed :
214
- return header {}, c . closeErr
214
+ return header {}, errClosed
215
215
case <- ctx .Done ():
216
216
return header {}, ctx .Err ()
217
217
default :
@@ -222,7 +222,7 @@ func (c *Conn) readFrameHeader(ctx context.Context) (header, error) {
222
222
223
223
select {
224
224
case <- c .closed :
225
- return header {}, c . closeErr
225
+ return header {}, errClosed
226
226
case c .readTimeout <- context .Background ():
227
227
}
228
228
@@ -232,15 +232,15 @@ func (c *Conn) readFrameHeader(ctx context.Context) (header, error) {
232
232
func (c * Conn ) readFramePayload (ctx context.Context , p []byte ) (int , error ) {
233
233
select {
234
234
case <- c .closed :
235
- return 0 , c . closeErr
235
+ return 0 , errClosed
236
236
case c .readTimeout <- ctx :
237
237
}
238
238
239
239
n , err := io .ReadFull (c .br , p )
240
240
if err != nil {
241
241
select {
242
242
case <- c .closed :
243
- return n , c . closeErr
243
+ return n , errClosed
244
244
case <- ctx .Done ():
245
245
return n , ctx .Err ()
246
246
default :
@@ -252,7 +252,7 @@ func (c *Conn) readFramePayload(ctx context.Context, p []byte) (int, error) {
252
252
253
253
select {
254
254
case <- c .closed :
255
- return n , c . closeErr
255
+ return n , errClosed
256
256
case c .readTimeout <- context .Background ():
257
257
}
258
258
0 commit comments