缓冲区内存泄漏

Question

编码结果始终在顶部有故障。如果我只是直接管道decode.stdout.pipe（encode.stdin），则无故障。我尽力解决。我的问题是在试图读取以稍后进行操纵时出现的。我不知道，这是崛起问题的哪一部分。我认为我需要刷新，来回阅读文档。什么都没有改变。

const { spawn } = require('child_process');
const path = require('path');

const decArgs = [
    '-i', path.join(__dirname + '/public/test.mp4'),
    '-an',
    '-pix_fmt', 'bgr24',
    '-f', 'rawvideo',
    '-'
];

const decode = spawn('ffmpeg', decArgs, {
    stdio: [
        'ignore',
        'pipe',
        'ignore'
    ] 
});

// Encode section
const width = 854;
const height = 480;
const channels = 3;
const fps = 23.97602397602398.toString();
const colorsLength = width*height*channels;


const encArgs = [
    '-f', 'rawvideo',
    '-pix_fmt', 'bgr24', 
    '-s', `${width}x${height}`,
    '-r', fps,
    '-i', '-',
    '-c:v', 'libx264',
    '-preset', 'ultrafast',
    '-crf', '30',
    '-pix_fmt', 'yuv420p',
    '-r', fps,
    '-y',
    path.join(__dirname + '/public/output.mp4')
];

const encode = spawn('ffmpeg', encArgs, {
    stdio: [
        'pipe',
        'ignore',
        'pipe'
    ]
});

// colors RGBA
let buffer = Buffer.alloc(0);
decode.stdout.on('data', data => {
    const allocSize = buffer.length + data.length;
    buffer = Buffer.concat([buffer, data], allocSize);
    
    if (buffer.length > colorsLength) decode.stdout.pause();
});

decode.stdout.on('pause', () => {
    // Create new buffer with size of colors length
    const bufferData = Buffer.alloc(colorsLength);
    buffer.copy(bufferData, 0, 0, colorsLength);
    // after manipulate the buffer send it to encode
    encode.stdin.write(bufferData);
    
    // Create new buffer to take out left buffer. cause stream length cant be predict.
    const leftBuffer = Buffer.alloc(buffer.length - bufferData.length);
    buffer.copy(leftBuffer, 0, buffer.length - bufferData.length, buffer.length);
    buffer = leftBuffer;

    decode.stdout.resume()
});

decode.stdout.on('end', () => {
    if (buffer.length) encode.stdin.write(buffer);
    encode.stdin.end();
})

encode.stderr.on('data', data => {
    console.log(data.toString())
})