#include <StreamParser.hh>

Inheritance diagram for StreamParser:

[legend]

Collaboration diagram for StreamParser:

[legend]

Public Member Functions
virtual void	flushInput ()

Protected Types
typedef void()	clientContinueFunc(void clientData, unsigned char ptr, unsigned size, struct timeval presentationTime)

Protected Member Functions
	StreamParser (FramedSource inputSource, FramedSource::onCloseFunc onInputCloseFunc, void onInputCloseClientData, clientContinueFunc clientContinueFunc, void *clientContinueClientData)

virtual	~StreamParser ()

void	saveParserState ()

virtual void	restoreSavedParserState ()

u_int32_t	get4Bytes ()

u_int32_t	test4Bytes ()

u_int16_t	get2Bytes ()

u_int16_t	test2Bytes ()

u_int8_t	get1Byte ()

u_int8_t	test1Byte ()

void	getBytes (u_int8_t *to, unsigned numBytes)

void	testBytes (u_int8_t *to, unsigned numBytes)

void	skipBytes (unsigned numBytes)

void	skipBits (unsigned numBits)

unsigned	getBits (unsigned numBits)

unsigned	curOffset () const

unsigned &	totNumValidBytes ()

Boolean	haveSeenEOF () const

unsigned	bankSize () const

Private Member Functions
unsigned char *	curBank ()

unsigned char *	nextToParse ()

unsigned char *	lastParsed ()

void	ensureValidBytes (unsigned numBytesNeeded)

void	ensureValidBytes1 (unsigned numBytesNeeded)

void	afterGettingBytes1 (unsigned numBytesRead, struct timeval presentationTime)

void	onInputClosure1 ()

Static Private Member Functions
static void	afterGettingBytes (void *clientData, unsigned numBytesRead, unsigned numTruncatedBytes, struct timeval presentationTime, unsigned durationInMicroseconds)

static void	onInputClosure (void *clientData)

Private Attributes
FramedSource *	fInputSource

FramedSource::onCloseFunc *	fClientOnInputCloseFunc

void *	fClientOnInputCloseClientData

clientContinueFunc *	fClientContinueFunc

void *	fClientContinueClientData

unsigned char *	fBank [2]

unsigned char	fCurBankNum

unsigned char *	fCurBank

unsigned	fSavedParserIndex

unsigned char	fSavedRemainingUnparsedBits

unsigned	fCurParserIndex

unsigned char	fRemainingUnparsedBits

unsigned	fTotNumValidBytes

Boolean	fHaveSeenEOF

struct timeval	fLastSeenPresentationTime

Detailed Description

Definition at line 28 of file StreamParser.hh.

Member Typedef Documentation

◆ clientContinueFunc

typedef void() StreamParser::clientContinueFunc(void *clientData, unsigned char *ptr, unsigned size, struct timeval presentationTime)

protected

Definition at line 33 of file StreamParser.hh.

Constructor & Destructor Documentation

◆ StreamParser()

StreamParser::StreamParser	(	FramedSource *	inputSource,
		FramedSource::onCloseFunc *	onInputCloseFunc,
		void *	onInputCloseClientData,
		clientContinueFunc *	clientContinueFunc,
		void *	clientContinueClientData
	)

protected

◆ ~StreamParser()

virtual StreamParser::~StreamParser ( )

protectedvirtual

Member Function Documentation

◆ afterGettingBytes()

static void StreamParser::afterGettingBytes	(	void *	clientData,
		unsigned	numBytesRead,
		unsigned	numTruncatedBytes,
		struct timeval	presentationTime,
		unsigned	durationInMicroseconds
	)

staticprivate

◆ afterGettingBytes1()

void StreamParser::afterGettingBytes1	(	unsigned	numBytesRead,
		struct timeval	presentationTime
	)

private

◆ bankSize()

unsigned StreamParser::bankSize ( ) const

protected

◆ curBank()

unsigned char * StreamParser::curBank ( )

inlineprivate

Definition at line 116 of file StreamParser.hh.

116{ return fCurBank; }

StreamParser::fCurBank

unsigned char * fCurBank

Definition: StreamParser.hh:148

References fCurBank.

Referenced by get1Byte(), lastParsed(), and nextToParse().

◆ curOffset()

unsigned StreamParser::curOffset ( ) const

inlineprotected

Definition at line 107 of file StreamParser.hh.

107{ return fCurParserIndex; }

StreamParser::fCurParserIndex

unsigned fCurParserIndex

Definition: StreamParser.hh:155

References fCurParserIndex.

◆ ensureValidBytes()

void StreamParser::ensureValidBytes ( unsigned numBytesNeeded )

inlineprivate

Definition at line 121 of file StreamParser.hh.

                                                 {
    // common case: inlined:
    if (fCurParserIndex + numBytesNeeded <= fTotNumValidBytes) return;
 
    ensureValidBytes1(numBytesNeeded);
  }

References ensureValidBytes1(), fCurParserIndex, and fTotNumValidBytes.

Referenced by get1Byte(), get2Bytes(), skipBytes(), test1Byte(), test2Bytes(), test4Bytes(), and testBytes().

