The C++ framework for developing highly scalable, high performance servers on Windows platforms.

JetByteTools::Streaming

JetByteTools::Streaming Namespace Reference


Classes

class  CAsynchronousFileBackedH264InterleavedTCPRTPStream
class  CAsynchronousFileBackedH264RTPStream
class  CAsynchronousFileBackedH264UDPRTPStream
class  CAsynchronousH264FileReader
class  CBitParser
class  CH264FrameProcessor
class  CH264FrameSource
class  CH264NALUnit
class  CH264ParameterSetReader
class  CH264RTPSource
class  CH264SequenceParameterSetParser
class  CH264SliceHeaderParser
class  CH264StreamParser
class  CH264StreamReader
class  CHLSFileResource
class  CHLSH264LiveResource
class  CHLSLiveResource
class  CHLSMemoryCacheResourceData
class  CHLSResource
class  IAcceptH264FrameData
class  IAcceptH264NALUnits
class  IAcceptLiveVideoData
class  IAcceptLiveVideoDataNotifications
class  IAcceptStreamData
class  IAllocateSSRCs
class  IAllocateStreamDataFiles
class  IBroadcastRTPStreams
class  ICreateRTPPackets
class  ICreateUDPConnections
class  IGenerateRTCPPackets
class  IInterleavedRTPTCPStream
class  IManagePacketStreamLifetime
class  IManageRTSPResources
class  IManageRTSPSessions
class  IManageRTSPSessionTimeouts
class  INotifyOnLastStreamDataWrite
class  INotifyOnMemoryCacheStreamWritten
class  CInterleavedTCPRTPStream
class  IProcessPayloadFrames
class  IProcessRTPFrames
class  IProvideH264NALUnits
class  IProvideRTPData
class  IProvideStreamData
class  IReleaseSSRCs
class  IRTPPacketStream
class  IRTPStreamRefCount
class  IRTPStream
class  IRTSPResource
class  IRTSPServer
class  IRTSPSession
class  ISaveStreamData
class  IStreamDataFileFactory
class  ITransmitRTCPPackets
class  ITransmitRTPPackets
class  CLiveH264InterleavedTCPRTPStream
class  CLiveH264RTPStream
class  CLiveH264UDPRTPStream
class  CMemoryCacheStreamDataFile
class  CMPEG2TransportStreamWriter
class  CNullRTPStream
class  CNullStreamDataFile
class  CRandomSSRCAllocator
class  CRTCPPacketGenerator
class  CRTPBroadcastPacketCache
class  CRTPFrameProcessor
class  CRTPPacketCreator
class  CRTPPacketStream
class  CRTSP_1_0_RequestParser
class  CRTSPConnection
class  CRTSPH264FileResource
class  CRTSPH264LiveResource
class  CRTSPMP3FileResource
class  CRTSPMultipleFileResource
class  CRTSPResourceManager
class  CRTSPServer
class  CRTSPSession
class  CStreamDataFile
class  CStreamDataFileFactory
class  CSynchronousFileBackedH264RTPStream
class  CSynchronousH264FileReader
class  CTimeStamp
class  CUDPConnectionCreator
class  CUDPRTPStream

Typedefs

typedef
JetByteTools::Core::TReferenceCountedSmartPointer
< IRTPStream > 		CSmartRTPStream
typedef
JetByteTools::Core::TReferenceCountedSmartPointer
< IRTSPResource > 		CSmartRTSPResource
typedef
JetByteTools::Core::TReferenceCountedSmartPointer
< IRTSPSession > 		CSmartRTSPSession
typedef BYTE RTPPayloadType
typedef
JetByteTools::Core::TReferenceCountedSmartPointer
< IInterleavedRTPTCPStream > 		CSmartRTSPConnection

Functions

