Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for getHashedSet (0.21 sec)

  1. cmd/erasure-sets.go

    }
    
    // NewNSLock - initialize a new namespace RWLocker instance.
    func (s *erasureSets) NewNSLock(bucket string, objects ...string) RWLocker {
    	if len(objects) == 1 {
    		return s.getHashedSet(objects[0]).NewNSLock(bucket, objects...)
    	}
    	return s.getHashedSet("").NewNSLock(bucket, objects...)
    }
    
    // SetDriveCount returns the current drives per set.
    func (s *erasureSets) SetDriveCount() int {
    	return s.setDriveCount
    }
    
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Apr 15 08:25:46 GMT 2024
    - 37.5K bytes
    - Viewed (5)
  2. 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)
    		}
    	}
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Mon Feb 12 07:21:56 GMT 2024
    - 6.9K bytes
    - Viewed (0)
  3. 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
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Wed Mar 27 15:10:40 GMT 2024
    - 47.6K bytes
    - Viewed (0)
  4. 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 {
    Go
    - Registered: Sun Apr 21 19:28:08 GMT 2024
    - Last Modified: Fri Apr 19 16:44:59 GMT 2024
    - 77.8K bytes
    - Viewed (0)
Back to top