feat: update task access time (dragonflyoss#909)

* update task access time when task is downloading Signed-off-by: sunwp <[email protected]>
sungjunyoung · Dec 10, 2021 · 1e62cc4 · 1e62cc4
1 parent 9d857ea
commit 1e62cc4
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/cdn/supervisor/progress/manager.go b/cdn/supervisor/progress/manager.go
@@ -126,6 +126,12 @@ func (pm *Manager) PublishPiece(ctx context.Context, taskID string, record *type
 	logger.Debugf("seed piece meta record %#v", record)
 	pm.mu.Lock(taskID, false)
 	defer pm.mu.UnLock(taskID, false)
+	// update task access time
+	if pm.taskMgr != nil {
+		if _, err := pm.taskMgr.Get(taskID); err != nil {
+			return err
+		}
+	}
 	err := pm.setPieceMetaRecord(taskID, record)
 	if err != nil {
 		return fmt.Errorf("set piece meta record: %v", err)