add research empty ffmpeg

@@ -18,7 +18,7 @@ vhost __defaultVhost__ {
     #forward         127.0.0.1:1936;
     #forward         127.0.0.1:1936;
     transcode {
     transcode {
         enabled     on;
         enabled     on;
-        ffmpeg      ./objs/ffmpeg/bin/ffmpeg;
+        ffmpeg      /home/winlin/srs/objs/ffmpeg/bin/ffmpeg;
         engine fd{
         engine fd{
             enabled         on;
             enabled         on;
             vcodec          libx264;
             vcodec          libx264;

@@ -23,6 +23,9 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 
 
 #include <srs_core_encoder.hpp>
 #include <srs_core_encoder.hpp>
 
 
+#include <stdlib.h>
+#include <unistd.h>
+
 #include <srs_core_error.hpp>
 #include <srs_core_error.hpp>
 #include <srs_core_log.hpp>
 #include <srs_core_log.hpp>
 #include <srs_core_config.hpp>
 #include <srs_core_config.hpp>
@@ -35,6 +38,7 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 SrsFFMPEG::SrsFFMPEG(std::string ffmpeg_bin)
 SrsFFMPEG::SrsFFMPEG(std::string ffmpeg_bin)
 {
 {
 	started			= false;
 	started			= false;
+	pid				= -1;
 	ffmpeg 			= ffmpeg_bin;
 	ffmpeg 			= ffmpeg_bin;
 	
 	
 	vbitrate 		= 0;
 	vbitrate 		= 0;
@@ -76,6 +80,14 @@ int SrsFFMPEG::initialize(std::string vhost, std::string port, std::string app,
 	vwidth -= vwidth % 2;
 	vwidth -= vwidth % 2;
 	vheight -= vheight % 2;
 	vheight -= vheight % 2;
 
 
+	// input stream, from local.
+	input = "rtmp://127.0.0.1:";
+	input += port;
+	input += "/";
+	input += app;
+	input += "/";
+	input += stream;
+	
 	if (vhost == RTMP_VHOST_DEFAULT) {
 	if (vhost == RTMP_VHOST_DEFAULT) {
 		output = srs_replace(output, "[vhost]", "127.0.0.1");
 		output = srs_replace(output, "[vhost]", "127.0.0.1");
 	} else {
 	} else {
@@ -167,6 +179,59 @@ int SrsFFMPEG::start()
 		return ret;
 		return ret;
 	}
 	}
 	
 	
+	// prepare execl params
+	char vsize[22];
+	snprintf(vsize, sizeof(vsize), "%dx%d", vwidth, vheight);
+	char vaspect[22];
+	snprintf(vaspect, sizeof(vaspect), "%d:%d", vwidth, vheight);
+	
+	// we use vfork, for we use fored process
+	// to start ffmpeg, that is, exec after vfork.
+	if ((pid = fork()) < 0) {
+		ret = ERROR_ENCODER_FORK;
+		srs_error("vfork process failed. ret=%d", ret);
+		return ret;
+	}
+	
+	// child process: ffmpeg encoder engine.
+	if (pid == 0) {
+		// must exec immediately, or may introduce bug.
+		ret = execl(ffmpeg.c_str(), 
+			"-i", input.c_str(), 
+			// video specified.
+			"-vcodec", vcodec.c_str(), 
+			"-b:v", vbitrate * 1000,
+			"-r", vfps,
+			"-size", vsize,
+			"-aspect", vaspect, // TODO: add aspect if needed.
+			"-threads", vthreads,
+			"-profile", vprofile.c_str(),
+			"-preset", vpreset.c_str(),
+			vparams.c_str(),
+			// audio specified.
+			"-acodec", acodec.c_str(),
+			"-b:a", abitrate * 1000,
+			"-ar", asample_rate,
+			"-ac", achannels,
+			aparams.c_str(),
+			"-f", "flv",
+			"-y", output.c_str(),
+			NULL
+		);
+		if (ret < 0) {
+			fprintf(stderr, "fork ffmpeg failed, errno=%d(%s)", 
+				errno, strerror(errno));
+		}
+		exit(ret);
+	}
+
+	// parent.
+	if (pid > 0) {
+		started = true;
+		srs_trace("vfored ffmpeg encoder engine, pid=%d", pid);
+		return ret;
+	}
+	
 	return ret;
 	return ret;
 }
 }
 
 

@@ -44,6 +44,7 @@ class SrsFFMPEG
 {
 {
 private:
 private:
 	bool started;
 	bool started;
+	pid_t pid;
 private:
 private:
 	std::string 				ffmpeg;
 	std::string 				ffmpeg;
 	std::string 				vcodec;
 	std::string 				vcodec;
@@ -61,6 +62,7 @@ private:
 	int 						achannels;
 	int 						achannels;
 	std::string					aparams;
 	std::string					aparams;
 	std::string 				output;
 	std::string 				output;
+	std::string 				input;
 public:
 public:
 	SrsFFMPEG(std::string ffmpeg_bin);
 	SrsFFMPEG(std::string ffmpeg_bin);
 	virtual ~SrsFFMPEG();
 	virtual ~SrsFFMPEG();

@@ -135,5 +135,6 @@ CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 #define ERROR_ENCODER_VWIDTH			710
 #define ERROR_ENCODER_VWIDTH			710
 #define ERROR_ENCODER_VFPS				711
 #define ERROR_ENCODER_VFPS				711
 #define ERROR_ENCODER_VBITRATE			712
 #define ERROR_ENCODER_VBITRATE			712
+#define ERROR_ENCODER_FORK				713
 
 
 #endif
 #endif