Fix stuck S3 client
This commit is contained in:
parent
575ec2beaf
commit
10c5f44e1a
2 changed files with 8 additions and 0 deletions
|
@ -160,6 +160,8 @@ export async function makeHLSFileAvailable (playlist: MStreamingPlaylistVideo, f
|
||||||
bucketInfo: CONFIG.OBJECT_STORAGE.STREAMING_PLAYLISTS
|
bucketInfo: CONFIG.OBJECT_STORAGE.STREAMING_PLAYLISTS
|
||||||
})
|
})
|
||||||
|
|
||||||
|
logger.debug('Fetched HLS file %s from object storage to %s.', key, destination, lTags())
|
||||||
|
|
||||||
return destination
|
return destination
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
@ -334,6 +334,12 @@ export async function muxToMergeVideoFiles (options: {
|
||||||
for (const destination of tmpDestinations) {
|
for (const destination of tmpDestinations) {
|
||||||
await remove(destination)
|
await remove(destination)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
for (const input of inputs) {
|
||||||
|
if (input instanceof Readable) {
|
||||||
|
if (!input.destroyed) input.destroy()
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue