Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for partNums (0.11 sec)

  1. cmd/erasure-multipart.go

    				continue
    			}
    			partQuorumMap[partNum]++
    		}
    	}
    
    	var partNums []int
    	for partNum, count := range partQuorumMap {
    		if count < readQuorum {
    			continue
    		}
    		partNums = append(partNums, partNum)
    	}
    
    	sort.Ints(partNums)
    	return partNums, nil
    }
    
    // ListObjectParts - lists all previously uploaded parts for a given
    // object and uploadID.  Takes additional input of part-number-marker
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  2. docs/debugging/xl-meta/main.go

    	names := make([][]string, 0)
    	/// part, verID, file
    	files := make([]map[string][]string, 0)
    	partNums := make(map[int]int)
    	for k, v := range all {
    		for _, file := range v {
    			part := getPartNum(file)
    			partIdx, ok := partNums[part]
    			if !ok {
    				partIdx = len(names)
    				partNums[part] = partIdx
    				names = append(names, nil)
    				files = append(files, make(map[string][]string))
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 05 11:57:44 UTC 2024
    - 40.3K bytes
    - Viewed (0)
  3. cmd/xl-storage-format-v2_gen.go

    				var zb0004 uint8
    				zb0004, err = dc.ReadUint8()
    				if err != nil {
    					err = msgp.WrapError(err, "BitrotChecksumAlgo")
    					return
    				}
    				z.BitrotChecksumAlgo = ChecksumAlgo(zb0004)
    			}
    		case "PartNums":
    			var zb0005 uint32
    			zb0005, err = dc.ReadArrayHeader()
    			if err != nil {
    				err = msgp.WrapError(err, "PartNumbers")
    				return
    			}
    			if cap(z.PartNumbers) >= int(zb0005) {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 55.5K bytes
    - Viewed (0)
  4. cmd/xl-storage-format-v2.go

    	BitrotChecksumAlgo ChecksumAlgo      `json:"CSumAlgo" msg:"CSumAlgo"`                        // Bitrot checksum algo
    	PartNumbers        []int             `json:"PartNums" msg:"PartNums"`                        // Part Numbers
    	PartETags          []string          `json:"PartETags" msg:"PartETags,allownil"`             // Part ETags
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 64K bytes
    - Viewed (1)
  5. cmd/erasure-metadata_test.go

    	for _, testCase := range testCases {
    		if testCase.expectedIndex > -1 {
    			partNumString := strconv.Itoa(testCase.partNum)
    			fi.AddObjectPart(testCase.partNum, "etag."+partNumString, int64(testCase.partNum+humanize.MiByte), ActualSize, UTCNow(), nil, nil)
    		}
    
    		if index := objectPartIndex(fi.Parts, testCase.partNum); index != testCase.expectedIndex {
    			t.Fatalf("%+v: expected = %d, got: %d", testCase, testCase.expectedIndex, index)
    		}
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Jul 25 21:02:50 UTC 2024
    - 13.5K bytes
    - Viewed (0)
  6. cmd/object-handlers_test.go

    		}
    	}
    
    	for idx, oi := range objectInputs {
    		for partNum := 1; partNum <= len(oi.partLengths); partNum++ {
    			mkGetReqWithPartNumber(idx, oi, partNum)
    		}
    	}
    }
    
    // Wrapper for calling PutObject API handler tests using streaming signature v4 for both Erasure multiple disks and FS single drive setup.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 12 20:10:44 UTC 2024
    - 163.2K bytes
    - Viewed (0)
  7. cmd/xl-storage.go

    // For any unexpected error, return checkPartUnknown (zero)
    func (s *xlStorage) checkPart(volumeDir, path, dataDir string, partNum int, expectedSize int64, skipAccessCheck bool) (resp int) {
    	partPath := pathJoin(path, dataDir, fmt.Sprintf("part.%d", partNum))
    	filePath := pathJoin(volumeDir, partPath)
    	st, err := Lstat(filePath)
    	if err != nil {
    		if osIsNotExist(err) {
    			if !skipAccessCheck {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
  8. cmd/bucket-replication.go

    		http.CanonicalHeaderKey(key),
    	} {
    		v, ok := m[k]
    		if ok {
    			return v, ok
    		}
    	}
    	return "", false
    }
    
    func putReplicationOpts(ctx context.Context, sc string, objInfo ObjectInfo, partNum int) (putOpts minio.PutObjectOptions, err error) {
    	meta := make(map[string]string)
    	isSSEC := crypto.SSEC.IsEncrypted(objInfo.UserDefined)
    
    	for k, v := range objInfo.UserDefined {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
Back to top