Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NumPendingRequestsForTesting (0.21 sec)

  1. src/net/http/export_test.go

    	return &timeoutHandler{
    		handler:     handler,
    		testContext: ctx,
    		// (no body)
    	}
    }
    
    func ResetCachedEnvironment() {
    	resetProxyConfig()
    }
    
    func (t *Transport) NumPendingRequestsForTesting() int {
    	t.reqMu.Lock()
    	defer t.reqMu.Unlock()
    	return len(t.reqCanceler)
    }
    
    func (t *Transport) IdleConnKeysForTesting() (keys []string) {
    	keys = make([]string, 0)
    	t.idleMu.Lock()
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Wed Apr 17 21:11:57 UTC 2024
    - 8.7K bytes
    - Viewed (0)
  2. src/net/http/transport_test.go

    	}
    
    	// Verify no outstanding requests after readLoop/writeLoop
    	// goroutines shut down.
    	waitCondition(t, 10*time.Millisecond, func(d time.Duration) bool {
    		n := tr.NumPendingRequestsForTesting()
    		if n > 0 {
    			if d > 0 {
    				t.Logf("pending requests = %d after %v (want 0)", n, d)
    			}
    			return false
    		}
    		return true
    	})
    }
    
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 192.6K bytes
    - Viewed (0)
Back to top