blitzwing/cobalt-7
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

stream: send SIGKILL after timeout

Browse source 
in case the ffmpeg process decides to hang when SIGTERM'd
This commit is contained in:
dumbmoron 2023-11-05 22:07:34 +00:00
parent cae4a68aa4
commit dbd13bc8b6
No known key found for this signature in database
GPG key ID: C59997C76C6A8E5F
1 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
src/modules/stream/types.js
View file

@ -11,6 +11,14 @@ function closeResponse(res) {
return res.destroy();
}
function killProcess(p) {
p?.kill();
setTimeout(() => {
if (p?.exitCode === null)
p?.kill(9);
}, 5000);
}
export async function streamDefault(streamInfo, res) {
const abortController = new AbortController();
const shutdown = () => (abortController.abort(), closeResponse(res));
@ -37,7 +45,7 @@ export async function streamDefault(streamInfo, res) {
export async function streamLiveRender(streamInfo, res) {
let abortController = new AbortController(), process;
const shutdown = () => (abortController.abort(), process?.kill(), closeResponse(res));
const shutdown = () => (abortController.abort(), killProcess(process), closeResponse(res));
try {
if (streamInfo.urls.length !== 2) return shutdown();
@ -85,7 +93,7 @@ export async function streamLiveRender(streamInfo, res) {
export function streamAudioOnly(streamInfo, res) {
let process;
const shutdown = () => (process?.kill(), closeResponse(res));
const shutdown = () => (killProcess(process), closeResponse(res));
try {
let args = [
@ -132,7 +140,7 @@ export function streamAudioOnly(streamInfo, res) {
export function streamVideoOnly(streamInfo, res) {
let process;
const shutdown = () => (process?.kill(), closeResponse(res));
const shutdown = () => (killProcess(process), closeResponse(res));
try {
let format = streamInfo.filename.split('.')[streamInfo.filename.split('.').length - 1], args = [