Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for RenameData (0.3 sec)

  1. cmd/naughty-disk_test.go

    		return err
    	}
    	return d.disk.AppendFile(ctx, volume, path, buf)
    }
    
    func (d *naughtyDisk) RenameData(ctx context.Context, srcVolume, srcPath string, fi FileInfo, dstVolume, dstPath string, opts RenameOptions) (RenameDataResp, error) {
    	if err := d.calcError(); err != nil {
    		return RenameDataResp{}, err
    	}
    	return d.disk.RenameData(ctx, srcVolume, srcPath, fi, dstVolume, dstPath, opts)
    }
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 9.3K bytes
    - Viewed (0)
  2. cmd/storage-interface.go

    	ReadVersion(ctx context.Context, origvolume, volume, path, versionID string, opts ReadOptions) (FileInfo, error)
    	ReadXL(ctx context.Context, volume, path string, readData bool) (RawFileInfo, error)
    	RenameData(ctx context.Context, srcVolume, srcPath string, fi FileInfo, dstVolume, dstPath string, opts RenameOptions) (RenameDataResp, error)
    
    	// File operations.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 4.9K bytes
    - Viewed (0)
  3. cmd/storage-rest-client.go

    		DiskID:   *client.diskID.Load(),
    		Volume:   volume,
    		FilePath: path,
    		FI:       fi,
    	})
    	return toStorageErr(err)
    }
    
    // RenameData - rename source path to destination path atomically, metadata and data file.
    func (client *storageRESTClient) RenameData(ctx context.Context, srcVolume, srcPath string, fi FileInfo,
    	dstVolume, dstPath string, opts RenameOptions,
    ) (res RenameDataResp, err error) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 26.1K bytes
    - Viewed (0)
  4. cmd/xl-storage-disk-id-check.go

    	w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    	return w.Run(func() error { return p.storage.RenameFile(ctx, srcVolume, srcPath, dstVolume, dstPath) })
    }
    
    func (p *xlStorageDiskIDCheck) RenameData(ctx context.Context, srcVolume, srcPath string, fi FileInfo, dstVolume, dstPath string, opts RenameOptions) (res RenameDataResp, err error) {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 33K bytes
    - Viewed (0)
  5. cmd/erasure-object.go

    		return objInfo, wquorum, toObjectErr(errMethodNotAllowed, bucket, object)
    	}
    
    	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))
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 76.9K bytes
    - Viewed (2)
  6. cmd/xl-storage.go

    		minioMetaBucket,
    	} {
    		if strings.HasPrefix(volume, prefix) {
    			return true
    		}
    	}
    	return ok
    }
    
    // RenameData - rename source path to destination path atomically, metadata and data directory.
    func (s *xlStorage) RenameData(ctx context.Context, srcVolume, srcPath string, fi FileInfo, dstVolume, dstPath string, opts RenameOptions) (res RenameDataResp, err error) {
    	defer func() {
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 84.7K bytes
    - Viewed (0)
  7. cmd/storage-datatypes.go

    type WriteAllHandlerParams struct {
    	DiskID   string `msg:"id"`
    	Volume   string `msg:"v"`
    	FilePath string `msg:"fp"`
    	Buf      []byte `msg:"b"`
    }
    
    // RenameDataResp - RenameData()'s response.
    // Provides information about the final state of Rename()
    //   - on xl.meta (array of versions) on disk to check for version disparity
    //   - on rewrite dataDir on disk that must be additionally purged
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 17:15:52 GMT 2024
    - 15.3K bytes
    - Viewed (0)
  8. cmd/xl-storage-format-v2.go

    				// Skip tierFVID, tierFVMarker keys; it's used
    				// only for creating free-version.
    				// Also skip xMinIOHealing, xMinIODataMov as used only in RenameData
    				switch k {
    				case tierFVIDKey, tierFVMarkerKey, xMinIOHealing, xMinIODataMov:
    					continue
    				}
    
    				ventry.ObjectV2.MetaSys[k] = []byte(v)
    			} else {
    				ventry.ObjectV2.MetaUser[k] = v
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Tue Apr 23 05:07:37 GMT 2024
    - 63.6K bytes
    - Viewed (1)
  9. cmd/erasure-healing.go

    		}
    
    		// record the index of the updated disks
    		partsMetadata[i].Erasure.Index = i + 1
    
    		// Attempt a rename now from healed data to final location.
    		partsMetadata[i].SetHealing()
    
    		if _, err = disk.RenameData(ctx, minioMetaTmpBucket, tmpID, partsMetadata[i], bucket, object, RenameOptions{}); err != nil {
    			return result, err
    		}
    
    		// - Remove any remaining parts from outdated disks from before transition.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 33.1K bytes
    - Viewed (0)
  10. cmd/erasure-multipart.go

    		if err == nil {
    			er.deleteAll(context.Background(), minioMetaMultipartBucket, uploadIDPath)
    		}
    	}()
    
    	// Rename the multipart object to final location.
    	onlineDisks, versions, oldDataDir, err := renameData(ctx, onlineDisks, minioMetaMultipartBucket, uploadIDPath,
    		partsMetadata, bucket, object, writeQuorum)
    	if err != nil {
    		return oi, toObjectErr(err, bucket, object, uploadID)
    	}
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
Back to top