Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for doRequest (0.18 sec)

  1. pkg/test/loadbalancersim/loadbalancer/leastrequest.go

    	if len(lb.conns) == 1 {
    		lb.doRequest(lb.get(0), onDone)
    		return
    	}
    
    	// Pick 2 endpoints at random.
    	c1, c2 := lb.pick2()
    
    	// Choose the endpoint with fewer active requests.
    	selected := c1
    	if c2.ActiveRequests() < c1.ActiveRequests() {
    		selected = c2
    	}
    
    	// Apply the selected endpoint to the metrics decorator and send the request.
    	lb.doRequest(selected, onDone)
    }
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Nov 14 20:23:34 UTC 2022
    - 3.4K bytes
    - Viewed (0)
  2. src/runtime/chanbarrier_test.go

    package runtime_test
    
    import (
    	"runtime"
    	"sync"
    	"testing"
    )
    
    type response struct {
    }
    
    type myError struct {
    }
    
    func (myError) Error() string { return "" }
    
    func doRequest(useSelect bool) (*response, error) {
    	type async struct {
    		resp *response
    		err  error
    	}
    	ch := make(chan *async, 0)
    	done := make(chan struct{}, 0)
    
    	if useSelect {
    		go func() {
    			select {
    Registered: Wed Jun 12 16:32:35 UTC 2024
    - Last Modified: Mon May 06 17:50:18 UTC 2024
    - 1.4K bytes
    - Viewed (0)
  3. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/CompatibleDaemonExpirationStrategy.java

            this.daemon = daemon;
            this.compatibilitySpec = compatibilitySpec;
        }
    
        CompatibleDaemonExpirationStrategy(Daemon daemon) {
            this(daemon, new DaemonCompatibilitySpec(daemon.getDaemonContext().toRequest()));
        }
    
        @Override
        public DaemonExpirationResult checkExpiration() {
            Spec<DaemonInfo> spec = new Spec<DaemonInfo>() {
                @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Apr 05 18:27:45 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  4. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/context/DaemonContext.java

        /**
         * Returns whether the daemon should use native services.
         */
        NativeServicesMode getNativeServicesMode();
    
        DaemonParameters.Priority getPriority();
    
        DaemonRequestContext toRequest();
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 29 05:33:15 UTC 2024
    - 2.7K bytes
    - Viewed (0)
  5. platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/context/DefaultDaemonContext.java

            return nativeServicesMode;
        }
    
        @Override
        public DaemonParameters.Priority getPriority() {
            return priority;
        }
    
        @Override
        public DaemonRequestContext toRequest() {
            return new DaemonRequestContext(Jvm.forHome(javaHome), null, this.getDaemonOpts(), this.shouldApplyInstrumentationAgent(), this.getNativeServicesMode(), this.getPriority());
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 23 05:16:16 UTC 2024
    - 6.8K bytes
    - Viewed (0)
Back to top