//
|
// LiveRTSPServer.cpp
|
// FFmpegRTSPServer
|
//
|
// Created by Mina Saad on 9/22/15.
|
// Copyright (c) 2015 Mina Saad. All rights reserved.
|
//
|
|
#include "../logger.h"
|
#include "LiveRTSPServer.h"
|
|
namespace MESAI
|
{
|
LiveRTSPServer::LiveRTSPServer( IEncoder * a_Encoder, int port, int httpPort )
|
: env(nullptr), framedSource(nullptr),
|
m_Encoder (a_Encoder), portNumber(port), httpTunnelingPort(httpPort)
|
{
|
quit = 0;
|
}
|
|
LiveRTSPServer::~LiveRTSPServer()
|
{
|
|
}
|
|
void LiveRTSPServer::init()
|
{
|
TaskScheduler* scheduler = BasicTaskScheduler::createNew();
|
env = BasicUsageEnvironment::createNew(*scheduler);
|
}
|
|
void LiveRTSPServer::run()
|
{
|
if (env == nullptr)
|
init();
|
|
char RTSP_Address[1024];
|
RTSP_Address[0]=0x00;
|
|
UserAuthenticationDatabase* authDB = NULL;
|
|
// if (m_Enable_Pass){
|
// authDB = new UserAuthenticationDatabase;
|
// authDB->addUserRecord(UserN, PassW);
|
// }
|
|
OutPacketBuffer::maxSize = 2000000;
|
RTSPServer* rtspServer = RTSPServer::createNew(*env, portNumber, authDB);
|
|
if (rtspServer == NULL)
|
{
|
LOG_ERROR <<"LIVE555: Failed to create RTSP server: " << env->getResultMsg() << LOG_ENDL;
|
}
|
else
|
{
|
if(httpTunnelingPort)
|
{
|
rtspServer->setUpTunnelingOverHTTP(httpTunnelingPort);
|
}
|
|
char const* descriptionString = "MESAI Streaming Session";
|
|
if (framedSource == nullptr)
|
framedSource = FFmpegH264Source::createNew(*env,m_Encoder);
|
StreamReplicator * inputDevice = StreamReplicator::createNew(*env, framedSource, false);
|
|
ServerMediaSession* sms = ServerMediaSession::createNew(*env, RTSP_Address, RTSP_Address, descriptionString);
|
sms->addSubsession(MESAI::LiveServerMediaSubsession::createNew(*env, inputDevice));
|
rtspServer->addServerMediaSession(sms);
|
|
char* url = rtspServer->rtspURL(sms);
|
LOG_INFO << "Play this stream using the URL " << url << LOG_ENDL;
|
delete [] url;
|
|
//signal(SIGNIT,sighandler);
|
env->taskScheduler().doEventLoop(&quit); // does not return
|
|
Medium::close(rtspServer);
|
Medium::close(inputDevice);
|
}
|
|
env->reclaim();
|
//delete scheduler; // #todo
|
}
|
}
|
