From: Chocobozzz Date: Tue, 30 May 2023 07:35:21 +0000 (+0200) Subject: Fix transcoding error X-Git-Tag: v5.2.0-rc.1~4 X-Git-Url: https://git.immae.eu/?a=commitdiff_plain;h=29c7319c8a42d5c4831d08a80f4d111d3a72f52c;p=github%2FChocobozzz%2FPeerTube.git Fix transcoding error When transcoding.always_transcode_original_resolution is false --- diff --git a/server/lib/job-queue/handlers/video-transcoding.ts b/server/lib/job-queue/handlers/video-transcoding.ts index 39f078bf0..f8758f170 100644 --- a/server/lib/job-queue/handlers/video-transcoding.ts +++ b/server/lib/job-queue/handlers/video-transcoding.ts @@ -75,21 +75,21 @@ export { // --------------------------------------------------------------------------- async function handleWebTorrentMergeAudioJob (job: Job, payload: MergeAudioTranscodingPayload, video: MVideoFullLight, user: MUserId) { - logger.info('Handling merge audio transcoding job for %s.', video.uuid, lTags(video.uuid)) + logger.info('Handling merge audio transcoding job for %s.', video.uuid, lTags(video.uuid), { payload }) await mergeAudioVideofile({ video, resolution: payload.resolution, fps: payload.fps, job }) - logger.info('Merge audio transcoding job for %s ended.', video.uuid, lTags(video.uuid)) + logger.info('Merge audio transcoding job for %s ended.', video.uuid, lTags(video.uuid), { payload }) await onTranscodingEnded({ isNewVideo: payload.isNewVideo, moveVideoToNextState: !payload.hasChildren, video }) } async function handleWebTorrentOptimizeJob (job: Job, payload: OptimizeTranscodingPayload, video: MVideoFullLight, user: MUserId) { - logger.info('Handling optimize transcoding job for %s.', video.uuid, lTags(video.uuid)) + logger.info('Handling optimize transcoding job for %s.', video.uuid, lTags(video.uuid), { payload }) await optimizeOriginalVideofile({ video, inputVideoFile: video.getMaxQualityFile(), quickTranscode: payload.quickTranscode, job }) - logger.info('Optimize transcoding job for %s ended.', video.uuid, lTags(video.uuid)) + logger.info('Optimize transcoding job for %s ended.', video.uuid, lTags(video.uuid), { payload }) await onTranscodingEnded({ isNewVideo: payload.isNewVideo, moveVideoToNextState: !payload.hasChildren, video }) } @@ -97,11 +97,11 @@ async function handleWebTorrentOptimizeJob (job: Job, payload: OptimizeTranscodi // --------------------------------------------------------------------------- async function handleNewWebTorrentResolutionJob (job: Job, payload: NewWebTorrentResolutionTranscodingPayload, video: MVideoFullLight) { - logger.info('Handling WebTorrent transcoding job for %s.', video.uuid, lTags(video.uuid)) + logger.info('Handling WebTorrent transcoding job for %s.', video.uuid, lTags(video.uuid), { payload }) await transcodeNewWebTorrentResolution({ video, resolution: payload.resolution, fps: payload.fps, job }) - logger.info('WebTorrent transcoding job for %s ended.', video.uuid, lTags(video.uuid)) + logger.info('WebTorrent transcoding job for %s ended.', video.uuid, lTags(video.uuid), { payload }) await onTranscodingEnded({ isNewVideo: payload.isNewVideo, moveVideoToNextState: true, video }) } @@ -109,7 +109,7 @@ async function handleNewWebTorrentResolutionJob (job: Job, payload: NewWebTorren // --------------------------------------------------------------------------- async function handleHLSJob (job: Job, payload: HLSTranscodingPayload, videoArg: MVideoFullLight) { - logger.info('Handling HLS transcoding job for %s.', videoArg.uuid, lTags(videoArg.uuid)) + logger.info('Handling HLS transcoding job for %s.', videoArg.uuid, lTags(videoArg.uuid), { payload }) const inputFileMutexReleaser = await VideoPathManager.Instance.lockFiles(videoArg.uuid) let video: MVideoFullLight @@ -138,7 +138,7 @@ async function handleHLSJob (job: Job, payload: HLSTranscodingPayload, videoArg: inputFileMutexReleaser() } - logger.info('HLS transcoding job for %s ended.', video.uuid, lTags(video.uuid)) + logger.info('HLS transcoding job for %s ended.', video.uuid, lTags(video.uuid), { payload }) if (payload.deleteWebTorrentFiles === true) { logger.info('Removing WebTorrent files of %s now we have a HLS version of it.', video.uuid, lTags(video.uuid)) diff --git a/server/lib/transcoding/shared/job-builders/transcoding-job-queue-builder.ts b/server/lib/transcoding/shared/job-builders/transcoding-job-queue-builder.ts index fa2ac70bf..4f802e2a6 100644 --- a/server/lib/transcoding/shared/job-builders/transcoding-job-queue-builder.ts +++ b/server/lib/transcoding/shared/job-builders/transcoding-job-queue-builder.ts @@ -18,7 +18,7 @@ import { } from '@shared/models' import { getTranscodingJobPriority } from '../../transcoding-priority' import { canDoQuickTranscode } from '../../transcoding-quick-transcode' -import { computeResolutionsToTranscode } from '../../transcoding-resolutions' +import { buildOriginalFileResolution, computeResolutionsToTranscode } from '../../transcoding-resolutions' import { AbstractJobBuilder } from './abstract-job-builder' export class TranscodingJobQueueBuilder extends AbstractJobBuilder { @@ -55,7 +55,7 @@ export class TranscodingJobQueueBuilder extends AbstractJobBuilder { const maxResolution = await isAudioFile(videoFilePath, probe) ? DEFAULT_AUDIO_RESOLUTION - : resolution + : buildOriginalFileResolution(resolution) if (CONFIG.TRANSCODING.HLS.ENABLED === true) { nextTranscodingSequentialJobPayloads.push([ diff --git a/server/lib/transcoding/transcoding-resolutions.ts b/server/lib/transcoding/transcoding-resolutions.ts index 91f4d18d8..9a6bf5722 100644 --- a/server/lib/transcoding/transcoding-resolutions.ts +++ b/server/lib/transcoding/transcoding-resolutions.ts @@ -2,6 +2,27 @@ import { CONFIG } from '@server/initializers/config' import { toEven } from '@shared/core-utils' import { VideoResolution } from '@shared/models' +export function buildOriginalFileResolution (inputResolution: number) { + if (CONFIG.TRANSCODING.ALWAYS_TRANSCODE_ORIGINAL_RESOLUTION === true) { + return toEven(inputResolution) + } + + const resolutions = computeResolutionsToTranscode({ + input: inputResolution, + type: 'vod', + includeInput: false, + strictLower: false, + // We don't really care about the audio resolution in this context + hasAudio: true + }) + + if (resolutions.length === 0) { + return toEven(inputResolution) + } + + return Math.max(...resolutions) +} + export function computeResolutionsToTranscode (options: { input: number type: 'vod' | 'live' diff --git a/server/lib/transcoding/web-transcoding.ts b/server/lib/transcoding/web-transcoding.ts index 22bd238ae..7cc8f20bc 100644 --- a/server/lib/transcoding/web-transcoding.ts +++ b/server/lib/transcoding/web-transcoding.ts @@ -3,8 +3,8 @@ import { copyFile, move, remove, stat } from 'fs-extra' import { basename, join } from 'path' import { computeOutputFPS } from '@server/helpers/ffmpeg' import { createTorrentAndSetInfoHash } from '@server/helpers/webtorrent' +import { VideoModel } from '@server/models/video/video' import { MVideoFile, MVideoFullLight } from '@server/types/models' -import { toEven } from '@shared/core-utils' import { ffprobePromise, getVideoStreamDuration, getVideoStreamFPS, TranscodeVODOptionsType } from '@shared/ffmpeg' import { VideoResolution, VideoStorage } from '@shared/models' import { CONFIG } from '../../initializers/config' @@ -13,8 +13,7 @@ import { generateWebTorrentVideoFilename } from '../paths' import { buildFileMetadata } from '../video-file' import { VideoPathManager } from '../video-path-manager' import { buildFFmpegVOD } from './shared' -import { computeResolutionsToTranscode } from './transcoding-resolutions' -import { VideoModel } from '@server/models/video/video' +import { buildOriginalFileResolution } from './transcoding-resolutions' // Optimize the original video file and replace it. The resolution is not changed. export async function optimizeOriginalVideofile (options: { @@ -248,26 +247,3 @@ export async function onWebTorrentVideoFileTranscoding (options: { mutexReleaser() } } - -// --------------------------------------------------------------------------- - -function buildOriginalFileResolution (inputResolution: number) { - if (CONFIG.TRANSCODING.ALWAYS_TRANSCODE_ORIGINAL_RESOLUTION === true) { - return toEven(inputResolution) - } - - const resolutions = computeResolutionsToTranscode({ - input: inputResolution, - type: 'vod', - includeInput: false, - strictLower: false, - // We don't really care about the audio resolution in this context - hasAudio: true - }) - - if (resolutions.length === 0) { - return toEven(inputResolution) - } - - return Math.max(...resolutions) -}