Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 457 for parts (0.05 sec)

  1. cmd/erasure-healing_test.go

    		Recursive: false,
    		Immediate: false,
    	})
    	if err != nil {
    		t.Errorf("Failure during deleting part.1 - %v", err)
    	}
    
    	err = firstDisk.WriteAll(context.Background(), bucket, pathJoin(object, fi.DataDir, "part.1"), []byte{})
    	if err != nil {
    		t.Errorf("Failure during creating part.1 - %v", err)
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:51:27 UTC 2024
    - 49K bytes
    - Viewed (0)
  2. cmd/bucket-replication-utils.go

    	if cr == "" {
    		return sz, fmt.Errorf("Content-Range not set")
    	}
    	parts := contentRangeRegexp.FindStringSubmatch(cr)
    	if len(parts) != 4 {
    		return sz, fmt.Errorf("invalid Content-Range header %s", cr)
    	}
    	if parts[3] == "*" {
    		return -1, nil
    	}
    	var usz uint64
    	usz, err = strconv.ParseUint(parts[3], 10, 64)
    	if err != nil {
    		return sz, err
    	}
    	return int64(usz), nil
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 26.3K bytes
    - Viewed (0)
  3. internal/event/target/elasticsearch.go

    	ESSSupported ESSupportStatus = "ESSSupported"
    )
    
    func getESVersionSupportStatus(version string) (res ESSupportStatus, err error) {
    	parts := strings.Split(version, ".")
    	if len(parts) < 1 {
    		err = fmt.Errorf("bad ES version string: %s", version)
    		return
    	}
    
    	majorVersion, err := strconv.Atoi(parts[0])
    	if err != nil {
    		err = fmt.Errorf("bad ES version string: %s", version)
    		return
    	}
    
    	switch {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 23:06:30 UTC 2024
    - 15K bytes
    - Viewed (0)
  4. cmd/erasure-object.go

    	}
    
    	var healOnce sync.Once
    
    	for ; partIndex <= lastPartIndex; partIndex++ {
    		if length == totalBytesRead {
    			break
    		}
    
    		partNumber := fi.Parts[partIndex].Number
    
    		// Save the current part name and size.
    		partSize := fi.Parts[partIndex].Size
    
    		partLength := partSize - partOffset
    		// partLength should be adjusted so that we don't write more data than what was requested.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  5. cmd/erasure-healing-common_test.go

    	// Test 4: key = disk index, value = part name with hash mismatch
    	diskFailures := make(map[int]string)
    	diskFailures[0] = "part.1"
    	diskFailures[3] = "part.1"
    	diskFailures[15] = "part.1"
    
    	for diskIndex, partName := range diskFailures {
    		for i := range partsMetadata[diskIndex].Parts {
    			if fmt.Sprintf("part.%d", i+1) == partName {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 15:19:10 UTC 2024
    - 23.1K bytes
    - Viewed (0)
  6. build-logic/documentation/src/main/groovy/gradlebuild/docs/GradleDocumentationExtension.java

         */
        public abstract ConfigurableFileCollection getRenderedDocumentation();
    
        // These are all helper methods for configuring the parts of the documentation (DSL ref, javadoc, user manual, etc).
        public ReleaseNotes getReleaseNotes() {
            return releaseNotes;
        }
    
        public void releaseNotes(Action<? super ReleaseNotes> action) {
    Registered: Wed Nov 06 11:36:14 UTC 2024
    - Last Modified: Tue Aug 20 14:11:17 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. cmd/storage-datatypes_gen.go

    	if err != nil {
    		err = msgp.WrapError(err, "Parts")
    		return
    	}
    	if cap(z.Parts) >= int(zb0003) {
    		z.Parts = (z.Parts)[:zb0003]
    	} else {
    		z.Parts = make([]ObjectPartInfo, zb0003)
    	}
    	for za0003 := range z.Parts {
    		err = z.Parts[za0003].DecodeMsg(dc)
    		if err != nil {
    			err = msgp.WrapError(err, "Parts", za0003)
    			return
    		}
    	}
    	err = z.Erasure.DecodeMsg(dc)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 150.2K bytes
    - Viewed (0)
  8. cmd/erasure-metadata-utils.go

    	}
    	if totalSize == -1 {
    		return -1, nil
    	}
    	if totalSize > 0 {
    		// Compute the total count of parts
    		partsCount := totalSize/partSize + 1
    		// Return the part's size
    		switch {
    		case int64(partIndex) < partsCount:
    			currPartSize = partSize
    		case int64(partIndex) == partsCount:
    			// Size of last part
    			currPartSize = totalSize % partSize
    		default:
    			currPartSize = 0
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 11.7K bytes
    - Viewed (0)
  9. src/archive/zip/zip_test.go

    		return cmp.Compare(rb.off+rb.n, off)
    	})
    	parts := r.buf[skipParts:]
    	if len(parts) > 0 {
    		skipBytes := off - parts[0].off
    		for _, part := range parts {
    			repeat := int(min(part.n-skipBytes, int64(len(p)-n)))
    			memset(p[n:n+repeat], part.b)
    			n += repeat
    			if n == len(p) {
    				return
    			}
    			skipBytes = 0
    		}
    	}
    	if n != len(p) {
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu May 23 01:00:11 UTC 2024
    - 19.6K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool-decom.go

    		parts := make([]CompletePart, len(objInfo.Parts))
    		for i, part := range objInfo.Parts {
    			hr, err := hash.NewReader(ctx, io.LimitReader(gr, part.Size), part.Size, "", "", part.ActualSize)
    			if err != nil {
    				return fmt.Errorf("decommissionObject: hash.NewReader() %w", err)
    			}
    			pi, err := z.PutObjectPart(ctx, bucket, objInfo.Name, res.UploadID,
    				part.Number,
    				NewPutObjReader(hr),
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 13:20:19 UTC 2024
    - 42.2K bytes
    - Viewed (0)
Back to top