static DWORD CalculateMTU (DWORD mtu, const IAllocateBuffers &bufferAllocator)
static
CH264FrameSource::ParameterSetOptions 		ValidateParameterSetOptions (DWORD parameterSetOptions)
static bool GetFrameRateIfPresentInVUIParameters (CBitParser &bitParser, double &frameRate)
static string GetFileName (DWORD index)
static string BuildplaylistHeader (Milliseconds maxTimePerFile)
static void CreateOrUpdateActiveFile (const _tstring &filename, const string &data)
static BYTE * InitialisePacket (BYTE *pPacket)
static BYTE * SetTransportStreamHeader (BYTE *pPacket, const unsigned short pid, const bool payloadStart, const bool payload, const bool adaption, BYTE &continuity)
static BYTE * BuildPAT (BYTE *pPacket, BYTE &continuity)
static BYTE * BuildPMT (BYTE *pPacket, BYTE &continuity)
static BYTE BuildFlags (const bool discontinuity, const bool randomAccessPoint, const bool esPriority, const bool pcr, const bool opcr, const bool splice, const bool priv, const bool extended)
static BYTE * SetAdaptationHeader (BYTE *pPacket, const bool includeFlags, const bool discontinuity, const bool randomAccessPoint, const bool esPriority, const BYTE paddingLength, BYTE &bytesLeft)
static BYTE * SetPCRAdaptationHeader (BYTE *pPacket, const bool discontinuity, const bool randomAccessPoint, const bool esPriority, const DWORD pcr, const BYTE paddingLength, BYTE &bytesLeft)
static BYTE * SetAdaptationHeader (BYTE *pPacket, BYTE &bytesLeftInThisPacket, const bool needsPCR, const DWORD pcr, const DWORD dataLeft, const bool needsPadding)
static BYTE * SetPESHeader (BYTE *pPacket, const DWORD pts, const DWORD dts, BYTE &bytesLeft)
static void AddNetworkByteOrderDWORD (CSmartBuffer &buffer, DWORD value)
static __int64 GetStartTime (const IProvideSystemTime &systemTimeProvider)
static const string LineEnd ("\r\n")
static void ValidateSupportedTransports (IManageRTSPResources::SupportedTransports supportedTransports)
static string GetOptionalHeader (const CHTTPHeaders &headers, const string &header)
static string GetOptionalHeaderWithDefault (const CHTTPHeaders &headers, const string &header, const string &defaultValue)
static void SplitUri (const string &completeUri, string &hostAddress, string &port, string &uri)
static string SplitUri (const string &completeUri)
static CSmartHandle OpenFile (const _tstring &filename)
static string BuildTransportString (const IFullAddress &rtpClientAddress, const IFullAddress &rtcpClientAddress, const IDatagramSocket &rtpSocket, const IDatagramSocket &rtcpSocket)

Variables

static const BYTE s_singleBitMask [8] = { 0x80, 0x40, 0x20, 0x10, 0x08, 0x04, 0x02, 0x01}
static const BYTE F_ZERO_MASK = 0x80
static const BYTE NRI_MASK = 0x60
static const BYTE TYPE_MASK = 0x1F
const DWORD SPS_ReportMask = CH264FrameSource::SPS_ReportFirst | CH264FrameSource::SPS_ReportAll
const DWORD SPS_ProcessMask = CH264FrameSource::SPS_GetFrameRate | SPS_ReportMask
const DWORD SPS_Mask = CH264FrameSource::SPS_Strip | SPS_ProcessMask
const DWORD PPS_ProcessMask = CH264FrameSource::PPS_ReportFirst | CH264FrameSource::PPS_ReportAll
const DWORD PPS_Mask = PPS_ProcessMask
const DWORD SPS_PPS_Valid = SPS_Mask | PPS_Mask
static const BYTE s_startCode []
static const BYTE s_packetSize = 188
static const BYTE s_tsHeaderSize = 4
static const BYTE s_minPESHeaderLength = 9
static const BYTE s_PESWithPTSDTSLength = s_minPESHeaderLength + 10
static const BYTE s_adaptionHeaderLength = 1
static const BYTE s_adaptionWithPCRLength = 8
static const BYTE s_packetLessHeader = s_packetSize - s_tsHeaderSize
static const WORD VERSION_MASK = 0xC000
static const WORD PADDING_MASK = 0x2000
static const WORD EXTENSION_MASK = 0x1000
static const WORD CC_MASK = 0x0F00
static const WORD MARKER_MASK = 0x0080
static const WORD PAYLOAD_TYPE_MASK = 0x007F
static const DWORD s_minRTPPacketSize = 12
static const size_t LineEndLength = LineEnd.length()
static const std::string s_RTSPMethodANNOUNCE = "ANNOUNCE"
static const std::string s_RTSPMethodDESCRIBE = "DESCRIBE"
static const std::string s_RTSPMethodOPTIONS = "OPTIONS"
static const std::string s_RTSPMethodPAUSE = "PAUSE"
static const std::string s_RTSPMethodPLAY = "PLAY"
static const std::string s_RTSPMethodSETUP = "SETUP"
static const std::string s_RTSPMethodTEARDOWN = "TEARDOWN"
static const std::string s_RTSPMethodGET_PARAMETER = "GET_PARAMETER"
static const std::string s_RTSPMethodSET_PARAMETER = "SET_PARAMETER"
static const std::string s_RTSPMethodRECORD = "RECORD"
static const std::string s_RTSPMethodREDIRECT = "REDIRECT"
static const DWORD s_maxRTSPMethodLength
CRandomSSRCAllocator s_ssrcAllocator
CSystemTimeProvider s_systemTimeProvider
static
CSystemTimeProvider 		s_systemTimeProvider

