首页 > 代码库 > Live555 直播源 以及MediaSubsession
Live555 直播源 以及MediaSubsession
/* * H264DeviceSource.hh * * Created on: 2014年7月19日 * Author: zjzhang */ #ifndef H264DEVICESOURCE_HH_ #define H264DEVICESOURCE_HH_ #include<DeviceSource.hh> class H264DeviceSource: public DeviceSource { public: static DeviceSource* createNew(UsageEnvironment& env,u_int8_t index=1,u_int width=352,u_int height=288,u_int fps=15,u_int kbps=100); protected: H264DeviceSource(UsageEnvironment& env,u_int8_t index,u_int width,u_int height,u_int fps,u_int kbps); virtual ~H264DeviceSource(); private: virtual void doGetNextFrame(); virtual unsigned maxFrameSize() const; int fHeight; int fWidth; void *fH264Encoder; u_int8_t * fBuffer; u_int fBufferSize; }; #endif /* H264DEVICESOURCE_HH_ */
/* * H264DeviceSource.cpp * * Created on: 2014年7月19日 * Author: zjzhang */ #include "H264DeviceSource.hh" #ifdef __cplusplus extern "C" { #endif #include "H264Stream.h" #ifdef __cplusplus } #endif DeviceSource* H264DeviceSource::createNew(UsageEnvironment& env, u_int8_t index, u_int width, u_int height, u_int fps, u_int kbps) { return new H264DeviceSource(env, index, width, height, fps, kbps); } H264DeviceSource::H264DeviceSource(UsageEnvironment& env, u_int8_t index, u_int width, u_int height, u_int fps, u_int kbps) : DeviceSource(env, DeviceParameters()) { openCamera(1); getFrame(1); fHeight = getHeight(1); fWidth = getWidth(1); openH264Encoder(fWidth, fHeight, fps, kbps, &fH264Encoder); fBufferSize = fHeight * fWidth * 3 / 2; fBuffer = new uint8_t[fBufferSize]; } H264DeviceSource::~H264DeviceSource() { // TODO Auto-generated destructor stub delete[] fBuffer; closeH264Encoder(fH264Encoder); closeCamera(1); } unsigned H264DeviceSource::maxFrameSize() const { // By default, this source has no maximum frame size. return 4096; } void H264DeviceSource::doGetNextFrame() { if (!isCurrentlyAwaitingData()) return; // we're not ready for the data yet unsigned char * rgbBuffer = getFrame(1); ConvertRGB2YUV(fWidth, fHeight, rgbBuffer, fBuffer); int newFrameSize = encodeFrame(fH264Encoder, fBuffer, fBufferSize); // Deliver the data here: if (newFrameSize < 0) { handleClosure(); return; } if (newFrameSize > fMaxSize) { fFrameSize = fMaxSize; fNumTruncatedBytes = newFrameSize - fMaxSize; } else { fFrameSize = newFrameSize; } if (fFrameSize > 0) { int result = 0; int p = 0; do { unsigned long len = 0; result = getNextPacket(fH264Encoder, fBuffer + p, &len); p += len; } while (result > 0); } gettimeofday(&fPresentationTime, NULL); // If you have a more accurate time - e.g., from an encoder - then use that instead. // If the device is *not* a 'live source' (e.g., it comes instead from a file or buffer), then set "fDurationInMicroseconds" here. memmove(fTo, fBuffer, fFrameSize); FramedSource::afterGetting(this); }
#ifndef _DEVIC_SERVER_MEDIA_SUBSESSION_HH #define _DEVICE_SERVER_MEDIA_SUBSESSION_HH #ifndef _ON_DEMAND_SERVER_MEDIA_SUBSESSION_HH #include "OnDemandServerMediaSubsession.hh" #endif class DeviceSource; class DeviceServerMediaSubsession: public OnDemandServerMediaSubsession { public: static DeviceServerMediaSubsession* createNew(UsageEnvironment& env, Boolean reuseFirstSource); // Used to implement "getAuxSDPLine()": void checkForAuxSDPLine1(); void afterPlayingDummy1(); protected: // we're a virtual base class DeviceServerMediaSubsession(UsageEnvironment& env, Boolean reuseFirstSource); virtual ~DeviceServerMediaSubsession(); void setDoneFlag() { fDoneFlag = ~0; } protected: // redefined virtual functions virtual char const* getAuxSDPLine(RTPSink* rtpSink, FramedSource* inputSource); virtual FramedSource* createNewStreamSource(unsigned clientSessionId, unsigned& estBitrate); virtual RTPSink* createNewRTPSink(Groupsock* rtpGroupsock, unsigned char rtpPayloadTypeIfDynamic, FramedSource* inputSource); private: char* fAuxSDPLine; char fDoneFlag; // used when setting up "fAuxSDPLine" RTPSink* fDummyRTPSink; // ditto }; #endif
#include "DeviceServerMediaSubsession.hh" #include "H264VideoRTPSink.hh" #include "DeviceSource.hh" #include "H264VideoStreamFramer.hh" #include "H264DeviceSource.hh" DeviceServerMediaSubsession* DeviceServerMediaSubsession::createNew(UsageEnvironment& env, Boolean reuseFirstSource) { return new DeviceServerMediaSubsession(env, reuseFirstSource); } DeviceServerMediaSubsession::DeviceServerMediaSubsession(UsageEnvironment& env, Boolean reuseFirstSource) : OnDemandServerMediaSubsession(env, reuseFirstSource) { } DeviceServerMediaSubsession::~DeviceServerMediaSubsession() { } FramedSource* DeviceServerMediaSubsession::createNewStreamSource( unsigned /*clientSessionId*/, unsigned& estBitrate) { DeviceSource* source = H264DeviceSource::createNew(envir()); return H264VideoStreamFramer::createNew(envir(), source); } RTPSink* DeviceServerMediaSubsession::createNewRTPSink(Groupsock* rtpGroupsock, unsigned char rtpPayloadTypeIfDynamic, FramedSource* /*inputSource*/) { return H264VideoRTPSink::createNew(envir(), rtpGroupsock, rtpPayloadTypeIfDynamic); } static void afterPlayingDummy(void* clientData) { DeviceServerMediaSubsession* subsess = (DeviceServerMediaSubsession*) clientData; subsess->afterPlayingDummy1(); } void DeviceServerMediaSubsession::afterPlayingDummy1() { // Unschedule any pending 'checking' task: envir().taskScheduler().unscheduleDelayedTask(nextTask()); // Signal the event loop that we're done: setDoneFlag(); } static void checkForAuxSDPLine(void* clientData) { DeviceServerMediaSubsession* subsess = (DeviceServerMediaSubsession*) clientData; subsess->checkForAuxSDPLine1(); } void DeviceServerMediaSubsession::checkForAuxSDPLine1() { char const* dasl; if (fAuxSDPLine != NULL) { // Signal the event loop that we're done: setDoneFlag(); } else if (fDummyRTPSink != NULL && (dasl = fDummyRTPSink->auxSDPLine()) != NULL) { fAuxSDPLine = strDup(dasl); fDummyRTPSink = NULL; // Signal the event loop that we're done: setDoneFlag(); } else if (!fDoneFlag) { // try again after a brief delay: int uSecsToDelay = 100000; // 100 ms nextTask() = envir().taskScheduler().scheduleDelayedTask(uSecsToDelay, (TaskFunc*) checkForAuxSDPLine, this); } } char const* DeviceServerMediaSubsession::getAuxSDPLine(RTPSink* rtpSink, FramedSource* inputSource) { if (fAuxSDPLine != NULL) return fAuxSDPLine; // it's already been set up (for a previous client) if (fDummyRTPSink == NULL) { // we're not already setting it up for another, concurrent stream // Note: For H264 video files, the 'config' information ("profile-level-id" and "sprop-parameter-sets") isn't known // until we start reading the file. This means that "rtpSink"s "auxSDPLine()" will be NULL initially, // and we need to start reading data from our file until this changes. fDummyRTPSink = rtpSink; // Start reading the file: fDummyRTPSink->startPlaying(*inputSource, afterPlayingDummy, this); // Check whether the sink's 'auxSDPLine()' is ready: checkForAuxSDPLine(this); } envir().taskScheduler().doEventLoop(&fDoneFlag); return fAuxSDPLine; }
Live555 直播源 以及MediaSubsession
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。