支持自定义环形缓冲大小

This commit is contained in:
xiongziliang 2018-12-29 17:38:10 +08:00
parent 41e5cab6c6
commit 5b5db04543
4 changed files with 8 additions and 6 deletions

View File

@ -53,9 +53,9 @@ public:
typedef std::shared_ptr<RtmpMediaSource> Ptr;
typedef RingBuffer<RtmpPacket::Ptr> RingType;
RtmpMediaSource(const string &vhost,const string &strApp, const string &strId) :
RtmpMediaSource(const string &vhost,const string &strApp, const string &strId,int ringSize = 32) :
MediaSource(RTMP_SCHEMA,vhost,strApp,strId),
_pRing(new RingBuffer<RtmpPacket::Ptr>()) {
_pRing(new RingBuffer<RtmpPacket::Ptr>(ringSize)) {
}
virtual ~RtmpMediaSource() {}

View File

@ -53,7 +53,8 @@ public:
const string &app,
const string &id,
bool bEnableHls = true,
bool bEnableMp4 = false):RtmpMediaSource(vhost, app, id){
bool bEnableMp4 = false,
int ringSize = 32):RtmpMediaSource(vhost, app, id,ringSize){
_recorder = std::make_shared<MediaRecorder>(vhost, app, id, bEnableHls, bEnableMp4);
}
virtual ~RtmpToRtspMediaSource(){}

View File

@ -55,9 +55,9 @@ public:
typedef std::shared_ptr<RtspMediaSource> Ptr;
typedef RingBuffer<RtpPacket::Ptr> RingType;
RtspMediaSource(const string &strVhost,const string &strApp, const string &strId) :
RtspMediaSource(const string &strVhost,const string &strApp, const string &strId,int ringSize = 32) :
MediaSource(RTSP_SCHEMA,strVhost,strApp,strId),
_pRing(new RingBuffer<RtpPacket::Ptr>()) {
_pRing(new RingBuffer<RtpPacket::Ptr>(ringSize)) {
}
virtual ~RtspMediaSource() {}

View File

@ -46,7 +46,8 @@ public:
const string &app,
const string &id,
bool bEnableHls = true,
bool bEnableMp4 = false) : RtspMediaSource(vhost, app, id) {
bool bEnableMp4 = false,
int ringSize = 32) : RtspMediaSource(vhost, app, id,ringSize) {
_recorder = std::make_shared<MediaRecorder>(vhost, app, id, bEnableHls, bEnableMp4);
}