Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for reqCanceler (0.11 sec)

  1. src/net/http/export_test.go

    		// (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()
    	defer t.idleMu.Unlock()
    	for key := range t.idleConn {
    		keys = append(keys, key.String())
    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.go

    	// concurrency guarantees.
    	cancel := func(err error) {
    		origCancel(err)
    		t.reqMu.Lock()
    		delete(t.reqCanceler, req)
    		t.reqMu.Unlock()
    	}
    	t.reqMu.Lock()
    	if t.reqCanceler == nil {
    		t.reqCanceler = make(map[*Request]context.CancelCauseFunc)
    	}
    	t.reqCanceler[req] = cancel
    	t.reqMu.Unlock()
    	return cancel
    }
    
    // CancelRequest cancels an in-flight request by closing its connection.
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Thu Jun 06 21:59:21 UTC 2024
    - 91K bytes
    - Viewed (0)
Back to top