Archives/v4l2rtspserver
2
0
Fork 0
mirror of https://github.com/mpromonet/v4l2rtspserver synced 2024-11-19 15:25:34 +00:00
Code Issues Projects Releases Wiki Activity

make some experiment with MPEG-DASH

Browse Source
This commit is contained in:
mpromonet 2016-05-05 14:14:50 +00:00
parent ea8b2ae551
commit 53e9e0e1c9
1 changed files with 63 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

64
src/main.cpp
View File

@ -127,12 +127,74 @@ class HLSServer : public RTSPServer
this->streamSource(ByteStreamMemoryBufferSource::createNew(envir(), playListBuffer, playList.size())); this->streamSource(ByteStreamMemoryBufferSource::createNew(envir(), playListBuffer, playList.size()));
} }
void sendMpdPlayList(char const* urlSuffix)
{
ServerMediaSubsession* subsession = this->getSubsesion(urlSuffix);
if (subsession == NULL)
{
handleHTTPCmd_notSupported();
return;
}
float duration = subsession->duration();
if (duration <= 0.0)
{
handleHTTPCmd_notSupported();
return;
}
unsigned int startTime = subsession->getCurrentNPT(NULL);
HLSServer* hlsServer = (HLSServer*)(&fOurServer);
unsigned sliceDuration = hlsServer->m_hlsSegment;
std::ostringstream os;
os << "<?xml version='1.0' encoding='UTF-8'?>\r\n"
<< "<MPD type='dynamic' xmlns='urn:mpeg:DASH:schema:MPD:2011' profiles='urn:mpeg:dash:profile:full:2011' minimumUpdatePeriod='PT"<< sliceDuration <<"S' minBufferTime='" << sliceDuration << "'>\r\n"
<< "<Period start='PT0S'><AdaptationSet segmentAlignment='true'><Representation mimeType='video/mp2t' codecs='' >"
<< "<SegmentList duration='" << sliceDuration << "' startNumber='" << startTime << "' >\r\n";
for (unsigned int slice=0; slice*sliceDuration<duration; slice++)
{
os << "<SegmentURL media='" << urlSuffix << "?segment=" << (startTime+slice*sliceDuration) << "' />\r\n";
}
os << "</SegmentList></Representation></AdaptationSet></Period>\r\n";
os << "</MPD>\r\n";
const std::string& playList(os.str());
// send response header
this->sendHeader("application/dash+xml", playList.size());
// stream body
u_int8_t* playListBuffer = new u_int8_t[playList.size()];
memcpy(playListBuffer, playList.c_str(), playList.size());
this->streamSource(ByteStreamMemoryBufferSource::createNew(envir(), playListBuffer, playList.size()));
}
void handleHTTPCmd_StreamingGET(char const* urlSuffix, char const* /*fullRequestStr*/) void handleHTTPCmd_StreamingGET(char const* urlSuffix, char const* /*fullRequestStr*/)
{ {
char const* questionMarkPos = strrchr(urlSuffix, '?'); char const* questionMarkPos = strrchr(urlSuffix, '?');
if (questionMarkPos == NULL) if (questionMarkPos == NULL)
{ {
this->sendPlayList(urlSuffix); std::string streamName(urlSuffix);
std::string ext;
std::string url(urlSuffix);
size_t pos = url.find_last_of(".");
if (pos != std::string::npos)
{
streamName.assign(url.substr(0,pos));
ext.assign(url.substr(pos+1));
}
if (ext == "mpd")
{
this->sendMpdPlayList(streamName.c_str());
}
else
{
this->sendPlayList(streamName.c_str());
}
} }
else else
{ {