Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 57 for resultCh (0.43 sec)

  1. staging/src/k8s.io/apiserver/pkg/server/filters/priority-and-fairness.go

    			// and the initialization signal will not be send.
    			// It has to happen before waiting on the resultCh below.
    			watchInitializationSignal.Signal()
    			// TODO: Consider finishing the request as soon as Handle call panics.
    			if err := <-resultCh; err != nil {
    				panic(err)
    			}
    		case err := <-resultCh:
    			if err != nil {
    				panic(err)
    			}
    		}
    	} else {
    		execute := func() {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Oct 30 12:18:35 UTC 2023
    - 15.3K bytes
    - Viewed (0)
  2. staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go

    func (ifr *inFlightRequest) launch(doer doer, client *http.Client) {
    	go func() {
    		result := doer.Do(client, func(httptrace.GotConnInfo) {}, ifr.url, 0)
    		ifr.resultCh <- result
    	}()
    }
    
    func (ifr *inFlightRequest) unblockAndWaitForResult(t *testing.T) result {
    	close(ifr.blockedCh)
    
    	var resultGot result
    	select {
    	case resultGot = <-ifr.resultCh:
    		return resultGot
    	case <-time.After(wait.ForeverTestTimeout):
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 38.3K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apiserver/pkg/server/genericapiserver_test.go

    		defer func() {
    			result := result{}
    			result.err = recover()
    			if result.err != nil {
    				// Same as stdlib http server code. Manually allocate stack
    				// trace buffer size to prevent excessively large logs
    				const size = 64 << 10
    				buf := make([]byte, size)
    				buf = buf[:goruntime.Stack(buf, false)]
    				result.stackTrace = string(buf)
    			}
    			resultCh <- result
    		}()
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Apr 29 18:59:21 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/util/webhook/webhook_test.go

    	if err != nil {
    		t.Fatalf("failed to create the webhook: %v", err)
    	}
    
    	resultCh := make(chan rest.Result)
    
    	go func() { resultCh <- wh.RestClient.Get().Do(context.TODO()) }()
    	select {
    	case <-time.After(time.Second * 5):
    		t.Errorf("expected request to timeout after %s", requestTimeout)
    	case <-resultCh:
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 29 15:48:39 UTC 2023
    - 25.8K bytes
    - Viewed (0)
  5. platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/junit/AbstractJUnitTestExecutionIntegrationTest.groovy

            then:
            TestFile results1 = testDirectory.file('build/test-results/test/TEST-org.gradle.SomeTest.xml')
            TestFile results2 = testDirectory.file('build/test-results/test/TEST-org.gradle.SomeTest2.xml')
            results1.assertIsFile()
            results2.assertIsFile()
            assertThat(results1.linesThat(containsString('VM START TIME =')).get(0), equalTo(results2.linesThat(containsString('VM START TIME =')).get(0)))
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Sat Apr 06 02:21:33 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  6. tensorflow/compiler/aot/tests/tfcompile_test.cc

          EXPECT_EQ(muladd.result0_data()[i], results0[i]);
          EXPECT_EQ(muladd.result1(i / 2, i % 2), results1[i]);
          EXPECT_EQ(muladd.result1_data()[i], results1[i]);
        }
        EXPECT_EQ(muladd.result0_data(), muladd.results()[0]);
        EXPECT_EQ(muladd.result1_data(), muladd.results()[1]);
    
        const ::foo::bar::MatMulAndAddComp& muladd_const = muladd;
    Registered: Sun Jun 16 05:45:23 UTC 2024
    - Last Modified: Wed Sep 06 19:12:29 UTC 2023
    - 26.4K bytes
    - Viewed (0)
  7. platforms/documentation/docs/src/docs/userguide/img/ci-systems/teamcity-results.png

    teamcity-results.png...
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Nov 27 17:53:42 UTC 2023
    - 15.5K bytes
    - Viewed (0)
  8. platforms/documentation/docs/src/docs/userguide/img/ci-systems/teamcity-build-results.png

    teamcity-build-results.png...
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Mon Nov 27 17:53:42 UTC 2023
    - 18.5K bytes
    - Viewed (0)
  9. platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/ComponentState.java

            DefaultBuildableComponentResolveResult result = new DefaultBuildableComponentResolveResult();
            resolver.resolve(componentIdentifier, componentOverrideMetadata, result);
    
            if (result.getFailure() != null) {
                metadataResolveFailure = result.getFailure();
                return;
            }
            resolveState = result.getState();
            graphResolveState = result.getGraphState();
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Jun 07 02:21:08 UTC 2024
    - 17K bytes
    - Viewed (0)
  10. platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolveengine/result/StreamingResolutionResultBuilderTest.groovy

    import static org.gradle.api.internal.artifacts.ivyservice.resolveengine.result.ComponentSelectionReasons.of
    import static org.gradle.api.internal.artifacts.ivyservice.resolveengine.result.ComponentSelectionReasons.requested
    import static org.gradle.api.internal.artifacts.ivyservice.resolveengine.result.ComponentSelectionReasons.root
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Thu May 23 17:29:40 UTC 2024
    - 11.5K bytes
    - Viewed (0)
Back to top