diff options
author | Chocobozzz <me@florianbigard.com> | 2022-10-25 11:50:44 +0200 |
---|---|---|
committer | Chocobozzz <me@florianbigard.com> | 2022-10-25 11:50:44 +0200 |
commit | 849f0fd3b2d00056a2c6252230814d6c2e3e3919 (patch) | |
tree | b55d6593c9a53e751bb689fad0ba8f2e1bd2407b /server/lib/job-queue/handlers/move-to-object-storage.ts | |
parent | 2e3b0825bbdd3cb45f610600690fc86af4a32feb (diff) | |
download | PeerTube-849f0fd3b2d00056a2c6252230814d6c2e3e3919.tar.gz PeerTube-849f0fd3b2d00056a2c6252230814d6c2e3e3919.tar.zst PeerTube-849f0fd3b2d00056a2c6252230814d6c2e3e3919.zip |
Lock files to generate torrents/move files
Diffstat (limited to 'server/lib/job-queue/handlers/move-to-object-storage.ts')
-rw-r--r-- | server/lib/job-queue/handlers/move-to-object-storage.ts | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/server/lib/job-queue/handlers/move-to-object-storage.ts b/server/lib/job-queue/handlers/move-to-object-storage.ts index 0b68555d1..a1530cc57 100644 --- a/server/lib/job-queue/handlers/move-to-object-storage.ts +++ b/server/lib/job-queue/handlers/move-to-object-storage.ts | |||
@@ -28,6 +28,8 @@ export async function processMoveToObjectStorage (job: Job) { | |||
28 | 28 | ||
29 | const lTags = lTagsBase(video.uuid, video.url) | 29 | const lTags = lTagsBase(video.uuid, video.url) |
30 | 30 | ||
31 | const fileMutexReleaser = await VideoPathManager.Instance.lockFiles(video.uuid) | ||
32 | |||
31 | try { | 33 | try { |
32 | if (video.VideoFiles) { | 34 | if (video.VideoFiles) { |
33 | logger.debug('Moving %d webtorrent files for video %s.', video.VideoFiles.length, video.uuid, lTags) | 35 | logger.debug('Moving %d webtorrent files for video %s.', video.VideoFiles.length, video.uuid, lTags) |
@@ -49,6 +51,10 @@ export async function processMoveToObjectStorage (job: Job) { | |||
49 | } | 51 | } |
50 | } catch (err) { | 52 | } catch (err) { |
51 | await onMoveToObjectStorageFailure(job, err) | 53 | await onMoveToObjectStorageFailure(job, err) |
54 | |||
55 | throw err | ||
56 | } finally { | ||
57 | fileMutexReleaser() | ||
52 | } | 58 | } |
53 | 59 | ||
54 | return payload.videoUUID | 60 | return payload.videoUUID |