mirror of
https://github.com/mpromonet/v4l2rtspserver
synced 2024-11-17 21:25:40 +00:00
83 lines
3.2 KiB
C++
83 lines
3.2 KiB
C++
/* ---------------------------------------------------------------------------
|
|
** This software is in the public domain, furnished "as is", without technical
|
|
** support, and with no warranty, express or implied, as to its usefulness for
|
|
** any purpose.
|
|
**
|
|
** HTTPServer.h
|
|
**
|
|
** V4L2 RTSP streamer
|
|
**
|
|
** HTTP server that serves HLS & MPEG-DASH playlist and segments
|
|
**
|
|
** -------------------------------------------------------------------------*/
|
|
|
|
|
|
#include "RTSPServer.hh"
|
|
#include "RTSPCommon.hh"
|
|
|
|
// ---------------------------------------------------------
|
|
// Extend RTSP server to add support for HLS and MPEG-DASH
|
|
// ---------------------------------------------------------
|
|
class HTTPServer : public RTSPServer
|
|
{
|
|
|
|
class HTTPClientConnection : public RTSPServer::RTSPClientConnection
|
|
{
|
|
public:
|
|
HTTPClientConnection(RTSPServer& ourServer, int clientSocket, struct sockaddr_in clientAddr)
|
|
: RTSPServer::RTSPClientConnection(ourServer, clientSocket, clientAddr), fTCPSink(NULL), fStreamToken(NULL), fSubsession(NULL), fSource(NULL) {
|
|
}
|
|
virtual ~HTTPClientConnection();
|
|
|
|
private:
|
|
|
|
void sendHeader(const char* contentType, unsigned int contentLength);
|
|
void streamSource(FramedSource* source);
|
|
void streamSource(const std::string & content);
|
|
ServerMediaSubsession* getSubsesion(const char* urlSuffix);
|
|
bool sendFile(char const* urlSuffix);
|
|
bool sendM3u8PlayList(char const* urlSuffix);
|
|
bool sendMpdPlayList(char const* urlSuffix);
|
|
virtual void handleHTTPCmd_StreamingGET(char const* urlSuffix, char const* fullRequestStr);
|
|
virtual void handleCmd_notFound();
|
|
static void afterStreaming(void* clientData);
|
|
|
|
private:
|
|
static u_int32_t fClientSessionId;
|
|
TCPStreamSink* fTCPSink;
|
|
void* fStreamToken;
|
|
ServerMediaSubsession* fSubsession;
|
|
FramedSource* fSource;
|
|
};
|
|
|
|
public:
|
|
static HTTPServer* createNew(UsageEnvironment& env, Port rtspPort, UserAuthenticationDatabase* authDatabase, unsigned reclamationTestSeconds, unsigned int hlsSegment, const std::string webroot)
|
|
{
|
|
HTTPServer* httpServer = NULL;
|
|
int ourSocket = setUpOurSocket(env, rtspPort);
|
|
if (ourSocket != -1)
|
|
{
|
|
httpServer = new HTTPServer(env, ourSocket, rtspPort, authDatabase, reclamationTestSeconds, hlsSegment, webroot);
|
|
}
|
|
return httpServer;
|
|
}
|
|
|
|
HTTPServer(UsageEnvironment& env, int ourSocket, Port rtspPort, UserAuthenticationDatabase* authDatabase, unsigned reclamationTestSeconds, unsigned int hlsSegment, const std::string & webroot)
|
|
: RTSPServer(env, ourSocket, rtspPort, authDatabase, reclamationTestSeconds), m_hlsSegment(hlsSegment), m_webroot(webroot)
|
|
{
|
|
if ( (!m_webroot.empty()) && (*m_webroot.rend() != '/') ) {
|
|
m_webroot += "/";
|
|
}
|
|
}
|
|
|
|
RTSPServer::RTSPClientConnection* createNewClientConnection(int clientSocket, struct sockaddr_in clientAddr)
|
|
{
|
|
return new HTTPClientConnection(*this, clientSocket, clientAddr);
|
|
}
|
|
|
|
private:
|
|
const unsigned int m_hlsSegment;
|
|
std::string m_webroot;
|
|
};
|
|
|