- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 77 for resultCh (0.18 sec)
-
staging/src/k8s.io/apimachinery/pkg/util/runtime/runtime_test.go
defer func() { PanicHandlers = old }() var result interface{} PanicHandlers = []func(context.Context, interface{}){ func(_ context.Context, r interface{}) { result = r }, } func() { defer func() { if x := recover(); x == nil { t.Errorf("Expected a panic to recover from") } }() defer HandleCrash() panic("test") }() if result != "test" { t.Errorf("did not receive custom handler")
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 4.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/filters/timeout.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 16:28:45 UTC 2024 - 8.9K 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) -
cmd/batch-handlers.go
} func (j *BatchJobPool) resume() { results := make(chan itemOrErr[ObjectInfo], 100) ctx, cancel := context.WithCancel(j.ctx) defer cancel() if err := j.objLayer.Walk(ctx, minioMetaBucket, batchJobPrefix, results, WalkOptions{}); err != nil { batchLogIf(j.ctx, err) return } for result := range results { if result.Err != nil { batchLogIf(j.ctx, result.Err) continue }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Jun 11 03:13:30 UTC 2024 - 56K bytes - Viewed (0) -
cmd/admin-handlers.go
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 98K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
b.ResetTimer() for i := 0; i < b.N; i++ { result := &example.PodList{} err = cacher.GetList(context.TODO(), "pods", storage.ListOptions{ Predicate: pred, Recursive: true, ResourceVersion: "12345", }, result) if err != nil { b.Fatalf("GetList cache: %v", err) } if len(result.Items) != tc.expectObjectNum {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
cmd/bucket-replication.go
lastCheckpoint = st.Object } workers := make([]chan ReplicateObjectInfo, resyncParallelRoutines) resultCh := make(chan TargetReplicationResyncStatus, 1) defer xioutil.SafeClose(resultCh) go func() { for r := range resultCh { s.incStats(r, opts) globalSiteResyncMetrics.updateMetric(r, opts.resyncID) } }() var wg sync.WaitGroup
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 06:56:12 UTC 2024 - 114.4K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/results/DefaultVisitedGraphResultsTest.groovy
def results3 = new DefaultVisitedGraphResults(resolutionResult, Collections.emptySet(), resolveEx) def results4 = new DefaultVisitedGraphResults(resolutionResult, Collections.singleton(unresolved), resolveEx) expect: visitFailures(results1) == [] visitFailures(results2) == [throwable] visitFailures(results3) == [resolveEx] visitFailures(results4) == [throwable, resolveEx] }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 23 17:30:13 UTC 2024 - 3.3K 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)