◆ ensureValidBytes1()

void StreamParser::ensureValidBytes1 ( unsigned numBytesNeeded )

private

Referenced by ensureValidBytes().

◆ flushInput()

virtual void StreamParser::flushInput ( )

virtual

◆ get1Byte()

u_int8_t StreamParser::get1Byte ( )

inlineprotected

Definition at line 79 of file StreamParser.hh.

                      { // byte-aligned
    ensureValidBytes(1);
    fRemainingUnparsedBits = 0;
    return curBank()[fCurParserIndex++];
  }

References curBank(), ensureValidBytes(), fCurParserIndex, and fRemainingUnparsedBits.

Referenced by MPEGVideoStreamParser::saveToNextCode(), and MPEGVideoStreamParser::skipToNextCode().

◆ get2Bytes()

u_int16_t StreamParser::get2Bytes ( )

inlineprotected

Definition at line 60 of file StreamParser.hh.

                        {
    ensureValidBytes(2);
 
    unsigned char const* ptr = nextToParse();
    u_int16_t result = (ptr[0]<<8)|ptr[1];
 
    fCurParserIndex += 2;
    fRemainingUnparsedBits = 0;
 
    return result;
  }

References ensureValidBytes(), fCurParserIndex, fRemainingUnparsedBits, and nextToParse().

◆ get4Bytes()

u_int32_t StreamParser::get4Bytes ( )

inlineprotected

Definition at line 46 of file StreamParser.hh.

                        { // byte-aligned; returned in big-endian order
    u_int32_t result = test4Bytes();
    fCurParserIndex += 4;
    fRemainingUnparsedBits = 0;
 
    return result;
  }

References fCurParserIndex, fRemainingUnparsedBits, and test4Bytes().

Referenced by MPEGVideoStreamParser::saveToNextCode(), and MPEGVideoStreamParser::skipToNextCode().

◆ getBits()

unsigned StreamParser::getBits ( unsigned numBits )

protected

◆ getBytes()

void StreamParser::getBytes	(	u_int8_t *	to,
		unsigned	numBytes
	)

inlineprotected

Definition at line 89 of file StreamParser.hh.

                                                 {
    testBytes(to, numBytes);
    fCurParserIndex += numBytes;
    fRemainingUnparsedBits = 0;
  }

References fCurParserIndex, fRemainingUnparsedBits, and testBytes().

◆ haveSeenEOF()

Boolean StreamParser::haveSeenEOF ( ) const

inlineprotected

Definition at line 111 of file StreamParser.hh.

111{ return fHaveSeenEOF; }

StreamParser::fHaveSeenEOF

Boolean fHaveSeenEOF

Definition: StreamParser.hh:162

References fHaveSeenEOF.

◆ lastParsed()

unsigned char * StreamParser::lastParsed ( )

inlineprivate

Definition at line 118 of file StreamParser.hh.

118{ return &curBank()[fCurParserIndex-1]; }

References curBank(), and fCurParserIndex.

◆ nextToParse()

unsigned char * StreamParser::nextToParse ( )

inlineprivate

Definition at line 117 of file StreamParser.hh.

117{ return &curBank()[fCurParserIndex]; }

References curBank(), and fCurParserIndex.

Referenced by get2Bytes(), test1Byte(), test2Bytes(), test4Bytes(), and testBytes().

◆ onInputClosure()

static void StreamParser::onInputClosure ( void * clientData )

staticprivate

◆ onInputClosure1()

void StreamParser::onInputClosure1 ( )

private

◆ restoreSavedParserState()

virtual void StreamParser::restoreSavedParserState ( )

protectedvirtual

Reimplemented in H263plusVideoStreamParser, MatroskaFileParser, MPEG2TransportStreamParser, and MPEGVideoStreamParser.

◆ saveParserState()

void StreamParser::saveParserState ( )

protected

Referenced by MPEGVideoStreamParser::setParseState().

◆ skipBits()

void StreamParser::skipBits ( unsigned numBits )

protected

◆ skipBytes()

void StreamParser::skipBytes ( unsigned numBytes )

inlineprotected

Definition at line 98 of file StreamParser.hh.

                                    {
    ensureValidBytes(numBytes);
    fCurParserIndex += numBytes;
  }

References ensureValidBytes(), and fCurParserIndex.

◆ test1Byte()

u_int8_t StreamParser::test1Byte ( )

inlineprotected

Definition at line 84 of file StreamParser.hh.

                       { // as above, but doesn't advance ptr
    ensureValidBytes(1);
    return nextToParse()[0];
  }

References ensureValidBytes(), and nextToParse().

◆ test2Bytes()

u_int16_t StreamParser::test2Bytes ( )

inlineprotected

Definition at line 71 of file StreamParser.hh.

                         {
    ensureValidBytes(2);
 
    unsigned char const* ptr = nextToParse();
    return (ptr[0]<<8)|ptr[1];
  }

References ensureValidBytes(), and nextToParse().

◆ test4Bytes()

u_int32_t StreamParser::test4Bytes ( )

inlineprotected

