Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 22 for mustGetUUID (0.06 sec)

  1. cmd/format-erasure_test.go

    	m := &formatErasureV1{}
    	m.Format = formatBackendErasure
    	m.Version = formatMetaVersionV1
    	m.Erasure.Version = formatErasureVersionV1
    	m.Erasure.Disk = mustGetUUID()
    	m.Erasure.JBOD = []string{m.Erasure.Disk, mustGetUUID(), mustGetUUID(), mustGetUUID()}
    
    	b, err := json.Marshal(m)
    	if err != nil {
    		t.Fatal(err)
    	}
    
    	if err = os.MkdirAll(pathJoin(rootPath, minioMetaBucket), os.FileMode(0o755)); err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 12.7K bytes
    - Viewed (0)
  2. cmd/local-locker_test.go

    		arg := dsync.LockArgs{
    			UID:       mustGetUUID(),
    			Resources: []string{mustGetUUID()},
    			Source:    t.Name(),
    			Owner:     "owner",
    			Quorum:    &quorum,
    		}
    		ok, err := l.Lock(ctx, arg)
    		if err != nil {
    			t.Fatal(err)
    		}
    		if !ok {
    			t.Fatal("did not get write lock")
    		}
    		wResources[i] = arg.Resources[0]
    	}
    	for i := range rResources {
    		name := mustGetUUID()
    		arg := dsync.LockArgs{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.8K bytes
    - Viewed (0)
  3. cmd/admin-handlers_test.go

    		lri := lockRequesterInfo{
    			Name:   resource,
    			UID:    mustGetUUID(),
    			Owner:  owners[i%len(owners)],
    			Quorum: 2,
    		}
    		lris = append(lris, lri)
    		locksHeld[resource] = append(locksHeld[resource], lri)
    		// concurrent read lock, same resource different uid
    		lri.UID = mustGetUUID()
    		lris = append(lris, lri)
    		locksHeld[resource] = append(locksHeld[resource], lri)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.9K bytes
    - Viewed (1)
  4. cmd/erasure-metadata_test.go

    		remoteVersionID string
    		status          string
    	}{
    		{
    			tier:            "S3TIER-1",
    			remoteObjName:   mustGetUUID(),
    			remoteVersionID: mustGetUUID(),
    			status:          "complete",
    		},
    		{
    			tier:            "S3TIER-2",
    			remoteObjName:   mustGetUUID(),
    			remoteVersionID: mustGetUUID(),
    			status:          "complete",
    		},
    	}
    
    	var i uint
    	for i = range uint(8) {
    		fi := FileInfo{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.4K bytes
    - Viewed (0)
  5. cmd/xl-storage-format-v2_test.go

    				Hash:       nil,
    			}},
    		},
    		MarkDeleted:      false,
    		Data:             data,
    		NumVersions:      1,
    		SuccessorModTime: time.Time{},
    	}
    
    	d0, d1, d2 := mustGetUUID(), mustGetUUID(), mustGetUUID()
    	testCases := []struct {
    		versionID        string
    		dataDir          string
    		data             []byte
    		shares           int
    		transitionStatus string
    		restoreObjStatus string
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 37.8K bytes
    - Viewed (0)
  6. cmd/metacache-server-pool.go

    	return readDirFn(pathJoin(epPath, minioMetaBucket, bucketMetaPrefix), func(name string, typ os.FileMode) error {
    		if typ == os.ModeDir {
    			tmpMetacacheOld := pathutil.Join(epPath, minioMetaTmpDeletedBucket, mustGetUUID())
    			if err := renameAll(pathJoin(epPath, minioMetaBucket, metacachePrefixForID(name, slashSeparator)),
    				tmpMetacacheOld, epPath); err != nil && err != errFileNotFound {
    				return fmt.Errorf("unable to rename (%s -> %s) %w",
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Mon May 26 07:06:43 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  7. cmd/xl-storage-format_test.go

    		b.Run(fmt.Sprint(size, "-versions"), func(b *testing.B) {
    			var xl xlMetaV2
    			ids := make([]string, size)
    			for i := range size {
    				fi.VersionID = mustGetUUID()
    				fi.DataDir = mustGetUUID()
    				ids[i] = fi.VersionID
    				fi.ModTime = fi.ModTime.Add(-time.Second)
    				xl.AddVersion(fi)
    			}
    			// Encode all. This is used for benchmarking.
    			enc, err := xl.AppendTo(nil)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  8. cmd/format-erasure.go

    	}
    	format.ID = mustGetUUID()
    	format.Erasure.Version = formatErasureVersionV3
    	format.Erasure.DistributionAlgo = formatErasureVersionV3DistributionAlgoV3
    	format.Erasure.Sets = make([][]string, numSets)
    
    	for i := range numSets {
    		format.Erasure.Sets[i] = make([]string, setLen)
    		for j := range setLen {
    			format.Erasure.Sets[i][j] = mustGetUUID()
    		}
    	}
    	return format
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 23.1K bytes
    - Viewed (0)
  9. cmd/erasure-multipart.go

    	fi := newFileInfo(pathJoin(bucket, object), dataDrives, parityDrives)
    	fi.VersionID = opts.VersionID
    	if opts.Versioned && fi.VersionID == "" {
    		fi.VersionID = mustGetUUID()
    	}
    	fi.DataDir = mustGetUUID()
    
    	if ckSum := userDefined[ReplicationSsecChecksumHeader]; ckSum != "" {
    		v, err := base64.StdEncoding.DecodeString(ckSum)
    		if err == nil {
    			fi.Checksum = v
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  10. cmd/bucket-replication-handlers.go

    	vars := mux.Vars(r)
    	bucket := vars["bucket"]
    	durationStr := r.URL.Query().Get("older-than")
    	arn := r.URL.Query().Get("arn")
    	resetID := r.URL.Query().Get("reset-id")
    	if resetID == "" {
    		resetID = mustGetUUID()
    	}
    	var (
    		days time.Duration
    		err  error
    	)
    	if durationStr != "" {
    		days, err = time.ParseDuration(durationStr)
    		if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 23.3K bytes
    - Viewed (0)
Back to top