Support for gracefully exiting ffmpeg

lib/processor.js

@@ -439,7 +439,7 @@ module.exports = function(proto) {
           niceness: self.options.niceness,
           cwd: self.options.cwd,
           windowsHide: true
-        }, 
+        },
 
         function processCB(ffmpegProc, stdoutRing, stderrRing) {
           self.ffmpegProc = ffmpegProc;
@@ -659,4 +659,23 @@ module.exports = function(proto) {
 
     return this;
   };
+
+  /**
+   * quit current ffmpeg process, if any
+   *
+   * @method FfmpegCommand#quit
+   * @category Processing
+   *
+   * @return FfmpegCommand
+   */
+  proto.quit = function(signal) {
+    if (!this.ffmpegProc) {
+      this.logger.warn('No running ffmpeg process, cannot quit');
+    } else {
+      this.ffmpegProc.stdin.setEncoding('utf-8');
+      this.ffmpegProc.stdin.write("q\n");
+    }
+
+    return this;
+  };
 };

test/processor.test.js

@@ -365,6 +365,39 @@ describe('Processor', function() {
     });
   });
 
+
+  it('should gracefully quit the process with .quit', function(done) {
+    var testFile = path.join(__dirname, 'assets', 'testProcessQuit.avi');
+    this.files.push(testFile);
+
+    var ffmpegJob = this.getCommand({ source: this.testfilebig, logger: testhelper.logger })
+        .usingPreset('divx');
+
+    var startCalled = false;
+    var errorCalled = false;
+    var endCalled = false;
+
+    ffmpegJob
+        .on('start', function() {
+          startCalled = true;
+          setTimeout(function() { ffmpegJob.quit(); }, 500);
+          ffmpegJob.ffmpegProc.on('exit', function() {
+            setTimeout(function() {
+              errorCalled.should.equal(false);
+              endCalled.should.equal(true);
+              done();
+            }, 1000);
+          });
+        })
+        .on('error', function(err) {
+          errorCalled = true;
+        })
+        .on('end', function() {
+          endCalled = true;
+        })
+        .saveToFile(testFile);
+  });
+
   describe('Events', function() {
     it('should report codec data through \'codecData\' event', function(done) {
       this.timeout(60000);