Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for StorageAPI (0.21 sec)

  1. cmd/erasure-object.go

    	return objInfo, wquorum, nil
    }
    
    // Similar to rename but renames data from srcEntry to dstEntry at dataDir
    func renameData(ctx context.Context, disks []StorageAPI, srcBucket, srcEntry string, metadata []FileInfo, dstBucket, dstEntry string, writeQuorum int) ([]StorageAPI, []byte, string, error) {
    	g := errgroup.WithNErrs(len(disks))
    
    	fvID := mustGetUUID()
    	for index := range disks {
    		metadata[index].SetTierFreeVersionID(fvID)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
  2. cmd/erasure-server-pool.go

    }
    
    // GetDisksID will return disks by their ID.
    func (z *erasureServerPools) GetDisksID(ids ...string) []StorageAPI {
    	idMap := make(map[string]struct{})
    	for _, id := range ids {
    		idMap[id] = struct{}{}
    	}
    	res := make([]StorageAPI, 0, len(idMap))
    	for _, s := range z.serverPools {
    		for _, set := range s.sets {
    			for _, disk := range set.getDisks() {
    				if disk == OfflineDisk {
    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)
  3. cmd/test-utils_test.go

    func initObjectLayer(ctx context.Context, endpointServerPools EndpointServerPools) (ObjectLayer, []StorageAPI, error) {
    	objLayer, err := newTestObjectLayer(ctx, endpointServerPools)
    	if err != nil {
    		return nil, nil, err
    	}
    
    	var formattedDisks []StorageAPI
    	// Should use the object layer tests for validating cache.
    	if z, ok := objLayer.(*erasureServerPools); ok {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 17:26:51 GMT 2024
    - 76.2K bytes
    - Viewed (0)
  4. cmd/xl-storage.go

    	}
    
    	if runtime.GOOS == "windows" {
    		// Volname shouldn't have reserved characters in Windows.
    		return !strings.ContainsAny(volname, `\:*?\"<>|`)
    	}
    
    	return true
    }
    
    // xlStorage - implements StorageAPI interface.
    type xlStorage struct {
    	// Indicate of NSScanner is in progress in this disk
    	scanning int32
    
    	drivePath string
    	endpoint  Endpoint
    
    	globalSync bool
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  5. cmd/object-api-multipart_test.go

    	z := obj.(*erasureServerPools)
    	er := z.serverPools[0].sets[0]
    
    	erasureDisks := er.getDisks()
    	ridx := rand.Intn(len(erasureDisks))
    
    	z.serverPools[0].erasureDisksMu.Lock()
    	er.getDisks = func() []StorageAPI {
    		erasureDisks[ridx] = newNaughtyDisk(erasureDisks[ridx], nil, errFaultyDisk)
    		return erasureDisks
    	}
    	z.serverPools[0].erasureDisksMu.Unlock()
    
    	uploadIDs = append(uploadIDs, res.UploadID)
    
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Feb 22 06:26:06 GMT 2024
    - 77.1K bytes
    - Viewed (0)
  6. cmd/xl-storage_test.go

    		}
    	}
    
    	// TestXLStorage for permission denied.
    	if runtime.GOOS != globalWindowsOSName {
    		permDeniedDir := createPermDeniedFile(t)
    
    		var xlStoragePermStorage StorageAPI
    		// Initialize xlStorage storage layer for permission denied error.
    		_, err = newLocalXLStorage(permDeniedDir)
    		if err != nil && err != errDiskAccessDenied {
    			t.Fatalf("Unable to initialize xlStorage, %s", err)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Apr 11 17:45:28 GMT 2024
    - 66.7K bytes
    - Viewed (0)
Back to top