Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for respHeaderTimer (0.12 sec)

  1. src/net/http/transport.go

    			req.logf("resc recv: %p, %T/%#v", re.res, re.err, re.err)
    		}
    		if re.err != nil {
    			return nil, pc.mapRoundTripError(req, startBytesWritten, re.err)
    		}
    		return re.res, nil
    	}
    
    	var respHeaderTimer <-chan time.Time
    	ctxDoneChan := req.ctx.Done()
    	pcClosed := pc.closech
    	for {
    		testHookWaitResLoop()
    		select {
    		case err := <-writeErrCh:
    			if debugRoundTrip {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 91K bytes
    - Viewed (0)
  2. src/net/http/h2_bundle.go

    			}
    		} else {
    			cs.sentEndStream = true
    		}
    	}
    
    	http2traceWroteRequest(cs.trace, err)
    
    	var respHeaderTimer <-chan time.Time
    	var respHeaderRecv chan struct{}
    	if d := cc.responseHeaderTimeout(); d != 0 {
    		timer := cc.t.newTimer(d)
    		defer timer.Stop()
    		respHeaderTimer = timer.C()
    		respHeaderRecv = cs.respHeaderRecv
    	}
    	// Wait until the peer half-closes its end of the stream,
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Tue Jun 04 16:19:04 UTC 2024
    - 364.1K bytes
    - Viewed (0)
Back to top