From 109ffe9a777658936a38d0c146579a67c60a0d17 Mon Sep 17 00:00:00 2001
From: xuxiuxi <xuxiuxi@454eff88-639b-444f-9e54-f578c98de674>
Date: 星期四, 11 五月 2017 17:48:48 +0800
Subject: [PATCH] 

---
 RtspFace/PL_RTSPServer.cpp |  291 ++++++++++++++++++++++++++++++---------------------------
 1 files changed, 153 insertions(+), 138 deletions(-)

diff --git a/RtspFace/PL_RTSPServer.cpp b/RtspFace/PL_RTSPServer.cpp
index 936b31d..6610e04 100644
--- a/RtspFace/PL_RTSPServer.cpp
+++ b/RtspFace/PL_RTSPServer.cpp
@@ -1,88 +1,42 @@
 #include "PL_RTSPServer.h"
+#include "MaterialBuffer.h"
+#include "logger.h"
 
 #include <liveMedia.hh>
 #include <BasicUsageEnvironment.hh>
 
-class MyH264FramedSource : public FramedSource
+#include "FFmpegRTSPServer/IEncoder.h"
+#include "FFmpegRTSPServer/LiveRTSPServer.h"
+#include "FFmpegRTSPServer/FFmpegH264Source.h"
+#include "FFmpegRTSPServer/LiveServerMediaSubsession.h"
+
+class MyEncoderStub;
+
+struct RTSPServer_Internal
 {
-public:
-	static MyH264FramedSource* createNew(UsageEnvironment& env);
-
-protected:
-	MyH264FramedSource(UsageEnvironment& env)
-	virtual ~MyH264FramedSource()
-
-	// overide FramedSource
-	virtual void doGetNextFrame()
-	{
-		// deliverFrame
-		//if (fFrameSize > 0)
-		//{
-		//	// send Frame to the consumer
-		//	FramedSource::afterGetting(this);			
-		//}
-		
-		
-		// isCurrentlyAwaitingData
-			//if (frame->m_size > fMaxSize) 
-			//{
-			//	fFrameSize = fMaxSize;
-			//	fNumTruncatedBytes = frame->m_size - fMaxSize;
-			//} 
-			//else 
-			//{
-			//	fFrameSize = frame->m_size;
-			//}
-		//memcpy(fTo, frame->m_buffer, fFrameSize);
-		//if (fFrameSize > 0)
-		//	FramedSource::afterGetting(this);
-	}
+	uint8_t buffer[1920*1080*3];
+	size_t buffSize;
+	size_t buffSizeMax;
 	
-	virtual void doStopGettingFrames()
-	{
-		FramedSource::doStopGettingFrames();
-	}
-};
-
-struct PL_RTSPServer_Internal
-{
-	//uint8_t buffer[1920*1080*4];
-	//size_t buffSize;
-	//size_t buffSizeMax;
+	RTSPServerConfig config;
 
 	bool payError;
 	pthread_t live_daemon_thid;
 	pthread_mutex_t* frame_mutex;
 	bool live_daemon_running;
 	
-	UsageEnvironment* env;
+	MESAI::LiveRTSPServer * server;
+	MyEncoderStub * encoderStub;
 
-	// To make the second and subsequent client for each stream reuse the same
-	// input stream as the first client (rather than playing the file from the
-	// start for each client), change the following "False" to "True":
-	Boolean reuseFirstSource;
-
-	// To stream *only* MPEG-1 or 2 video "I" frames
-	// (e.g., to reduce network bandwidth),
-	// change the following "False" to "True":
-	Boolean iFramesOnly;
-	
-	UserAuthenticationDatabase* authDB;
-
-	RTSPServer* rtspServer;//#todo delete
-	
-	char descriptionString[1024];
-	
-	PL_RTSPServer_Internal() : 
-		//buffSize(0), buffSizeMax(sizeof(buffer)), 
-		payError(true), live_daemon_thid(0), frame_mutex(nullptr), live_daemon_running(false), 
-		env(nullptr), reuseFirstSource(False), iFramesOnly(False), authDB(nullptr), 
-		rtspServer(nullptr);
+	RTSPServer_Internal() : 
+		buffSize(0), buffSizeMax(sizeof(buffer)), config(), 
+		payError(true), live_daemon_thid(0), frame_mutex(new pthread_mutex_t), live_daemon_running(false), 
+		server(nullptr), encoderStub(nullptr)
 	{
 		pthread_mutex_init(frame_mutex, NULL);
 	}
 	
-	~PL_RTSPServer_Internal()
+	~RTSPServer_Internal()
 	{
 		if (frame_mutex != nullptr)
 		{
@@ -94,7 +48,10 @@
 	
 	void reset()
 	{
-		//buffSize = 0;
+		buffSize = 0;
+		
+		RTSPServerConfig _config;
+		config =_config;
 
 		payError = true;
 
@@ -111,14 +68,90 @@
 		live_daemon_thid = 0;
 		live_daemon_running = false;
 		
-		env = nullptr;
-		reuseFirstSource = False;
-		iFramesOnly = False;
-		authDB = nullptr; 
-		rtspServer = nullptr;
-		
-		strcpy(descriptionString, "Session streamed by \"testOnDemandRTSPServer\"");
+		server = nullptr;
+		encoderStub = nullptr;
 	}
+};
+
+class MyEncoderStub : public MESAI::IEncoder
+{
+public:
+	MyEncoderStub(RTSPServer_Internal& _in) : in(_in)
+	{
+	}
+	
+	virtual ~MyEncoderStub()
+	{
+	}
+	
+	virtual void setCallbackFunctionFrameIsReady(std::function<void()> func)
+	{
+		onFrame = func;
+	}
+	
+	virtual char GetFrame(u_int8_t** FrameBuffer, unsigned int *FrameSize)
+	{
+		if (in.buffer == nullptr || in.buffSize <= 0)
+		{
+			ReleaseFrame();
+			return 0;
+		}
+		
+		uint8_t* pBuffer = in.buffer;
+		size_t newBufferSize = in.buffSize;
+		if (in.config.payWithAux)
+		{
+			if (newBufferSize <= 4)
+			{
+				ReleaseFrame();
+				return 0;
+			}
+			pBuffer += 4;
+			newBufferSize -= 4;
+		}
+		
+		*FrameBuffer = pBuffer;
+		*FrameSize = newBufferSize;
+
+		LOG_DEBUG << "send frame size=" << in.buffSize << std::endl;
+	}
+	
+	virtual char ReleaseFrame()
+	{
+		in.buffSize = 0;
+		
+		if (in.config.syncDeliverFrame)
+		{
+			int ret = pthread_mutex_unlock(in.frame_mutex);
+			if(ret != 0)
+			{
+				LOG_WARN << "pthread_mutex_unlock frame_mutex: " << strerror(ret) << std::endl;
+				return 0;
+			}
+		}
+		
+		return 1;
+	}
+
+	void deliverFrame()
+	{
+		// write frame buffer of RTSPServer_Internal::buffer
+		onFrame();
+
+		if (in.config.syncDeliverFrame)
+		{
+			int ret = pthread_mutex_lock(in.frame_mutex);
+			if(ret != 0)
+			{
+				LOG_WARN << "pthread_mutex_lock frame_mutex: " << strerror(ret) << std::endl;
+				return;
+			}
+		}
+	}
+
+private:
+	RTSPServer_Internal& in;
+	std::function<void()> onFrame;
 };
 
 PipeLineElem* create_PL_RTSPServer()
@@ -126,86 +159,45 @@
 	return new PL_RTSPServer;
 }
 
-PL_RTSPServer::PL_RTSPServer() : internal(new PL_RTSPServer_Internal)
+PL_RTSPServer::PL_RTSPServer() : internal(new RTSPServer_Internal)
 {
 }
 
 PL_RTSPServer::~PL_RTSPServer()
 {
-	delete (PL_RTSPServer_Internal*)internal;
-	internal= nullptr;
+	delete (RTSPServer_Internal*)internal;
+	internal = nullptr;
 }
 
-void* live_daemon_thd(void* arg)
+static void* live_daemon_thd(void* arg)
 {
-	RTSPClient_Internal* in = (RTSPClient_Internal*)arg;
+	RTSPServer_Internal* in = (RTSPServer_Internal*)arg;
+
+	MyEncoderStub encoder(*in);
+	in->encoderStub = &encoder;
+	in->server = new MESAI::LiveRTSPServer(&encoder, 8554, 8080);
 	
-	// Begin by setting up our usage environment:
-	TaskScheduler* scheduler = BasicTaskScheduler::createNew();
-	in->env = BasicUsageEnvironment::createNew(*scheduler);
-
-#ifdef ACCESS_CONTROL
-	// To implement client access control to the RTSP server, do the following:
-	in->authDB = new UserAuthenticationDatabase;
-	in->authDB->addUserRecord("username1", "password1"); // replace these with real strings
-	// Repeat the above with each <username>, <password> that you wish to allow
-	// access to the server.
-#endif
-
-	// Create the RTSP server:
-	in->rtspServer = RTSPServer::createNew(*env, 8554, authDB);
-	if (rtspServer == NULL)
-	{
-		*(in->env) << "Failed to create RTSP server: " << env->getResultMsg() << "\n";
-		return;
-	}
-
-	// Set up each of the possible streams that can be served by the
-	// RTSP server.  Each such stream is implemented using a
-	// "ServerMediaSession" object, plus one or more
-	// "ServerMediaSubsession" objects for each audio/video substream.
-	
-    char const* streamName = "plH264Encoder";
-    ServerMediaSession* sms = ServerMediaSession::createNew(*(in->env), streamName, streamName, in->descriptionString);
-    sms->addSubsession(MyH264FramedSource::createNew(*(in->env), in));
-    in->rtspServer->addServerMediaSession(sms);
-	
-	// announceStream
-	char* url = rtspServer->rtspURL(sms);
-	*(in->env) << "\n\"" << streamName << "\" stream, from the file \"" << inputFileName << "\"\n";
-	*(in->env) << "Play this stream using the URL \"" << url << "\"\n";
-	delete[] url;
-	
-	// Also, attempt to create a HTTP server for RTSP-over-HTTP tunneling.
-	// Try first with the default HTTP port (80), and then with the alternative HTTP
-	// port numbers (8000 and 8080).
-
-	if (rtspServer->setUpTunnelingOverHTTP(80))
-		*(in->env) << "\n(We use port " << rtspServer->httpServerPortNum() << " for optional RTSP-over-HTTP tunneling.)\n";
-	else
-		*(in->env) << "\n(RTSP-over-HTTP tunneling is not available.)\n";
-
 	in->live_daemon_running = true;
-	env->taskScheduler().doEventLoop(); // does not return
+	in->server->run(); // does not return
+	in->encoderStub = nullptr;
 	in->live_daemon_running = false;
 }
 
 bool PL_RTSPServer::init(void* args)
 {
-	PL_RTSPServer_Internal* in = (PL_RTSPServer_Internal*)internal;
+	RTSPServer_Internal* in = (RTSPServer_Internal*)internal;
 	in->reset();
-	
-	int ret = pthread_mutex_lock(in->frame_mutex);
-	if(ret != 0)
+
+	if (args)
 	{
-		printf("pthread_mutex_lock frame_mutex: %s/n", strerror(ret));
-		return false;
+		RTSPServerConfig* config = (RTSPServerConfig*)args;
+		in->config = *config;
 	}
-	
-	ret = pthread_create(&(in->live_daemon_thid), NULL, live_daemon_thd, in);
+
+	int ret = pthread_create(&(in->live_daemon_thid), NULL, live_daemon_thd, in);
 	if(ret != 0)
 	{
-		printf("pthread_create: %s/n", strerror(ret));
+		LOG_ERROR << "pthread_create: " << strerror(ret) << std::endl;
 		return false;
 	}
 
@@ -214,22 +206,45 @@
 
 void PL_RTSPServer::finit()
 {
-	RTSPClient_Internal* in = (RTSPClient_Internal*)internal;
+	RTSPServer_Internal* in = (RTSPServer_Internal*)internal;
 
 	pthread_join(in->live_daemon_thid, NULL);
 }
 
 bool PL_RTSPServer::pay(const PipeMaterial& pm)
 {
-	PL_RTSPServer_Internal* in = (PL_RTSPServer_Internal*)internal;
+	RTSPServer_Internal* in = (RTSPServer_Internal*)internal;
 
+	if (pm.buffer == nullptr)
+		return false;
+	
+	if (pm.type != PipeMaterial::PMT_FRAME)
+	{
+		LOG_ERROR << "PL_RTSPServer::pay only support PMT_FRAME" << std::endl;
+		return false;
+	}
+	
+	if (in->buffSize > 0)
+		LOG_WARN << "PL_RTSPServer::pay may lost data size=" << in->buffSize << std::endl;
+	
+	MB_Frame* frame = (MB_Frame*)pm.buffer;
+	if (frame->buffer == nullptr)
+		return false;
+	memcpy(in->buffer, frame->buffer, frame->buffSize);
+	in->buffSize = frame->buffSize;
+	
+	if (in->encoderStub == nullptr)
+		return false;
+	
+	in->encoderStub->deliverFrame();
 	return true;
 }
 
 bool PL_RTSPServer::gain(PipeMaterial& pm)
 {
-	PL_RTSPServer_Internal* in = (PL_RTSPServer_Internal*)internal;
+	RTSPServer_Internal* in = (RTSPServer_Internal*)internal;
 
+	pm.type = PipeMaterial::PMT_NONE;
 	pm.buffer = nullptr;
 	pm.buffSize = 0;
 	pm.former = this;

--
Gitblit v1.8.0