You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
77 lines
3.0 KiB
C++
77 lines
3.0 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.
|
|
**
|
|
** MJPEGVideoSource.h
|
|
**
|
|
** V4L2 RTSP streamer
|
|
**
|
|
** MJPEG Source for RTSP server
|
|
**
|
|
** -------------------------------------------------------------------------*/
|
|
|
|
#pragma once
|
|
|
|
#include "logger.h"
|
|
#include "JPEGVideoSource.hh"
|
|
|
|
class MJPEGVideoSource : public JPEGVideoSource
|
|
{
|
|
public:
|
|
static MJPEGVideoSource* createNew (UsageEnvironment& env, FramedSource* source)
|
|
{
|
|
return new MJPEGVideoSource(env,source);
|
|
}
|
|
virtual void doGetNextFrame()
|
|
{
|
|
if (m_inputSource) {
|
|
m_inputSource->getNextFrame(fTo, fMaxSize, afterGettingFrameSub, this, FramedSource::handleClosure, this);
|
|
}
|
|
}
|
|
virtual void doStopGettingFrames()
|
|
{
|
|
FramedSource::doStopGettingFrames();
|
|
if (m_inputSource) {
|
|
m_inputSource->stopGettingFrames();
|
|
}
|
|
}
|
|
static void afterGettingFrameSub(void* clientData, unsigned frameSize,unsigned numTruncatedBytes,struct timeval presentationTime,unsigned durationInMicroseconds)
|
|
{
|
|
MJPEGVideoSource* source = (MJPEGVideoSource*)clientData;
|
|
source->afterGettingFrame(frameSize, numTruncatedBytes, presentationTime, durationInMicroseconds);
|
|
}
|
|
|
|
void afterGettingFrame(unsigned frameSize,unsigned numTruncatedBytes,struct timeval presentationTime,unsigned durationInMicroseconds);
|
|
virtual u_int8_t type() { return m_restartInterval ? m_type | 0x40 : m_type; };
|
|
virtual u_int8_t qFactor() { return 128; };
|
|
virtual u_int8_t width() { return m_width; };
|
|
virtual u_int8_t height() { return m_height; };
|
|
virtual u_int16_t restartInterval() { return m_restartInterval; }
|
|
|
|
u_int8_t const* quantizationTables( u_int8_t& precision, u_int16_t& length );
|
|
|
|
protected:
|
|
MJPEGVideoSource(UsageEnvironment& env, FramedSource* source) : JPEGVideoSource(env),
|
|
m_inputSource(source),
|
|
m_width(0), m_height(0), m_qTableSize(0), m_precision(0),
|
|
m_type(0), m_restartInterval(0)
|
|
{
|
|
memset(&m_qTable,0,sizeof(m_qTable));
|
|
}
|
|
virtual ~MJPEGVideoSource()
|
|
{
|
|
Medium::close(m_inputSource);
|
|
}
|
|
|
|
protected:
|
|
FramedSource* m_inputSource;
|
|
u_int8_t m_width;
|
|
u_int8_t m_height;
|
|
u_int8_t m_qTable[128*2];
|
|
unsigned int m_qTableSize;
|
|
unsigned int m_precision;
|
|
u_int8_t m_type;
|
|
u_int16_t m_restartInterval;
|
|
};
|