Definition at line 53 of file StreamParser.hh.

                         { // as above, but doesn't advance ptr
    ensureValidBytes(4);
 
    unsigned char const* ptr = nextToParse();
    return (ptr[0]<<24)|(ptr[1]<<16)|(ptr[2]<<8)|ptr[3];
  }

References ensureValidBytes(), and nextToParse().

Referenced by get4Bytes().

◆ testBytes()

void StreamParser::testBytes	(	u_int8_t *	to,
		unsigned	numBytes
	)

inlineprotected

Definition at line 94 of file StreamParser.hh.

                                                  { // as above, but doesn't advance ptr
    ensureValidBytes(numBytes);
    memmove(to, nextToParse(), numBytes);
  }

References ensureValidBytes(), and nextToParse().

Referenced by getBytes().

◆ totNumValidBytes()

unsigned & StreamParser::totNumValidBytes ( )

inlineprotected

Definition at line 109 of file StreamParser.hh.

109{ return fTotNumValidBytes; }

References fTotNumValidBytes.

Field Documentation

◆ fBank

unsigned char* StreamParser::fBank[2]

private

Definition at line 146 of file StreamParser.hh.

◆ fClientContinueClientData

void* StreamParser::fClientContinueClientData

private

Definition at line 143 of file StreamParser.hh.

◆ fClientContinueFunc

clientContinueFunc* StreamParser::fClientContinueFunc

private

Definition at line 142 of file StreamParser.hh.

◆ fClientOnInputCloseClientData

void* StreamParser::fClientOnInputCloseClientData

private

Definition at line 141 of file StreamParser.hh.

◆ fClientOnInputCloseFunc

FramedSource::onCloseFunc* StreamParser::fClientOnInputCloseFunc

private

Definition at line 140 of file StreamParser.hh.

◆ fCurBank

unsigned char* StreamParser::fCurBank

private

Definition at line 148 of file StreamParser.hh.

Referenced by curBank().

◆ fCurBankNum

unsigned char StreamParser::fCurBankNum

private

Definition at line 147 of file StreamParser.hh.

◆ fCurParserIndex

unsigned StreamParser::fCurParserIndex

private

Definition at line 155 of file StreamParser.hh.

Referenced by curOffset(), ensureValidBytes(), get1Byte(), get2Bytes(), get4Bytes(), getBytes(), lastParsed(), nextToParse(), and skipBytes().

◆ fHaveSeenEOF

Boolean StreamParser::fHaveSeenEOF

private

Definition at line 162 of file StreamParser.hh.

Referenced by haveSeenEOF().

◆ fInputSource

FramedSource* StreamParser::fInputSource

private

Definition at line 139 of file StreamParser.hh.

◆ fLastSeenPresentationTime

struct timeval StreamParser::fLastSeenPresentationTime

private

Definition at line 164 of file StreamParser.hh.

◆ fRemainingUnparsedBits

unsigned char StreamParser::fRemainingUnparsedBits

private

Definition at line 156 of file StreamParser.hh.

Referenced by get1Byte(), get2Bytes(), get4Bytes(), and getBytes().

◆ fSavedParserIndex

unsigned StreamParser::fSavedParserIndex

private

Definition at line 151 of file StreamParser.hh.

◆ fSavedRemainingUnparsedBits

unsigned char StreamParser::fSavedRemainingUnparsedBits

private

Definition at line 152 of file StreamParser.hh.

◆ fTotNumValidBytes

unsigned StreamParser::fTotNumValidBytes

private

Definition at line 159 of file StreamParser.hh.

Referenced by ensureValidBytes(), and totNumValidBytes().

The documentation for this class was generated from the following file:

liveMedia/StreamParser.hh

Public Member Functions

Protected Types

Protected Member Functions

Private Member Functions

Static Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ clientContinueFunc

Constructor & Destructor Documentation

◆ StreamParser()

◆ ~StreamParser()

Member Function Documentation

◆ afterGettingBytes()

◆ afterGettingBytes1()

◆ bankSize()

◆ curBank()

◆ curOffset()

◆ ensureValidBytes()

◆ ensureValidBytes1()

◆ flushInput()

◆ get1Byte()

◆ get2Bytes()

◆ get4Bytes()

◆ getBits()

◆ getBytes()

◆ haveSeenEOF()

◆ lastParsed()

◆ nextToParse()

◆ onInputClosure()

◆ onInputClosure1()

◆ restoreSavedParserState()

◆ saveParserState()

◆ skipBits()

◆ skipBytes()

◆ test1Byte()

◆ test2Bytes()

◆ test4Bytes()

◆ testBytes()

◆ totNumValidBytes()

Field Documentation

◆ fBank

◆ fClientContinueClientData

◆ fClientContinueFunc

◆ fClientOnInputCloseClientData

◆ fClientOnInputCloseFunc

◆ fCurBank

◆ fCurBankNum

◆ fCurParserIndex

◆ fHaveSeenEOF

◆ fInputSource

◆ fLastSeenPresentationTime

◆ fRemainingUnparsedBits

◆ fSavedParserIndex

◆ fSavedRemainingUnparsedBits

◆ fTotNumValidBytes