fanhuadesenlinnn/cloudpods
1
0
Fork 0
mirror of https://hubproxy.babadafafafafa.cn/https://github.com/yunionio/cloudpods.git synced 2026-09-20 08:03:53 +08:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #15177 from swordqiu/hotfix/qj-disk-fallocate-support

Browse Source 
fix: disk fallocate support
This commit is contained in:
Zexi Li
2022-10-13 09:47:38 +08:00
committed by GitHub
parent 9952c9ad8d a38d0e2d05
commit bcf52f3db4
1 changed files with 24 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
pkg/hostman/storageman/disk_local.go
View File

@@ -187,8 +187,10 @@ func (d *SLocalDisk) Resize(ctx context.Context, params interface{}) (jsonutils.
}
}
if options.HostOptions.EnableFallocateDisk {
// TODO
// d.Fallocate()
err := d.fallocate()
if err != nil {
log.Errorf("fallocate fail %s", err)
}
}
if err := d.ResizeFs(resizeFsInfo); err != nil {
@@ -304,8 +306,10 @@ func (d *SLocalDisk) CreateFromUrl(ctx context.Context, url string, size int64,
return errors.Wrapf(err, "fetch image from %s", url)
}
if options.HostOptions.EnableFallocateDisk {
//TODO
// d.fallocate()
err := d.fallocate()
if err != nil {
log.Errorf("fallocate fail %s", err)
}
}
return nil
}
@@ -340,8 +344,10 @@ func (d *SLocalDisk) CreateRaw(ctx context.Context, sizeMB int, diskFormat, fsFo
}
if options.HostOptions.EnableFallocateDisk {
// TODO
// d.Fallocate
err := d.fallocate()
if err != nil {
log.Errorf("fallocate fail %s", err)
}
}
diskInfo := &deployapi.DiskInfo{
@@ -705,3 +711,15 @@ func (d *SLocalDisk) DoDeleteSnapshot(snapshotId string) error {
func (d *SLocalDisk) IsFile() bool {
return true
}
func (d *SLocalDisk) fallocate() error {
img, err := qemuimg.NewQemuImage(d.GetPath())
if err != nil {
return errors.Wrap(err, "NewQemuImage")
}
err = img.Fallocate()
if err != nil {
return errors.Wrap(err, "Fallocate")
}
return nil
}