Typedef Documentation

typedef JetByteTools::Core::TReferenceCountedSmartPointer<IRTPStream> CSmartRTPStream

typedef JetByteTools::Core::TReferenceCountedSmartPointer<IInterleavedRTPTCPStream> CSmartRTSPConnection

typedef JetByteTools::Core::TReferenceCountedSmartPointer<IRTSPResource> CSmartRTSPResource

typedef JetByteTools::Core::TReferenceCountedSmartPointer<IRTSPSession> CSmartRTSPSession

typedef BYTE RTPPayloadType

Function Documentation

static void AddNetworkByteOrderDWORD ( CSmartBuffer &  buffer,
DWORD  value 
) [static]

static BYTE JetByteTools::Streaming::BuildFlags ( const bool  discontinuity,
const bool  randomAccessPoint,
const bool  esPriority,
const bool  pcr,
const bool  opcr,
const bool  splice,
const bool  priv,
const bool  extended 
) [static]

static BYTE* JetByteTools::Streaming::BuildPAT ( BYTE *  pPacket,
BYTE &  continuity 
) [static]

static string JetByteTools::Streaming::BuildplaylistHeader ( Milliseconds  maxTimePerFile  )  [static]

static BYTE* JetByteTools::Streaming::BuildPMT ( BYTE *  pPacket,
BYTE &  continuity 
) [static]

static string BuildTransportString ( const IFullAddress &  rtpClientAddress,
const IFullAddress &  rtcpClientAddress,
const IDatagramSocket &  rtpSocket,
const IDatagramSocket &  rtcpSocket 
) [static]

static DWORD CalculateMTU ( DWORD  mtu,
const IAllocateBuffers &  bufferAllocator 
) [static]

static void CreateOrUpdateActiveFile ( const _tstring &  filename,
const string &  data 
) [static]

static string GetFileName ( DWORD  index  )  [static]

static bool GetFrameRateIfPresentInVUIParameters ( CBitParser &  bitParser,
double &  frameRate 
) [static]

static string GetOptionalHeader ( const CHTTPHeaders &  headers,
const string &  header 
) [static]

static string GetOptionalHeaderWithDefault ( const CHTTPHeaders &  headers,
const string &  header,
const string &  defaultValue 
) [static]

static __int64 GetStartTime ( const IProvideSystemTime &  systemTimeProvider  )  [static]

static BYTE* JetByteTools::Streaming::InitialisePacket ( BYTE *  pPacket  )  [static]

static const string JetByteTools::Streaming::LineEnd ( "\r\n"   )  [static]

static CSmartHandle OpenFile ( const _tstring &  filename  )  [static]

static BYTE* JetByteTools::Streaming::SetAdaptationHeader ( BYTE *  pPacket,
BYTE &  bytesLeftInThisPacket,
const bool  needsPCR,
const DWORD  pcr,
const DWORD  dataLeft,
const bool  needsPadding 
) [static]

static BYTE* JetByteTools::Streaming::SetAdaptationHeader ( BYTE *  pPacket,
const bool  includeFlags,
const bool  discontinuity,
const bool  randomAccessPoint,
const bool  esPriority,
const BYTE  paddingLength,
BYTE &  bytesLeft 
) [static]

static BYTE* JetByteTools::Streaming::SetPCRAdaptationHeader ( BYTE *  pPacket,
const bool  discontinuity,
const bool  randomAccessPoint,
const bool  esPriority,
const DWORD  pcr,
const BYTE  paddingLength,
BYTE &  bytesLeft 
) [static]

| Base @ 90khz |PAD |Ext @ 27Mhz | 33 bits | | 9 bits |

|012345670123456701234567012345670123456701234567|

static BYTE* JetByteTools::Streaming::SetPESHeader ( BYTE *  pPacket,
const DWORD  pts,
const DWORD  dts,
BYTE &  bytesLeft 
) [static]

static BYTE* JetByteTools::Streaming::SetTransportStreamHeader ( BYTE *  pPacket,
const unsigned short  pid,
const bool  payloadStart,
const bool  payload,
const bool  adaption,
BYTE &  continuity 
) [static]

