Support THP in tiup cluster check (#964)

* Support THP in tiup cluster check

* fix typo

* update err msg

* Update auto fix prompt message

Co-authored-by: SIGSEGV <gnu.crazier@gmail.com>
Co-authored-by: Ti Prow Robot <71242396+ti-community-prow-bot@users.noreply.github.com>

components/cluster/command/check.go

@@ -442,6 +442,11 @@ func fixFailedChecks(ctx *task.Context, host string, res *operator.CheckResult,
 			),
 			true)
 		msg = fmt.Sprintf("will try to %s, reboot might be needed", color.HiBlueString("disable SELinux"))
+	case operator.CheckNameTHP:
+		t.Shell(host,
+			"echo never > /sys/kernel/mm/transparent_hugepage/enabled && echo never > /sys/kernel/mm/transparent_hugepage/defrag",
+			true)
+		msg = fmt.Sprintf("will try to %s, please check again after reboot", color.HiBlueString("disable THP"))
 	default:
 		msg = fmt.Sprintf("%s, auto fixing not supported", res)
 	}

pkg/cluster/operation/check.go

@@ -58,6 +58,7 @@ var (
 	CheckNameSELinux     = "selinux"
 	CheckNameCommand     = "command"
 	CheckNameFio         = "fio"
+	CheckNameTHP         = "thp"
 )
 
 // CheckResult is the result of a check
@@ -651,3 +652,30 @@ func CheckFIOResult(rr, rw, lat []byte) []*CheckResult {
 
 	return results
 }
+
+// CheckTHP checks THP in /sys/kernel/mm/transparent_hugepage/{enabled,defrag}
+func CheckTHP(e executor.Executor) *CheckResult {
+	result := &CheckResult{
+		Name: CheckNameTHP,
+	}
+
+	m := module.NewShellModule(module.ShellModuleConfig{
+		Command: "cat /sys/kernel/mm/transparent_hugepage/{enabled,defrag}",
+		Sudo:    false,
+	})
+	stdout, stderr, err := m.Execute(e)
+	if err != nil {
+		result.Err = fmt.Errorf("%w %s", err, stderr)
+		return result
+	}
+
+	for _, line := range strings.Split(string(stdout), "\n") {
+		if !strings.Contains(line, "[never]") {
+			result.Err = fmt.Errorf("THP is enabled, please disable it for best performance")
+			return result
+		}
+	}
+
+	result.Msg = "THP is disabled"
+	return result
+}

pkg/cluster/task/check.go

@@ -70,6 +70,7 @@ func (c *CheckSys) Execute(ctx *Context) error {
 		results = append(
 			results,
 			operator.CheckSELinux(e),
+			operator.CheckTHP(e),
 		)
 		ctx.SetCheckResults(c.host, results)
 	case CheckTypePort:

tests/tiup-cluster/script/cmd_subtest.sh

@@ -29,6 +29,7 @@ function cmd_subtest() {
     echo $check_result | grep "os-version"
     echo $check_result | grep "selinux"
     echo $check_result | grep "service"
+    echo $check_result | grep "thp"
 
     # This should fail because there is no such user: tidb
     ! tiup-cluster $client --yes deploy $name $version $topo -i ~/.ssh/id_rsa --skip-create-user