备份节点 检查硬盘状态

pkg/app/raspberryChan.go

@@ -9,6 +9,8 @@ import (
 	"os"
 	"os/exec"
 	"time"
+	"strings"
+	"strconv"
 )
 
 var (
@@ -149,6 +151,10 @@ func backup() error {
 	if BityuanFlag.Flag {
 		return errors.New("env err")
 	}
+	check := checkDiskStatus()
+	if !check {
+		return errors.New("disk not aviable")
+	}
 	BityuanFlag.Flag = true
 	ok, err := SafeCloseNode()
 	if err != nil {
@@ -179,6 +185,28 @@ func backup() error {
 	return nil
 }
 
+func checkDiskStatus() bool {
+	var pai pai_service.Pai
+	err := pai.GetDiskUseage()
+	if err != nil {
+		tlog.Error("GetDiskUseage", "err", err)
+		return false
+	}
+	if len(pai.Disks) == 0 {
+		tlog.Error("disk ", "err", "disk not find")
+		return false
+	}
+	tlog.Info("disk info", "ssd", pai.Disks[0])
+	p := pai.Disks[0].Use
+	ps := strings.Split(p, "%")
+	pint, _ := strconv.Atoi(ps[0])
+	if pint*2 > 80 {
+		tlog.Error("disk space ", "err", "space not enough to backup")
+		return false
+	}
+	return true
+}
+
 func SafeBackup() error {
 	s := time.Now()
 	defer func() {