- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 136 for errc2 (0.07 sec)
-
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/internal/generic/controller.go
AddFunc: enqueue, UpdateFunc: func(oldObj, newObj interface{}) { oldMeta, err1 := meta.Accessor(oldObj) newMeta, err2 := meta.Accessor(newObj) if err1 != nil || err2 != nil { if err1 != nil { utilruntime.HandleError(err1) } if err2 != nil { utilruntime.HandleError(err2) } return } else if oldMeta.GetResourceVersion() == newMeta.GetResourceVersion() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 7.5K bytes - Viewed (0) -
internal/s3select/message.go
getProgressFunc func() (int64, int64) bytesReturned int64 payloadBuffer []byte payloadBufferIndex int payloadCh chan *bytes.Buffer finBytesScanned, finBytesProcessed int64 errCh chan []byte doneCh chan struct{} } func (writer *messageWriter) write(data []byte) bool { if _, err := writer.writer.Write(data); err != nil { return false }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Aug 30 15:26:43 UTC 2022 - 15.2K bytes - Viewed (0) -
src/net/http/httputil/reverseproxy.go
return } if err := brw.Flush(); err != nil { p.getErrorHandler()(rw, req, fmt.Errorf("response flush: %v", err)) return } errc := make(chan error, 1) spc := switchProtocolCopier{user: conn, backend: backConn} go spc.copyToBackend(errc) go spc.copyFromBackend(errc) <-errc } // switchProtocolCopier exists so goroutines proxying data back and // forth have nice names in stacks.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Feb 27 23:37:42 UTC 2024 - 24.9K bytes - Viewed (0) -
src/hash/maphash/maphash_test.go
h2.SetSeed(h1.Seed()) n1, err1 := h1.WriteString(s) if n1 != len(s) || err1 != nil { t.Fatalf("WriteString(s) = %d, %v, want %d, nil", n1, err1, len(s)) } n2, err2 := h2.Write(b) if n2 != len(b) || err2 != nil { t.Fatalf("Write(b) = %d, %v, want %d, nil", n2, err2, len(b)) } if h1.Sum64() != h2.Sum64() { t.Errorf("hash of string and bytes not identical") } } func TestHashHighBytes(t *testing.T) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jun 14 00:03:57 UTC 2023 - 5.2K bytes - Viewed (0) -
pkg/config/validation/agent/validation.go
appendError := func(err, err2 error) error { if err == nil { return err2 } else if err2 == nil { return err } return multierror.Append(err, err2) } for _, err2 := range errs { switch t := err2.(type) { case Validation: err = appendError(err, t.Err) default: err = appendError(err, err2) } } return err }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 30.9K bytes - Viewed (0) -
src/math/big/floatconv.go
r := strings.NewReader(s) if f, b, err = z.scan(r, base); err != nil { return } // entire string must have been consumed if ch, err2 := r.ReadByte(); err2 == nil { err = fmt.Errorf("expected end of string, found %q", ch) } else if err2 != io.EOF { err = err2 } return } // ParseFloat is like f.Parse(s, base) with f set to the given precision // and rounding mode.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu Oct 19 11:59:09 UTC 2023 - 8.3K bytes - Viewed (0) -
pkg/config/validation/agent/extensionprovider.go
return fmt.Errorf("service must not be empty") } parts := strings.Split(service, "/") if len(parts) == 1 { if err := ValidateFQDN(service); err != nil { if err2 := ValidateIPAddress(service); err2 != nil { return fmt.Errorf("invalid service fmt %s: %s", service, err2) } } } else { if err := ValidateNamespaceSlashWildcardHostname(service, false, false); err != nil { return err } } return nil }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Apr 17 20:06:41 UTC 2024 - 11K bytes - Viewed (0) -
src/cmd/go/internal/clean/clean.go
if runtime.GOOS == "windows" { // Remove lingering ~ file from last attempt. if _, err2 := os.Stat(f + "~"); err2 == nil { os.Remove(f + "~") } // Try to move it out of the way. If the move fails, // which is likely, we'll try again the // next time we do an install of this binary. if err2 := os.Rename(f, f+"~"); err2 == nil { os.Remove(f + "~") return } } base.Error(err)
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Thu May 16 14:34:32 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
errCh := make(chan error, len(pods)) successfulDeletes := int32(len(pods)) wg := sync.WaitGroup{} wg.Add(len(pods)) for i := range pods { go func(pod *v1.Pod) { defer wg.Done() if err := jm.podControl.DeletePod(ctx, job.Namespace, pod.Name, job); err != nil && !apierrors.IsNotFound(err) { atomic.AddInt32(&successfulDeletes, -1) errCh <- err utilruntime.HandleError(err)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
errCh := make(chan error, batchSize) var wg sync.WaitGroup wg.Add(batchSize) for i := 0; i < batchSize; i++ { go func() { defer wg.Done() if err := fn(); err != nil { errCh <- err } }() } wg.Wait() curSuccesses := batchSize - len(errCh) successes += curSuccesses if len(errCh) > 0 { return successes, <-errCh }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0)