diff options
| author | Chocobozzz <me@florianbigard.com> | 2023-05-22 14:31:35 +0200 |
|---|---|---|
| committer | Chocobozzz <me@florianbigard.com> | 2023-05-22 15:03:14 +0200 |
| commit | 6a9b3151822461a85bbc72b7a50e12ffb69bec3a (patch) | |
| tree | 1685c31114707d90144100319aead6c63aef6254 /server/lib/live | |
| parent | 8762b1c7ffbb82e817bb07b381503997b5aca50d (diff) | |
| download | PeerTube-6a9b3151822461a85bbc72b7a50e12ffb69bec3a.tar.gz PeerTube-6a9b3151822461a85bbc72b7a50e12ffb69bec3a.tar.zst PeerTube-6a9b3151822461a85bbc72b7a50e12ffb69bec3a.zip | |
Fix tests
Diffstat (limited to 'server/lib/live')
| -rw-r--r-- | server/lib/live/live-segment-sha-store.ts | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/server/lib/live/live-segment-sha-store.ts b/server/lib/live/live-segment-sha-store.ts index 1a0a93985..08fc460b8 100644 --- a/server/lib/live/live-segment-sha-store.ts +++ b/server/lib/live/live-segment-sha-store.ts | |||
| @@ -72,6 +72,8 @@ class LiveSegmentShaStore { | |||
| 72 | 72 | ||
| 73 | private writeToDisk () { | 73 | private writeToDisk () { |
| 74 | return this.writeQueue.add(async () => { | 74 | return this.writeQueue.add(async () => { |
| 75 | logger.debug(`Writing segment sha JSON ${this.sha256Path} of ${this.videoUUID} on disk %s.`, lTags(this.videoUUID)) | ||
| 76 | |||
| 75 | // Atomic write: use rename instead of move that is not atomic | 77 | // Atomic write: use rename instead of move that is not atomic |
| 76 | await writeJson(this.sha256PathTMP, mapToJSON(this.segmentsSha256)) | 78 | await writeJson(this.sha256PathTMP, mapToJSON(this.segmentsSha256)) |
| 77 | await rename(this.sha256PathTMP, this.sha256Path) | 79 | await rename(this.sha256PathTMP, this.sha256Path) |