- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 136 for errc2 (0.35 sec)
-
cmd/kubemark/app/hollow_node_test.go
s := &hollowNodeConfig{ KubeconfigPath: kubeconfigPath, Morph: morph, } errCh := make(chan error) go func() { data, err := os.ReadFile(kubeconfigPath) t.Logf("read %d, err=%v\n", len(data), err) ctx := ktesting.Init(t) errCh <- run(ctx, s) }() select { case err := <-errCh: t.Fatalf("Run finished unexpectedly with error: %v", err) case <-time.After(3 * time.Second):
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 10:06:15 UTC 2024 - 2.3K bytes - Viewed (0) -
src/cmd/internal/objfile/plan9obj.go
var err2 error if pclntab, err2 = loadPlan9Table(f.plan9, "pclntab", "epclntab"); err2 != nil { return 0, nil, nil, err } } if symtab, err = loadPlan9Table(f.plan9, "runtime.symtab", "runtime.esymtab"); err != nil { // Same as above. var err2 error if symtab, err2 = loadPlan9Table(f.plan9, "symtab", "esymtab"); err2 != nil { return 0, nil, nil, err } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Sep 21 01:01:44 UTC 2017 - 3.5K bytes - Viewed (0) -
pkg/util/goroutinemap/goroutinemap_test.go
// Act err2 := grm.Run(operationName, operation2) // Assert if err2 == nil { t.Fatalf("NewGoRoutine did not fail. Expected: <Failed to create operation with name \"%s\". An operation with that name already exists.> Actual: <no error>", operationName) } if !IsAlreadyExists(err2) { t.Fatalf("NewGoRoutine did not return alreadyExistsError, got: %v", err2) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 11 14:09:48 UTC 2017 - 14.9K bytes - Viewed (0) -
pkg/volume/util/nestedpendingoperations/nestedpendingoperations_test.go
} operation2 := noopFunc // Act err2 := grm.Run(volumeName2, podName2, nodeName2, volumetypes.GeneratedOperations{OperationFunc: operation2}) // Assert if err2 == nil { t.Errorf("NestedPendingOperations did not fail. Expected an operation to already exist") } if !IsAlreadyExists(err2) { t.Errorf("NestedPendingOperations did not return alreadyExistsError, got: %v", err2) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Aug 26 01:29:17 UTC 2022 - 36.1K bytes - Viewed (0) -
src/cmd/internal/objfile/pe.go
var err2 error if pclntab, err2 = loadPETable(f.pe, "pclntab", "epclntab"); err2 != nil { return 0, nil, nil, err } } if symtab, err = loadPETable(f.pe, "runtime.symtab", "runtime.esymtab"); err != nil { // Same as above. var err2 error if symtab, err2 = loadPETable(f.pe, "symtab", "esymtab"); err2 != nil { return 0, nil, nil, err } }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Sat Aug 20 00:56:30 UTC 2022 - 4.9K bytes - Viewed (0) -
cmd/kube-scheduler/app/testing/testserver.go
logger := klog.FromContext(ctx) ctx, cancel := context.WithCancel(ctx) var errCh chan error tearDown := func() { cancel() // If the scheduler was started, let's wait for it to // shutdown clearly. if errCh != nil { err, ok := <-errCh if ok && err != nil { logger.Error(err, "Failed to shutdown test server clearly") } } if len(result.TmpDir) != 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 10:35:59 UTC 2023 - 5.2K bytes - Viewed (0) -
src/compress/gzip/example_test.go
// gzipWriter compresses data to httpWriter. gzipWriter := gzip.NewWriter(httpWriter) // errch collects any errors from the writing goroutine. errch := make(chan error, 1) go func() { defer close(errch) sentErr := false sendErr := func(err error) { if !sentErr { errch <- err sentErr = true } } // Copy our data to gzipWriter, which compresses it to
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 22 16:24:14 UTC 2022 - 4.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/webhook/validating/dispatcher.go
errCh <- apierrors.NewInternalError(err) return } if rejectionErr, ok := err.(*webhookutil.ErrWebhookRejection); ok { err = rejectionErr.Status } klog.Warningf("rejected by webhook %q: %#v", hook.Name, err) errCh <- err }(relevantHooks[i], i) } wg.Wait() close(errCh) var errs []error for e := range errCh {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 23 20:24:12 UTC 2023 - 13K bytes - Viewed (0) -
pkg/kube/portforwarder.go
fw, err = f.buildK8sPortForwarder(readyCh) if err != nil { f.errCh <- fmt.Errorf("building port forwarded: %v", err) return } if err = fw.ForwardPorts(); err != nil { log.Errorf("port forward failed: %v", err) f.errCh <- fmt.Errorf("port forward: %v", err) return } log.Infof("port forward completed without error") f.errCh <- nil
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 02:12:37 UTC 2023 - 5.5K bytes - Viewed (0) -
cmd/kube-controller-manager/app/testing/testserver.go
logger := klog.FromContext(ctx) ctx, cancel := context.WithCancel(ctx) var errCh chan error tearDown := func() { cancel() // If the kube-controller-manager was started, let's wait for // it to shutdown cleanly. if errCh != nil { err, ok := <-errCh if ok && err != nil { logger.Error(err, "Failed to shutdown test server cleanly") } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Oct 27 11:28:02 UTC 2023 - 5.4K bytes - Viewed (0)