static string SplitUri ( const string &  completeUri  )  [static]

static void SplitUri ( const string &  completeUri,
string &  hostAddress,
string &  port,
string &  uri 
) [static]

static CH264FrameSource::ParameterSetOptions ValidateParameterSetOptions ( DWORD  parameterSetOptions  )  [static]

static void ValidateSupportedTransports ( IManageRTSPResources::SupportedTransports  supportedTransports  )  [static]

Variable Documentation

const WORD CC_MASK = 0x0F00 [static]

const WORD EXTENSION_MASK = 0x1000 [static]

const BYTE F_ZERO_MASK = 0x80 [static]

const size_t LineEndLength = LineEnd.length() [static]

const WORD MARKER_MASK = 0x0080 [static]

const BYTE NRI_MASK = 0x60 [static]

const WORD PADDING_MASK = 0x2000 [static]

const WORD PAYLOAD_TYPE_MASK = 0x007F [static]

const DWORD PPS_Mask = PPS_ProcessMask

const DWORD PPS_ProcessMask = CH264FrameSource::PPS_ReportFirst | CH264FrameSource::PPS_ReportAll

const BYTE s_adaptionHeaderLength = 1 [static]

const BYTE s_adaptionWithPCRLength = 8 [static]

const DWORD s_maxRTSPMethodLength [static]

Initial value:

 static_cast<DWORD>(std::max(s_RTSPMethodANNOUNCE.length(),
                                                              std::max(s_RTSPMethodDESCRIBE.length(),
                                                              std::max(s_RTSPMethodOPTIONS.length(),
                                                              std::max(s_RTSPMethodPAUSE.length(),
                                                              std::max(s_RTSPMethodPLAY.length(),
                                                              std::max(s_RTSPMethodSETUP.length(),
                                                              std::max(s_RTSPMethodTEARDOWN.length(),
                                                              std::max(s_RTSPMethodGET_PARAMETER.length(),
                                                              std::max(s_RTSPMethodSET_PARAMETER.length(),
                                                              std::max(s_RTSPMethodRECORD.length(),
                                                                       s_RTSPMethodREDIRECT.length())))))))))))

const BYTE s_minPESHeaderLength = 9 [static]

const DWORD s_minRTPPacketSize = 12 [static]

const BYTE s_packetLessHeader = s_packetSize - s_tsHeaderSize [static]

const BYTE s_packetSize = 188 [static]

const BYTE s_PESWithPTSDTSLength = s_minPESHeaderLength + 10 [static]

const std::string s_RTSPMethodANNOUNCE = "ANNOUNCE" [static]

const std::string s_RTSPMethodDESCRIBE = "DESCRIBE" [static]

const std::string s_RTSPMethodGET_PARAMETER = "GET_PARAMETER" [static]

const std::string s_RTSPMethodOPTIONS = "OPTIONS" [static]

const std::string s_RTSPMethodPAUSE = "PAUSE" [static]

const std::string s_RTSPMethodPLAY = "PLAY" [static]

const std::string s_RTSPMethodRECORD = "RECORD" [static]

const std::string s_RTSPMethodREDIRECT = "REDIRECT" [static]

const std::string s_RTSPMethodSET_PARAMETER = "SET_PARAMETER" [static]

const std::string s_RTSPMethodSETUP = "SETUP" [static]

const std::string s_RTSPMethodTEARDOWN = "TEARDOWN" [static]

const BYTE s_singleBitMask[8] = { 0x80, 0x40, 0x20, 0x10, 0x08, 0x04, 0x02, 0x01} [static]

CRandomSSRCAllocator s_ssrcAllocator

const BYTE s_startCode[] [static]

Initial value:

{
   0x00, 0x00, 0x00, 0x01
}

CSystemTimeProvider s_systemTimeProvider [static]

CSystemTimeProvider s_systemTimeProvider

const BYTE s_tsHeaderSize = 4 [static]

const DWORD SPS_Mask = CH264FrameSource::SPS_Strip | SPS_ProcessMask

const DWORD SPS_PPS_Valid = SPS_Mask | PPS_Mask

const DWORD SPS_ProcessMask = CH264FrameSource::SPS_GetFrameRate | SPS_ReportMask

const DWORD SPS_ReportMask = CH264FrameSource::SPS_ReportFirst | CH264FrameSource::SPS_ReportAll

const BYTE TYPE_MASK = 0x1F [static]

const WORD VERSION_MASK = 0xC000 [static]

Generated on Sun Sep 12 19:11:02 2021 for The Server Framework - v7.4 by doxygen 1.5.3