- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 57 for resultCh (0.43 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)