- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for getHashedSet (0.11 sec)
-
cmd/erasure-sets.go
set := s.getHashedSet(object) return set.GetObjectNInfo(ctx, bucket, object, rs, h, opts) } // PutObject - writes an object to hashedSet based on the object name. func (s *erasureSets) PutObject(ctx context.Context, bucket string, object string, data *PutObjReader, opts ObjectOptions) (objInfo ObjectInfo, err error) { set := s.getHashedSet(object)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 27 10:41:37 UTC 2024 - 37K bytes - Viewed (1) -
cmd/erasure-sets_test.go
{"a/b/c/", objs[1]}, {"/a/b/c", objs[4]}, {string([]byte{0xff, 0xfe, 0xfd}), objs[13]}, } // Tests hashing order to be consistent. for i, testCase := range testCases { gotObj := sets.getHashedSet(testCase.objectName) if gotObj != testCase.expectedObj { t.Errorf("Test case %d: Expected \"%#v\" but failed \"%#v\"", i+1, testCase.expectedObj, gotObj) } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Feb 12 07:21:56 UTC 2024 - 6.9K bytes - Viewed (0) -
cmd/erasure-healing_test.go
_, err = io.Copy(actualH, bytes.NewReader(data)) if err != nil { return } actualSha256 := actualH.Sum(nil) z := obj.(*erasureServerPools) er := z.serverPools[0].getHashedSet(object) disks := er.getDisks() distribution := hashOrder(pathJoin(bucket, object), nDisks) shuffledDisks := shuffleDisks(disks, distribution) // remove last data shard
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Jun 10 15:51:27 UTC 2024 - 49K bytes - Viewed (0) -
cmd/erasure-server-pool.go
continue } pool := z.serverPools[index] nSets[index] = pool.setCount g.Go(func() error { // Get the set where it would be placed. storageInfos[index] = getDiskInfos(ctx, pool.getHashedSet(object).getDisks()...) return nil }, index) } // Wait for the go routines. g.Wait() for i, zinfo := range storageInfos { if zinfo == nil {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Sep 29 22:40:36 UTC 2024 - 89.8K bytes - Viewed (0)