- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for partNums (0.11 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)