98 lines
2.5 KiB
C++
98 lines
2.5 KiB
C++
#ifndef F9CED6CA_74FC_49C3_8D58_95A62F2EA1EC
|
|
#define F9CED6CA_74FC_49C3_8D58_95A62F2EA1EC
|
|
/*
|
|
*******************************************************************************
|
|
* INCLUDE
|
|
*******************************************************************************
|
|
*/
|
|
#include "../core/Muxer.h"
|
|
#include "util/ClassAssistant.h"
|
|
#include <sdk/include/sockutil.h>
|
|
#include <media-server/libmpeg/mpeg-muxer.h>
|
|
#include <media-server/libmpeg/mpeg-proto.h>
|
|
|
|
/*
|
|
*******************************************************************************
|
|
* MACROS
|
|
*******************************************************************************
|
|
*/
|
|
#define TRACE_VIDEO_FRAME_RATE (0)
|
|
|
|
namespace Video
|
|
{
|
|
namespace MediaServer
|
|
{
|
|
/*
|
|
*******************************************************************************
|
|
* CLASS DECLARE
|
|
*******************************************************************************
|
|
*/
|
|
class MPEGMuxer: public Core::Muxer
|
|
{
|
|
private:
|
|
class Stream
|
|
{
|
|
public:
|
|
using Ptr = Poco::SharedPtr<Stream>;
|
|
|
|
public:
|
|
Stream(const std::string& name, int id, Core::PacketQueue::Ptr pQueue);
|
|
~Stream();
|
|
|
|
public:
|
|
bool operator<(const Stream& other);
|
|
Core::PacketQueue::Ptr queue();
|
|
Core::SerialCodeWatcher& serialCodeWatcher();
|
|
|
|
PROPERTY_DECLARE(Timeline, uint64_t, 0, public, public);
|
|
READONLY_PROPERTY_DECLARE(name, std::string)
|
|
READONLY_PROPERTY_DECLARE(id, int)
|
|
|
|
private:
|
|
Core::PacketQueue::Ptr _pQueue;
|
|
Core::SerialCodeWatcher _serialCodeWatcher;
|
|
};
|
|
|
|
public:
|
|
MPEGMuxer(const std::string& url);
|
|
~MPEGMuxer();
|
|
|
|
protected:
|
|
void connect() override;
|
|
void mux() override;
|
|
void disconnect() override;
|
|
void flush();
|
|
|
|
const int getCodecID(Core::CodecID id);
|
|
|
|
private:
|
|
socket_t _socket;
|
|
struct sockaddr_in _destAddr;
|
|
mpeg_muxer_t* _pMuxer;
|
|
std::vector<Stream::Ptr> _streams;
|
|
|
|
uint8_t _buffer[1316];
|
|
int _writeIndex;
|
|
#if (TRACE_VIDEO_FRAME_RATE)
|
|
int count = 0;
|
|
uint64_t timeline = 0;
|
|
#endif
|
|
};
|
|
|
|
inline bool MPEGMuxer::Stream::operator<(const Stream& other)
|
|
{
|
|
return _Timeline < other._Timeline;
|
|
}
|
|
|
|
inline Core::PacketQueue::Ptr MPEGMuxer::Stream::queue()
|
|
{
|
|
return _pQueue;
|
|
}
|
|
|
|
inline Core::SerialCodeWatcher& MPEGMuxer::Stream::serialCodeWatcher()
|
|
{
|
|
return _serialCodeWatcher;
|
|
}
|
|
}
|
|
}
|
|
#endif
|