fix(host,host-deployer): support lvm disk resize (#23335)

- add resize lvm disk support
- support qga online resize disk partitions and filesystems

Author: wanyaoqi

pkg/esxi/handler/handlers.go

@@ -148,7 +148,17 @@ func resizeHandler(ctx context.Context, w http.ResponseWriter, r *http.Request)
 		httperrors.GeneralServerError(ctx, w, err)
 		return
 	}
-	hostutils.DelayTask(ctx, disk.Resize, diskInfo)
+	resizeDiskInfo := &storageman.SDiskResizeInput{
+		DiskInfo: diskInfo,
+	}
+	resizeFunc := func(ctx context.Context, params interface{}) (jsonutils.JSONObject, error) {
+		input, ok := params.(*storageman.SDiskResizeInput)
+		if !ok {
+			return nil, hostutils.ParamsError
+		}
+		return disk.Resize(ctx, input)
+	}
+	hostutils.DelayTask(ctx, resizeFunc, resizeDiskInfo)
 	hostutils.ResponseOk(ctx, w)
 }
 

pkg/hostman/diskutils/deploy_iface/deployer.go

@@ -20,13 +20,14 @@ import (
 )
 
 type IDeployer interface {
-	Connect(desc *apis.GuestDesc) error
+	Connect(desc *apis.GuestDesc, diskId string) error
 	Disconnect() error
 
 	GetPartitions() []fsdriver.IDiskPartition
 	IsLVMPartition() bool
 	Zerofree()
-	ResizePartition() error
+
+	ResizePartition(diskId string, rootPartDev string) error
 	FormatPartition(fs, uuid string, features *apis.FsFeatures) error
 	MakePartition(fs string) error
 
@@ -35,7 +36,7 @@ type IDeployer interface {
 	DetectIsUEFISupport(rootfs fsdriver.IRootFsDriver) bool
 
 	DeployGuestfs(req *apis.DeployParams) (res *apis.DeployGuestFsResponse, err error)
-	ResizeFs() (res *apis.Empty, err error)
+	ResizeFs(req *apis.ResizeFsParams) (res *apis.Empty, err error)
 	FormatFs(req *apis.FormatFsParams) (*apis.Empty, error)
 	SaveToGlance(req *apis.SaveToGlanceParams) (*apis.SaveToGlanceResponse, error)
 	ProbeImageInfo(req *apis.ProbeImageInfoPramas) (*apis.ImageInfo, error)

pkg/hostman/diskutils/fsutils/driver/doc.go

@@ -0,0 +1,15 @@
+// Copyright 2019 Yunion
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package driver // import "yunion.io/x/onecloud/pkg/hostman/diskutils/fsutils/driver"

pkg/hostman/diskutils/fsutils/driver/driver.go

@@ -0,0 +1,87 @@
+// Copyright 2019 Yunion
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package driver
+
+import (
+	"fmt"
+	"io"
+	"io/ioutil"
+
+	"yunion.io/x/onecloud/pkg/util/procutils"
+)
+
+type IFsutilExecDriver interface {
+	Run(name string, args ...string) error
+	Exec(name string, args ...string) ([]byte, error)
+	ExecInputWait(name string, args []string, input []string) (int, string, string, error)
+}
+
+type SProcDriver struct {
+}
+
+func NewProcDriver() IFsutilExecDriver {
+	return new(SProcDriver)
+}
+
+func (*SProcDriver) Exec(name string, args ...string) ([]byte, error) {
+	return procutils.NewCommand(name, args...).Output()
+}
+
+func (*SProcDriver) Run(name string, args ...string) error {
+	return procutils.NewCommand(name, args...).Run()
+}
+
+func (*SProcDriver) ExecInputWait(name string, args []string, input []string) (int, string, string, error) {
+	proc := procutils.NewCommand(name, args...)
+	stdin, err := proc.StdinPipe()
+	if err != nil {
+		return -1, "", "", err
+	}
+	defer stdin.Close()
+
+	outb, err := proc.StdoutPipe()
+	if err != nil {
+		return -1, "", "", err
+	}
+	defer outb.Close()
+
+	errb, err := proc.StderrPipe()
+	if err != nil {
+		return -1, "", "", err
+	}
+	defer errb.Close()
+	if err := proc.Start(); err != nil {
+		return -1, "", "", err
+	}
+	for _, s := range input {
+		io.WriteString(stdin, fmt.Sprintf("%s\n", s))
+	}
+	stdoutPut, err := ioutil.ReadAll(outb)
+	if err != nil {
+		return -1, "", "", err
+	}
+	stderrOutPut, err := ioutil.ReadAll(errb)
+	if err != nil {
+		return -1, "", "", err
+	}
+	if err = proc.Wait(); err != nil {
+		if status, succ := proc.GetExitStatus(err); succ {
+			return status, string(stdoutPut), string(stderrOutPut), err
+		} else {
+			return 0, string(stdoutPut), string(stderrOutPut), err
+		}
+	}
+	return 0, string(stdoutPut), string(stderrOutPut), nil
+}