log-backup: update method for telemetry to check usage of pitr feature

br/pkg/streamhelper/advancer.go

@@ -413,10 +413,12 @@ func (c *CheckpointAdvancer) onTaskEvent(ctx context.Context, e TaskEvent) error
 	defer c.taskMu.Unlock()
 	switch e.Type {
 	case EventAdd:
+		utils.LogBackupTaskCountInc()
 		c.task = e.Info
 		c.taskRange = CollapseRanges(len(e.Ranges), func(i int) kv.KeyRange { return e.Ranges[i] })
 		log.Info("added event", zap.Stringer("task", e.Info), zap.Stringer("ranges", logutil.StringifyKeys(c.taskRange)))
 	case EventDel:
+		utils.LogBackupTaskCountDec()
 		c.task = nil
 		c.taskRange = nil
 		c.state = &fullScan{}

br/pkg/utils/db.go

@@ -6,6 +6,7 @@ import (
 	"context"
 	"database/sql"
 	"strings"
+	"sync"
 
 	"github.com/pingcap/log"
 	"github.com/pingcap/tidb/kv"
@@ -18,6 +19,9 @@ var (
 	// check sql.DB and sql.Conn implement QueryExecutor and DBExecutor
 	_ DBExecutor = &sql.DB{}
 	_ DBExecutor = &sql.Conn{}
+
+	LogBackupTaskMutex sync.Mutex
+	logBackupTaskCount int
 )
 
 // QueryExecutor is a interface for exec query
@@ -89,3 +93,22 @@ func IsLogBackupEnabled(ctx sqlexec.RestrictedSQLExecutor) (bool, error) {
 	}
 	return true, nil
 }
+
+// CheckLogBackupTaskExist increases the count of log backup task.
+func LogBackupTaskCountInc() {
+	LogBackupTaskMutex.Lock()
+	logBackupTaskCount++
+	LogBackupTaskMutex.Unlock()
+}
+
+// CheckLogBackupTaskExist decreases the count of log backup task.
+func LogBackupTaskCountDec() {
+	LogBackupTaskMutex.Lock()
+	logBackupTaskCount--
+	LogBackupTaskMutex.Unlock()
+}
+
+// CheckLogBackupTaskExist checks that whether log-backup is existed.
+func CheckLogBackupTaskExist() bool {
+	return logBackupTaskCount > 0
+}

br/pkg/utils/db_test.go

@@ -107,3 +107,11 @@ func TestIsLogBackupEnabled(t *testing.T) {
 	require.Error(t, err)
 	require.False(t, enabled)
 }
+
+func TestCheckLogBackupTaskExist(t *testing.T) {
+	require.False(t, utils.CheckLogBackupTaskExist())
+	utils.LogBackupTaskCountInc()
+	require.True(t, utils.CheckLogBackupTaskExist())
+	utils.LogBackupTaskCountDec()
+	require.False(t, utils.CheckLogBackupTaskExist())
+}

telemetry/data_feature_usage.go

@@ -353,7 +353,7 @@ func getGlobalKillUsageInfo() bool {
 }
 
 func getLogBackupUsageInfo(ctx sessionctx.Context) bool {
-	return utils.CheckLogBackupEnabled(ctx)
+	return utils.CheckLogBackupEnabled(ctx) && utils.CheckLogBackupTaskExist()
 }
 
 func getCostModelVer2UsageInfo(ctx sessionctx.Context) bool {