- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 100 for Sets (0.13 sec)
-
cmd/erasure-sets.go
func (s *erasureSets) StorageInfo(ctx context.Context) StorageInfo { var storageInfo madmin.StorageInfo storageInfos := make([]madmin.StorageInfo, len(s.sets)) g := errgroup.WithNErrs(len(s.sets)) for index := range s.sets { index := index g.Go(func() error { storageInfos[index] = s.sets[index].StorageInfo(ctx) return nil }, index) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 37.7K bytes - Viewed (5) -
cmd/erasure-sets_test.go
// consistently for a given object name. func TestHashedLayer(t *testing.T) { // Test distribution with 16 sets. var objs [16]*erasureObjects for i := range objs { objs[i] = &erasureObjects{} } sets := &erasureSets{sets: objs[:], distributionAlgo: "CRCMOD"} testCases := []struct { objectName string expectedObj *erasureObjects }{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Feb 12 07:21:56 GMT 2024 - 6.9K bytes - Viewed (0) -
cmd/erasure-object_test.go
if err != nil { t.Fatal(err) } // Cleanup backend directories. defer obj.Shutdown(context.Background()) defer removeRoots(fsDirs) z := obj.(*erasureServerPools) sets := z.serverPools[0] xl := sets.sets[0] origErasureDisks := xl.getDisks() testCases := []struct { bucket string versioned bool object string content []byte }{
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Tue Jan 30 20:43:25 GMT 2024 - 36.8K bytes - Viewed (0) -
docs/debugging/reorder-disks/main.go
"flag" "fmt" "log" "net/url" "os" "path/filepath" "strings" "syscall" "github.com/minio/pkg/v2/ellipses" ) type xl struct { This string `json:"this"` Sets [][]string `json:"sets"` } type format struct { ID string `json:"id"` XL xl `json:"xl"` } func getMountMap() (map[string]string, error) { result := make(map[string]string)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Jan 18 07:03:17 GMT 2024 - 5.4K bytes - Viewed (0) -
cmd/erasure-server-pool.go
// Return the disks belonging to the poolIdx, and setIdx. func (z *erasureServerPools) GetDisks(poolIdx, setIdx int) ([]StorageAPI, error) { if poolIdx < len(z.serverPools) && setIdx < len(z.serverPools[poolIdx].sets) { return z.serverPools[poolIdx].sets[setIdx].getDisks(), nil } return nil, fmt.Errorf("Matching pool %s, set %s not found", humanize.Ordinal(poolIdx+1), humanize.Ordinal(setIdx+1)) } // Return the count of disks in each pool
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 80.5K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
workerSize, err := env.GetInt(envRebalanceWorkers, len(pool.sets)) if err != nil { rebalanceLogIf(ctx, fmt.Errorf("invalid workers value err: %v, defaulting to %d", err, len(pool.sets))) workerSize = len(pool.sets) } // Each decom worker needs one List() goroutine/worker // add that many extra workers. workerSize += len(pool.sets) wk, err := workers.New(workerSize) if err != nil { return err
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri Apr 26 19:29:28 GMT 2024 - 27.2K bytes - Viewed (0) -
cmd/format-erasure.go
tmpFormat.Erasure.This = "" if len(reference.Erasure.Sets) != len(format.Erasure.Sets) { return fmt.Errorf("Expected number of sets %d, got %d", len(reference.Erasure.Sets), len(format.Erasure.Sets)) } // Make sure that the sets match. for i := range reference.Erasure.Sets { if len(reference.Erasure.Sets[i]) != len(format.Erasure.Sets[i]) { return fmt.Errorf("Each set should be of same size, expected %d got %d",
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 15:54:03 GMT 2024 - 23.2K bytes - Viewed (0) -
cmd/bucket-targets.go
sys.hMutex.RLock() defer sys.hMutex.RUnlock() if h, ok := sys.hc[ep.Host]; ok { return !h.Online } go sys.initHC(ep) return false } // markOffline sets endpoint to offline if network i/o timeout seen. func (sys *BucketTargetSys) markOffline(ep *url.URL) { sys.hMutex.Lock() defer sys.hMutex.Unlock() if h, ok := sys.hc[ep.Host]; ok { h.Online = false
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed May 01 01:09:56 GMT 2024 - 20.9K bytes - Viewed (0) -
cmd/format-erasure_test.go
} if len(formatV3.Erasure.Sets) != 1 { t.Fatalf("expected single set after migrating from v1 to v3, but found %d", len(formatV3.Erasure.Sets)) } if !reflect.DeepEqual(formatV3.Erasure.Sets[0], m.Erasure.JBOD) { t.Fatalf("expected drive uuid: %v, got: %v", m.Erasure.JBOD, formatV3.Erasure.Sets[0]) } m = &formatErasureV1{} m.Format = "unknown"
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Mon Apr 15 08:25:46 GMT 2024 - 12.9K bytes - Viewed (0) -
cmd/iam.go
if !sys.Initialized() { return nil, errServerNotInitialized } return sys.store.ListPolicyDocs(ctx, bucketName) } // SetPolicy - sets a new named policy. func (sys *IAMSys) SetPolicy(ctx context.Context, policyName string, p policy.Policy) (time.Time, error) { if !sys.Initialized() { return time.Time{}, errServerNotInitialized }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 25 21:28:16 GMT 2024 - 71.1K bytes - Viewed (1)