feat(media): support cloud codec via ffmpeg

Author: PIKACHUIM

internal/transcode/manager.go

@@ -111,6 +111,9 @@ func (m *Manager) maintenance() {
 }
 
 // sweepIdleJobs 扫描所有活跃任务，超过空闲超时时间无播放端请求则自动取消并 kill FFmpeg
+// 注意：这里只 cancel job + kill ffmpeg 释放 CPU，**不删除已转好的切片缓存**。
+// 当用户继续播放时，TCSegment / TCPlaylist 会通过 Scheduler.Reactivate 复用同一 jobID/token
+// 重新启动转码；已存在的切片可以直接命中，不需要再次转码。
 func (m *Manager) sweepIdleJobs() {
 	idleTimeoutSec := setting.GetInt(conf.TranscodeIdleTimeoutSec, 90)
 	if idleTimeoutSec <= 0 {
@@ -124,15 +127,16 @@ func (m *Manager) sweepIdleJobs() {
 		lastAccess := j.GetLastAccess()
 		idle := now.Sub(lastAccess)
 		if idle > timeout {
-			utils.Log.Infof("[transcode] job %s idle for %.0fs (threshold %ds), auto-cancelling",
+			utils.Log.Infof("[transcode] job %s idle for %.0fs (threshold %ds), pausing ffmpeg (cache kept for resume)",
 				j.ID, idle.Seconds(), idleTimeoutSec)
-			// 先取消所有 chunk ffmpeg，再调度器层面取消，最后清理缓存
+			// 先取消所有 chunk ffmpeg，再调度器层面取消
 			if m.Chunks != nil {
 				m.Chunks.CancelAllForJob(j.ID)
 			}
 			m.Scheduler.Cancel(j.ID)
-			// 清理缓存文件释放磁盘空间
-			m.Cache.Cleanup(j.ID)
+			// 【重要】不再调用 m.Cache.Cleanup —— 已转好的切片必须保留，
+			// 这样浏览器恢复播放时旧的 seg-N.ts 仍然能命中，避免 404 和重新转码。
+			// 真正的磁盘清理由更长周期的 PurgeBefore + Cache.EnforceLRU 负责。
 		}
 	}
 }

internal/transcode/scheduler.go

@@ -265,6 +265,61 @@ func (s *Scheduler) ListJobs() []*Job {
 	return out
 }
 
+// Reactivate 把一个已 Cancelled / Failed / Finished 的 job 重新激活回 Pending 状态，
+// 让 worker 能再次领取并跑转码。用于"播放端重新请求时按需重启转码"的场景。
+//
+// 设计点：
+//  1. 复用原 jobID 和 callback_token，前端持有的 master.m3u8 中的 URL 不需要变更
+//  2. 重置 readyCh / Status / WorkerID 等运行时字段，但保留 Path / SourceURL / Profiles / Probe
+//  3. 重新加入 pending 队列并唤醒等待的 worker
+//
+// 返回被激活的 Job；如果 job 不存在返回 nil 和 false。
+func (s *Scheduler) Reactivate(jobID string) (*Job, bool) {
+	s.mu.Lock()
+	j, ok := s.jobs[jobID]
+	if !ok {
+		s.mu.Unlock()
+		return nil, false
+	}
+	j.mu.Lock()
+	// 只有终止态才需要重新激活；Running/Ready 直接返回即可
+	switch j.Status {
+	case JobPending, JobRunning, JobReady:
+		j.mu.Unlock()
+		s.mu.Unlock()
+		return j, true
+	}
+	// 重置运行时状态
+	j.Status = JobPending
+	j.WorkerID = ""
+	j.Error = ""
+	j.FinishedAt = time.Time{}
+	j.LastAccessAt = time.Now()
+	// 重置 readyCh：原 channel 已 closed，需要全新一份给后续 WaitReady
+	j.readyCh = make(chan struct{})
+	j.readyOnce = sync.Once{}
+	j.mu.Unlock()
+
+	// 重新入 pending 队列（先确认不在队列中以免重复）
+	inQueue := false
+	for _, pj := range s.pending {
+		if pj.ID == jobID {
+			inQueue = true
+			break
+		}
+	}
+	if !inQueue {
+		s.pending = append(s.pending, j)
+	}
+	// 唤醒等待的 worker
+	for _, ch := range s.waiters {
+		close(ch)
+	}
+	s.waiters = nil
+	s.mu.Unlock()
+	return j, true
+}
+
 // PurgeBefore 删除 finishedAt 早于某时刻的任务，避免 jobs map 无限增长
 // 返回被清理的 job ID 列表，调用方需联动清理 Cache
 func (s *Scheduler) PurgeBefore(t time.Time) []string {

server/handles/transcode.go

@@ -147,7 +147,8 @@ func TCPlaylist(c *gin.Context) {
 	jobID := c.Param("job")
 	token := c.Param("token")
 	profile := c.Param("profile")
-	job, ok := transcode.Default().Scheduler.Get(jobID)
+	mgr := transcode.Default()
+	job, ok := mgr.Scheduler.Get(jobID)
 	if !ok {
 		c.String(http.StatusNotFound, "job not found")
 		return
@@ -156,6 +157,13 @@ func TCPlaylist(c *gin.Context) {
 		c.String(http.StatusForbidden, "bad token")
 		return
 	}
+	// 【关键】如果 job 之前因 idle 被 cancel，这里重新激活：复用 jobID/token 重新入队
+	// 让 worker 再次启动 ffmpeg 转码，避免播放器看到 404 后无法恢复
+	if st := job.GetStatus(); st == transcode.JobCancelled || st == transcode.JobFinished || st == transcode.JobFailed {
+		if _, ok := mgr.Scheduler.Reactivate(jobID); ok {
+			fmt.Printf("[transcode] reactivate job %s on playlist request (was %s)\n", jobID, st)
+		}
+	}
 	job.Touch()
 	// 等首切片
 	select {
@@ -193,7 +201,8 @@ func TCSegment(c *gin.Context) {
 	token := c.Param("token")
 	profile := c.Param("profile")
 	segName := c.Param("seg")
-	job, ok := transcode.Default().Scheduler.Get(jobID)
+	mgr := transcode.Default()
+	job, ok := mgr.Scheduler.Get(jobID)
 	if !ok {
 		c.String(http.StatusNotFound, "job not found")
 		return
@@ -202,17 +211,23 @@ func TCSegment(c *gin.Context) {
 		c.String(http.StatusForbidden, "bad token")
 		return
 	}
+	// 【关键】job 之前因 idle 被 cancel 时，复用同一 jobID/token 重新入队启动转码。
+	// 这样浏览器持有的旧 master.m3u8 + 切片 URL 仍然有效，暂停再继续也不会 404。
+	if st := job.GetStatus(); st == transcode.JobCancelled || st == transcode.JobFinished || st == transcode.JobFailed {
+		if _, ok := mgr.Scheduler.Reactivate(jobID); ok {
+			fmt.Printf("[transcode] reactivate job %s on segment request (was %s)\n", jobID, st)
+		}
+	}
 	// seg-N.ts
 	name := strings.TrimSuffix(strings.TrimPrefix(segName, "seg-"), ".ts")
 	seq, err := strconv.Atoi(name)
 	if err != nil {
 		c.String(http.StatusBadRequest, "bad segment name")
 		return
 	}
-	cache := transcode.Default().Cache
+	cache := mgr.Cache
 	// 【智能调度】触发对应 chunk 的 ffmpeg 启动（如已运行则只更新 LastAccess）
 	// 这是用户拖动进度条到任意位置时能快速响应的关键
-	mgr := transcode.Default()
 	if mgr.Chunks != nil {
 		chunkIdx := mgr.Chunks.EnsureChunkRunningForSeg(jobID, profile, seq)
 		fmt.Printf("[tc-segment] req seq=%d chunk=%d job=%s\n", seq, chunkIdx, jobID)