- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 141 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/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) -
src/internal/singleflight/singleflight_test.go
t.Errorf("After first goroutine finished, key %q is still shared, should return false", key) } secondCh <- struct{}{} if result := <-resultCh; result.Val != 2 { t.Errorf("We should receive result produced by second call, expected: 2, got %d", result.Val) } } func TestDoAndForgetUnsharedRace(t *testing.T) { t.Parallel() var g Group key := "key" d := time.Millisecond for {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Mar 29 22:21:50 UTC 2023 - 3.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) -
tensorflow/compiler/mlir/tfrt/tests/cross_device_transfer.mlir
// CHECK-NEXT: %[[RESULT_3:.*]] = corert.executeop(%[[RESULT_0]]) "tf.AddV2"(%[[RESULT_2]], %[[RESULT_2]]) %3 = corert.executeop(%0) "tf.AddV2"(%2, %2) {T = f32, device = "/device:CPU:0"} : 1 // CHECK-NEXT: %[[RESULT_4:.*]] = tfrt.get_device %[[ARG_0]] {device_name = "/device:GPU:0"} // CHECK-NEXT: %[[RESULT_5:.*]] = corert.get_dst_tensor_type %[[RESULT_3]], %[[RESULT_4]] // CHECK-NEXT: %[[RESULT_6:.*]] = corert.transfer %[[RESULT_3]], %[[RESULT_4]], %[[RESULT_5]]
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Fri Mar 25 10:58:25 UTC 2022 - 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) -
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)