Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for setupReqStatsUpdate (0.35 sec)

  1. internal/rest/rpc-stats.go

    		s.TTFBAvgDuration = atomic.LoadUint64(&globalStats.tcpTimeForFirstByteTotalDur) / v
    	}
    	return s
    }
    
    // Return a function which update the global stats related to tcp connections
    func setupReqStatsUpdate(req *http.Request) (*http.Request, func()) {
    	var dialStart, dialEnd int64
    	start := time.Now()
    	trace := &httptrace.ClientTrace{
    		GotFirstResponseByte: func() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 18:21:34 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  2. internal/rest/client.go

    	if err != nil {
    		return nil, &NetworkError{Err: err}
    	}
    	if length > 0 {
    		req.ContentLength = length
    	}
    
    	_, expectTimeouts := ctx.Deadline()
    
    	req, update := setupReqStatsUpdate(req)
    	defer update()
    
    	resp, err := c.httpClient.Do(req)
    	if err != nil {
    		if xnet.IsNetworkOrHostDown(err, expectTimeouts) {
    			if !c.NoMetrics {
    				atomic.AddUint64(&globalStats.errs, 1)
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
Back to top