Search Options

Results per page
Sort
Preferred Languages
Advance

Results 511 - 520 of 932 for erre (0.09 sec)

  1. cmd/xl-storage-format-v1.go

    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	if err := json.Unmarshal(data, &info); err != nil {
    		return err
    	}
    	sum, err := hex.DecodeString(info.Hash)
    	if err != nil {
    		return err
    	}
    	c.Algorithm = BitrotAlgorithmFromString(info.Algorithm)
    	c.Hash = sum
    	if _, err = fmt.Sscanf(info.Name, "part.%d", &c.PartNumber); err != nil {
    		return err
    	}
    
    	if !c.Algorithm.Available() {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. istioctl/pkg/tag/generate.go

    	}
    	tagWhYAML, err := generateMutatingWebhook(tagWhConfig, opts)
    	if err != nil {
    		return "", fmt.Errorf("failed to create tag webhook: %w", err)
    	}
    
    	if opts.Tag == DefaultRevisionName {
    		if !opts.Generate {
    			// deactivate other istio-injection=enabled injectors if using default revisions.
    			err := DeactivateIstioInjectionWebhook(ctx, client.Kube())
    			if err != nil {
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 13.3K bytes
    - Viewed (0)
  3. internal/s3select/sql/jsonpath.go

    		case simdjson.Object:
    			elem := kvs.FindKey(key, nil)
    			if elem == nil {
    				// Key not found - return nil result
    				return Missing{}, false, nil
    			}
    			val, err := IterToValue(elem.Iter)
    			if err != nil {
    				return nil, false, err
    			}
    			return jsonpathEval(p[1:], val)
    		default:
    			return nil, false, errKeyLookup
    		}
    
    	case p[0].Index != nil:
    		idx := *p[0].Index
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.5K bytes
    - Viewed (0)
  4. internal/handlers/forwarder.go

    //
    //	`http: proxy error: context canceled` printed by Golang
    func (f *Forwarder) customErrHandler(w http.ResponseWriter, r *http.Request, err error) {
    	if f.Logger != nil && err != context.Canceled {
    		f.Logger(err)
    	}
    	w.WriteHeader(http.StatusBadGateway)
    }
    
    func (f *Forwarder) getURLFromRequest(req *http.Request) *url.URL {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 07 05:42:10 UTC 2023
    - 5.6K bytes
    - Viewed (0)
  5. internal/bucket/bandwidth/reader.go

    	av := int(r.throttle.Tokens())
    	if av < tokens && av > 0 {
    		tokens = av
    		need = int(math.Min(float64(tokens), float64(need)))
    	}
    	err = r.throttle.WaitN(r.ctx, tokens)
    	if err != nil {
    		return
    	}
    	n, err = r.r.Read(buf[:need])
    	if err != nil {
    		r.lastErr = err
    		return
    	}
    	r.m.updateMeasurement(r.opts.BucketOptions, uint64(tokens))
    	return
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 14:57:31 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  6. lib/time/mkzip.go

    			CRC32:              crc32.ChecksumIEEE(data),
    		})
    		if err != nil {
    			log.Fatal(err)
    		}
    		if _, err := w.Write(data); err != nil {
    			log.Fatal(err)
    		}
    		seen[name] = true
    		return nil
    	})
    	if err != nil {
    		log.Fatal(err)
    	}
    	if err := zw.Close(); err != nil {
    		log.Fatal(err)
    	}
    	if len(seen) == 0 {
    		log.Fatalf("did not find any files to add")
    	}
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Mar 04 17:32:07 UTC 2024
    - 2.1K bytes
    - Viewed (0)
  7. cmd/copy-part-range.go

    // for full details. This function treats an empty rangeString as
    // referring to the whole resource.
    func parseCopyPartRangeSpec(rangeString string) (hrange *HTTPRangeSpec, err error) {
    	hrange, err = parseRequestRangeSpec(rangeString)
    	if err != nil {
    		return nil, err
    	}
    	if hrange.IsSuffixLength || hrange.Start < 0 || hrange.End < 0 {
    		return nil, errInvalidRange
    	}
    	return hrange, nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jun 18 03:27:04 UTC 2021
    - 2.5K bytes
    - Viewed (0)
  8. internal/config/certs_test.go

    	var tmpfile *os.File
    
    	if tmpfile, err = os.CreateTemp("", prefix); err != nil {
    		return tempFile, err
    	}
    
    	if _, err = tmpfile.Write([]byte(content)); err != nil {
    		return tempFile, err
    	}
    
    	if err = tmpfile.Close(); err != nil {
    		return tempFile, err
    	}
    
    	tempFile = tmpfile.Name()
    	return tempFile, err
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 19 18:05:16 UTC 2022
    - 21.6K bytes
    - Viewed (0)
  9. src/bytes/reader.go

    func (r *Reader) WriteTo(w io.Writer) (n int64, err error) {
    	r.prevRune = -1
    	if r.i >= int64(len(r.s)) {
    		return 0, nil
    	}
    	b := r.s[r.i:]
    	m, err := w.Write(b)
    	if m > len(b) {
    		panic("bytes.Reader.WriteTo: invalid Write count")
    	}
    	r.i += int64(m)
    	n = int64(m)
    	if m != len(b) && err == nil {
    		err = io.ErrShortWrite
    	}
    	return
    }
    
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Tue Jul 16 18:17:37 UTC 2024
    - 3.9K bytes
    - Viewed (0)
  10. src/archive/zip/writer.go

    		} else {
    			b.uint32(uint32(h.offset))
    		}
    		if _, err := w.cw.Write(buf[:]); err != nil {
    			return err
    		}
    		if _, err := io.WriteString(w.cw, h.Name); err != nil {
    			return err
    		}
    		if _, err := w.cw.Write(h.Extra); err != nil {
    			return err
    		}
    		if _, err := io.WriteString(w.cw, h.Comment); err != nil {
    			return err
    		}
    	}
    	end := w.cw.count
    
    	records := uint64(len(w.dir))
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Mon Sep 23 14:32:33 UTC 2024
    - 19.4K bytes
    - Viewed (0)
Back to top