Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for RenameFile (0.11 sec)

  1. cmd/naughty-disk_test.go

    		return nil, err
    	}
    	return d.disk.ReadParts(ctx, bucket, partMetaPaths...)
    }
    
    func (d *naughtyDisk) RenameFile(ctx context.Context, srcVolume, srcPath, dstVolume, dstPath string) error {
    	if err := d.calcError(); err != nil {
    		return err
    	}
    	return d.disk.RenameFile(ctx, srcVolume, srcPath, dstVolume, dstPath)
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  2. cmd/storage-interface.go

    	CreateFile(ctx context.Context, origvolume, olume, path string, size int64, reader io.Reader) error
    	ReadFileStream(ctx context.Context, volume, path string, offset, length int64) (io.ReadCloser, error)
    	RenameFile(ctx context.Context, srcVolume, srcPath, dstVolume, dstPath string) error
    	RenamePart(ctx context.Context, srcVolume, srcPath, dstVolume, dstPath string, meta []byte) error
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Aug 12 08:38:15 UTC 2024
    - 5.2K bytes
    - Viewed (0)
  3. cmd/storage-rest-client.go

    	readPartsResp := &ReadPartsResp{}
    	if err = readPartsResp.DecodeMsg(rd); err != nil {
    		return nil, toStorageErr(err)
    	}
    
    	return readPartsResp.Infos, nil
    }
    
    // RenameFile - renames a file.
    func (client *storageRESTClient) RenameFile(ctx context.Context, srcVolume, srcPath, dstVolume, dstPath string) (err error) {
    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    	defer cancel()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  4. cmd/storage-rest_test.go

    		{"foo", "yourobject", "bar", "myobject", false},
    		// overwrite.
    		{"foo", "otherobject", "bar", "myobject", false},
    	}
    
    	for i, testCase := range testCases {
    		err := storage.RenameFile(context.Background(), testCase.volumeName, testCase.objectName, testCase.destVolumeName, testCase.destObjectName)
    		expectErr := (err != nil)
    
    		if expectErr != testCase.expectErr {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 22 07:04:48 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    	w := xioutil.NewDeadlineWorker(globalDriveConfig.GetMaxTimeout())
    	return w.Run(func() error { return p.storage.RenamePart(ctx, srcVolume, srcPath, dstVolume, dstPath, meta) })
    }
    
    func (p *xlStorageDiskIDCheck) RenameFile(ctx context.Context, srcVolume, srcPath, dstVolume, dstPath string) (err error) {
    	ctx, done, err := p.TrackDiskHealth(ctx, storageMetricRenameFile, srcVolume, srcPath, dstVolume, dstPath)
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:56:26 UTC 2024
    - 34.5K bytes
    - Viewed (0)
  6. cmd/format-erasure.go

    	})
    
    	// write to unique file.
    	if err = disk.WriteAll(context.TODO(), minioMetaBucket, tmpFormat, formatData); err != nil {
    		return err
    	}
    
    	// Rename file `uuid.json` --> `format.json`.
    	if err = disk.RenameFile(context.TODO(), minioMetaBucket, tmpFormat, minioMetaBucket, formatConfigFile); err != nil {
    		return err
    	}
    
    	disk.SetDiskID(format.Erasure.This)
    	if healID != "" {
    		ctx := context.Background()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  7. cmd/xl-storage_test.go

    	if err != errVolumeNotFound {
    		t.Fatalf("expected: \"Invalid argument error\", got: \"%s\"", err)
    	}
    }
    
    // TestXLStorage xlStorage.RenameFile()
    func TestXLStorageRenameFile(t *testing.T) {
    	// create xlStorage test setup
    	xlStorage, _, err := newXLStorageTestSetup(t)
    	if err != nil {
    		t.Fatalf("Unable to create xlStorage test setup, %s", err)
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 66.7K bytes
    - Viewed (0)
  8. cmd/erasure-multipart.go

    	errs := g.Wait()
    
    	err := reduceWriteQuorumErrs(ctx, errs, objectOpIgnoredErrs, writeQuorum)
    	if err != nil {
    		er.cleanupMultipartPath(ctx, paths...)
    	}
    
    	// We can safely allow RenameFile errors up to len(er.getDisks()) - writeQuorum
    	// otherwise return failure. Cleanup successful renames.
    	return evalDisks(disks, errs), err
    }
    
    // PutObjectPart - reads incoming stream and internally erasure codes
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  9. cmd/storage-rest-server.go

    func (s *storageRESTServer) RenameFileHandler(p *RenameFileHandlerParams) (grid.NoPayload, *grid.RemoteErr) {
    	if !s.checkID(p.DiskID) {
    		return grid.NewNPErr(errDiskNotFound)
    	}
    	return grid.NewNPErr(s.getStorage().RenameFile(context.Background(), p.SrcVolume, p.SrcFilePath, p.DstVolume, p.DstFilePath))
    }
    
    // RenamePartHandler - rename a multipart part from source to destination
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  10. cmd/xl-storage.go

    	parentDir := pathutil.Dir(srcFilePath)
    	s.deleteFile(srcVolumeDir, parentDir, false, false)
    
    	return nil
    }
    
    // RenameFile - rename source path to destination path atomically.
    func (s *xlStorage) RenameFile(ctx context.Context, srcVolume, srcPath, dstVolume, dstPath string) (err error) {
    	srcVolumeDir, err := s.getVolDir(srcVolume)
    	if err != nil {
    		return err
    	}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 91.3K bytes
    - Viewed (0)
Back to top