@@ -11,36 +11,35 @@ import (
11
11
"path/filepath"
12
12
13
13
"github.com/docker/go-units"
14
-
15
- "github.com/lima-vm/lima/pkg/driver"
16
14
"github.com/lima-vm/lima/pkg/fileutils"
17
15
"github.com/lima-vm/lima/pkg/iso9660util"
18
16
"github.com/lima-vm/lima/pkg/nativeimgutil"
17
+ "github.com/lima-vm/lima/pkg/store"
19
18
"github.com/lima-vm/lima/pkg/store/filenames"
20
19
)
21
20
22
- func EnsureDisk (ctx context.Context , driver * driver. BaseDriver ) error {
23
- diffDisk := filepath .Join (driver . Instance .Dir , filenames .DiffDisk )
21
+ func EnsureDisk (ctx context.Context , inst * store. Instance ) error {
22
+ diffDisk := filepath .Join (inst .Dir , filenames .DiffDisk )
24
23
if _ , err := os .Stat (diffDisk ); err == nil || ! errors .Is (err , os .ErrNotExist ) {
25
24
// disk is already ensured
26
25
return err
27
26
}
28
27
29
- baseDisk := filepath .Join (driver . Instance .Dir , filenames .BaseDisk )
30
- kernel := filepath .Join (driver . Instance .Dir , filenames .Kernel )
31
- kernelCmdline := filepath .Join (driver . Instance .Dir , filenames .KernelCmdline )
32
- initrd := filepath .Join (driver . Instance .Dir , filenames .Initrd )
28
+ baseDisk := filepath .Join (inst .Dir , filenames .BaseDisk )
29
+ kernel := filepath .Join (inst .Dir , filenames .Kernel )
30
+ kernelCmdline := filepath .Join (inst .Dir , filenames .KernelCmdline )
31
+ initrd := filepath .Join (inst .Dir , filenames .Initrd )
33
32
if _ , err := os .Stat (baseDisk ); errors .Is (err , os .ErrNotExist ) {
34
33
var ensuredBaseDisk bool
35
- errs := make ([]error , len (driver . Instance .Config .Images ))
36
- for i , f := range driver . Instance .Config .Images {
37
- if _ , err := fileutils .DownloadFile (ctx , baseDisk , f .File , true , "the image" , * driver . Instance .Config .Arch ); err != nil {
34
+ errs := make ([]error , len (inst .Config .Images ))
35
+ for i , f := range inst .Config .Images {
36
+ if _ , err := fileutils .DownloadFile (ctx , baseDisk , f .File , true , "the image" , * inst .Config .Arch ); err != nil {
38
37
errs [i ] = err
39
38
continue
40
39
}
41
40
if f .Kernel != nil {
42
41
// ensure decompress kernel because vz expects it to be decompressed
43
- if _ , err := fileutils .DownloadFile (ctx , kernel , f .Kernel .File , true , "the kernel" , * driver . Instance .Config .Arch ); err != nil {
42
+ if _ , err := fileutils .DownloadFile (ctx , kernel , f .Kernel .File , true , "the kernel" , * inst .Config .Arch ); err != nil {
44
43
errs [i ] = err
45
44
continue
46
45
}
@@ -52,7 +51,7 @@ func EnsureDisk(ctx context.Context, driver *driver.BaseDriver) error {
52
51
}
53
52
}
54
53
if f .Initrd != nil {
55
- if _ , err := fileutils .DownloadFile (ctx , initrd , * f .Initrd , false , "the initrd" , * driver . Instance .Config .Arch ); err != nil {
54
+ if _ , err := fileutils .DownloadFile (ctx , initrd , * f .Initrd , false , "the initrd" , * inst .Config .Arch ); err != nil {
56
55
errs [i ] = err
57
56
continue
58
57
}
@@ -64,7 +63,7 @@ func EnsureDisk(ctx context.Context, driver *driver.BaseDriver) error {
64
63
return fileutils .Errors (errs )
65
64
}
66
65
}
67
- diskSize , _ := units .RAMInBytes (* driver . Instance .Config .Disk )
66
+ diskSize , _ := units .RAMInBytes (* inst .Config .Disk )
68
67
if diskSize == 0 {
69
68
return nil
70
69
}
0 commit comments