MPEG1or2Demux Class Reference

#include <MPEG1or2Demux.hh>

Inheritance diagram for MPEG1or2Demux:

Inheritance graph
[legend]
Collaboration diagram for MPEG1or2Demux:

Collaboration graph
[legend]

Public Member Functions

MPEG1or2DemuxedElementaryStream * newElementaryStream (u_int8_t streamIdTag)
MPEG1or2DemuxedElementaryStream * newAudioStream ()
MPEG1or2DemuxedElementaryStream * newVideoStream ()
MPEG1or2DemuxedElementaryStream * newRawPESStream ()
void getNextFrame (u_int8_t streamIdTag, unsigned char *to, unsigned maxSize, FramedSource::afterGettingFunc *afterGettingFunc, void *afterGettingClientData, FramedSource::onCloseFunc *onCloseFunc, void *onCloseClientData)
void stopGettingFrames (u_int8_t streamIdTag)
FramedSource * inputSource () const
SCR & lastSeenSCR ()
unsigned char mpegVersion () const
void flushInput ()
UsageEnvironment & envir () const
char const * name () const
virtual Boolean isSource () const
virtual Boolean isSink () const
virtual Boolean isRTCPInstance () const
virtual Boolean isRTSPClient () const
virtual Boolean isRTSPServer () const
virtual Boolean isMediaSession () const
virtual Boolean isServerMediaSession () const
virtual Boolean isDarwinInjector () const

Static Public Member Functions

static MPEG1or2Demux * createNew (UsageEnvironment &env, FramedSource *inputSource, Boolean reclaimWhenLastESDies=False)
static void handleClosure (void *clientData)
static Boolean lookupByName (UsageEnvironment &env, char const *mediumName, Medium *&resultMedium)
static void close (UsageEnvironment &env, char const *mediumName)
static void close (Medium *medium)

Protected Member Functions

TaskToken & nextTask ()

Private Types

typedef MPEG1or2Demux::OutputDescriptor OutputDescriptor_t

Private Member Functions

 MPEG1or2Demux (UsageEnvironment &env, FramedSource *inputSource, Boolean reclaimWhenLastESDies)
virtual ~MPEG1or2Demux ()
void registerReadInterest (u_int8_t streamIdTag, unsigned char *to, unsigned maxSize, FramedSource::afterGettingFunc *afterGettingFunc, void *afterGettingClientData, FramedSource::onCloseFunc *onCloseFunc, void *onCloseClientData)
Boolean useSavedData (u_int8_t streamIdTag, unsigned char *to, unsigned maxSize, FramedSource::afterGettingFunc *afterGettingFunc, void *afterGettingClientData)
void continueReadProcessing ()
void noteElementaryStreamDeletion (MPEG1or2DemuxedElementaryStream *es)

Static Private Member Functions

static void continueReadProcessing (void *clientData, unsigned char *ptr, unsigned size, struct timeval presentationTime)

Private Attributes

FramedSource * fInputSource
SCR fLastSeenSCR
unsigned char fMPEGversion
unsigned char fNextAudioStreamNumber
unsigned char fNextVideoStreamNumber
Boolean fReclaimWhenLastESDies
unsigned fNumOutstandingESs
OutputDescriptor_t fOutput [256]
unsigned fNumPendingReads
Boolean fHaveUndeliveredData
MPEGProgramStreamParser * fParser

Friends

class MPEG1or2DemuxedElementaryStream
class MPEGProgramStreamParser

Data Structures

struct  OutputDescriptor
class  SCR

Detailed Description

Definition at line 30 of file MPEG1or2Demux.hh.

Member Typedef Documentation

typedef struct MPEG1or2Demux::OutputDescriptor MPEG1or2Demux::OutputDescriptor_t [private]

Constructor & Destructor Documentation

MPEG1or2Demux::MPEG1or2Demux ( UsageEnvironment &  env,
FramedSource *  inputSource,
Boolean  reclaimWhenLastESDies 
) [private]

Definition at line 82 of file MPEG1or2Demux.cpp.

References False, and NULL.

Referenced by createNew().

00084   : Medium(env),
00085     fInputSource(inputSource), fMPEGversion(0),
00086     fNextAudioStreamNumber(0), fNextVideoStreamNumber(0),
00087     fReclaimWhenLastESDies(reclaimWhenLastESDies), fNumOutstandingESs(0),
00088     fNumPendingReads(0), fHaveUndeliveredData(False) {
00089   fParser = new MPEGProgramStreamParser(this, inputSource);
00090   for (unsigned i = 0; i < 256; ++i) {
00091     fOutput[i].savedDataHead = fOutput[i].savedDataTail = NULL;
00092     fOutput[i].isPotentiallyReadable = False;
00093     fOutput[i].isCurrentlyActive = False;
00094     fOutput[i].isCurrentlyAwaitingData = False;
00095   }
00096 }

MPEG1or2Demux::~MPEG1or2Demux (  )  [private, virtual]

Definition at line 98 of file MPEG1or2Demux.cpp.

References Medium::close(), fInputSource, fOutput, and fParser.

00098                               {
00099   delete fParser;
00100   for (unsigned i = 0; i < 256; ++i) delete fOutput[i].savedDataHead;
00101   Medium::close(fInputSource);
00102 }

Member Function Documentation

MPEG1or2Demux * MPEG1or2Demux::createNew ( UsageEnvironment &  env,
FramedSource *  inputSource,
Boolean  reclaimWhenLastESDies = False 
) [static]

Definition at line 105 of file MPEG1or2Demux.cpp.

References env, inputSource(), and MPEG1or2Demux().

Referenced by main(), MPEG1or2ProgramStreamFileDuration(), and MPEG1or2FileServerDemux::newElementaryStream().

00106                                                                       {
00107   // Need to add source type checking here???  #####
00108 
00109   return new MPEG1or2Demux(env, inputSource, reclaimWhenLastESDies);
00110 }

MPEG1or2DemuxedElementaryStream * MPEG1or2Demux::newElementaryStream ( u_int8_t  streamIdTag  ) 

Definition at line 128 of file MPEG1or2Demux.cpp.

References Medium::envir(), fNumOutstandingESs, fOutput, MPEG1or2Demux::OutputDescriptor::isPotentiallyReadable, MPEG1or2DemuxedElementaryStream, and True.

Referenced by newAudioStream(), MPEG1or2FileServerDemux::newElementaryStream(), newRawPESStream(), and newVideoStream().

00128                                                        {
00129   ++fNumOutstandingESs;
00130   fOutput[streamIdTag].isPotentiallyReadable = True;
00131   return new MPEG1or2DemuxedElementaryStream(envir(), streamIdTag, *this);
00132 }

MPEG1or2DemuxedElementaryStream * MPEG1or2Demux::newAudioStream (  ) 

Definition at line 134 of file MPEG1or2Demux.cpp.

References fNextAudioStreamNumber, and newElementaryStream().

Referenced by main().

00134                                                                {
00135   unsigned char newAudioStreamTag = 0xC0 | (fNextAudioStreamNumber++&~0xE0);
00136       // MPEG audio stream tags are 110x xxxx (binary)
00137   return newElementaryStream(newAudioStreamTag);
00138 }

MPEG1or2DemuxedElementaryStream * MPEG1or2Demux::newVideoStream (  ) 

Definition at line 140 of file MPEG1or2Demux.cpp.

References fNextVideoStreamNumber, and newElementaryStream().

Referenced by main().

00140                                                                {
00141   unsigned char newVideoStreamTag = 0xE0 | (fNextVideoStreamNumber++&~0xF0);
00142       // MPEG video stream tags are 1110 xxxx (binary)
00143   return newElementaryStream(newVideoStreamTag);
00144 }

MPEG1or2DemuxedElementaryStream * MPEG1or2Demux::newRawPESStream (  ) 

Definition at line 149 of file MPEG1or2Demux.cpp.

References newElementaryStream(), and RAW_PES.

Referenced by main(), and MPEG1or2ProgramStreamFileDuration().

00149                                                                 {
00150   return newElementaryStream(RAW_PES);
00151 }

void MPEG1or2Demux::getNextFrame ( u_int8_t  streamIdTag,
unsigned char *  to,
unsigned  maxSize,
FramedSource::afterGettingFunc *  afterGettingFunc,
void *  afterGettingClientData,
FramedSource::onCloseFunc *  onCloseFunc,
void *  onCloseClientData 
)

Definition at line 258 of file MPEG1or2Demux.cpp.

References continueReadProcessing(), fHaveUndeliveredData, fNumPendingReads, registerReadInterest(), and useSavedData().

Referenced by MPEG1or2DemuxedElementaryStream::doGetNextFrame().

00263                                                           {
00264   // First, check whether we have saved data for this stream id:
00265   if (useSavedData(streamIdTag, to, maxSize,
00266                    afterGettingFunc, afterGettingClientData)) {
00267     return;
00268   }
00269 
00270   // Then save the parameters of the specified stream id:
00271   registerReadInterest(streamIdTag, to, maxSize,
00272                        afterGettingFunc, afterGettingClientData,
00273                        onCloseFunc, onCloseClientData);
00274 
00275   // Next, if we're the only currently pending read, continue looking for data:
00276   if (fNumPendingReads == 1 || fHaveUndeliveredData) {
00277     fHaveUndeliveredData = 0;
00278     continueReadProcessing();
00279   } // otherwise the continued read processing has already been taken care of
00280 }

void MPEG1or2Demux::stopGettingFrames ( u_int8_t  streamIdTag  ) 

Definition at line 282 of file MPEG1or2Demux.cpp.

References False, fOutput, MPEG1or2Demux::OutputDescriptor::isCurrentlyActive, and MPEG1or2Demux::OutputDescriptor::isCurrentlyAwaitingData.

Referenced by MPEG1or2DemuxedElementaryStream::doStopGettingFrames().

00282                                                           {
00283     struct OutputDescriptor& out = fOutput[streamIdTag];
00284     out.isCurrentlyActive = out.isCurrentlyAwaitingData = False;
00285 }

void MPEG1or2Demux::handleClosure ( void *  clientData  )  [static]

Definition at line 287 of file MPEG1or2Demux.cpp.

References fNumPendingReads, MPEG1or2Demux::OutputDescriptor::fOnCloseFunc, fOutput, if(), NULL, and MPEG1or2Demux::OutputDescriptor::onCloseClientData.

00287                                                   {
00288   MPEG1or2Demux* demux = (MPEG1or2Demux*)clientData;
00289 
00290   demux->fNumPendingReads = 0;
00291 
00292   // Tell all pending readers that our source has closed.
00293   // Note that we need to make a copy of our readers' close functions
00294   // (etc.) before we start calling any of them, in case one of them
00295   // ends up deleting this.
00296   struct {
00297     FramedSource::onCloseFunc* fOnCloseFunc;
00298     void* onCloseClientData;
00299   } savedPending[256];
00300   unsigned i, numPending = 0;
00301   for (i = 0; i < 256; ++i) {
00302     struct OutputDescriptor& out = demux->fOutput[i];
00303     if (out.isCurrentlyAwaitingData) {
00304       if (out.fOnCloseFunc != NULL) {
00305         savedPending[numPending].fOnCloseFunc = out.fOnCloseFunc;
00306         savedPending[numPending].onCloseClientData = out.onCloseClientData;
00307         ++numPending;
00308       }
00309     }
00310     delete out.savedDataHead; out.savedDataHead = out.savedDataTail = NULL;
00311     out.savedDataTotalSize = 0;
00312     out.isPotentiallyReadable = out.isCurrentlyActive = out.isCurrentlyAwaitingData
00313       = False;
00314   }
00315   for (i = 0; i < numPending; ++i) {
00316     (*savedPending[i].fOnCloseFunc)(savedPending[i].onCloseClientData);
00317   }
00318 }

FramedSource* MPEG1or2Demux::inputSource (  )  const [inline]

Definition at line 64 of file MPEG1or2Demux.hh.

References fInputSource.

Referenced by createNew(), and MPEG1or2DemuxedServerMediaSubsession::seekStreamSource().

00064 { return fInputSource; }

SCR& MPEG1or2Demux::lastSeenSCR (  )  [inline]

Definition at line 76 of file MPEG1or2Demux.hh.

References fLastSeenSCR.

Referenced by DummySink::afterGettingFrame1(), MPEG1or2DemuxedElementaryStream::afterGettingFrame1(), and getMPEG1or2TimeCode().

00076 { return fLastSeenSCR; }

unsigned char MPEG1or2Demux::mpegVersion (  )  const [inline]

Definition at line 78 of file MPEG1or2Demux.hh.

References fMPEGversion.

Referenced by MPEG1or2DemuxedElementaryStream::afterGettingFrame1().

00078 { return fMPEGversion; }

void MPEG1or2Demux::flushInput (  ) 

Definition at line 123 of file MPEG1or2Demux.cpp.

References StreamParser::flushInput(), and fParser.

Referenced by MPEG1or2ProgramStreamFileDuration(), and MPEG1or2DemuxedServerMediaSubsession::seekStreamSource().

00123                                {
00124   fParser->flushInput();
00125 }

void MPEG1or2Demux::registerReadInterest ( u_int8_t  streamIdTag,
unsigned char *  to,
unsigned  maxSize,
FramedSource::afterGettingFunc *  afterGettingFunc,
void *  afterGettingClientData,
FramedSource::onCloseFunc *  onCloseFunc,
void *  onCloseClientData 
) [private]

Definition at line 153 of file MPEG1or2Demux.cpp.

References MPEG1or2Demux::OutputDescriptor::afterGettingClientData, Medium::envir(), MPEG1or2Demux::OutputDescriptor::fAfterGettingFunc, fNumPendingReads, MPEG1or2Demux::OutputDescriptor::fOnCloseFunc, fOutput, MPEG1or2Demux::OutputDescriptor::isCurrentlyActive, MPEG1or2Demux::OutputDescriptor::isCurrentlyAwaitingData, MPEG1or2Demux::OutputDescriptor::maxSize, MPEG1or2Demux::OutputDescriptor::onCloseClientData, MPEG1or2Demux::OutputDescriptor::to, and True.

Referenced by getNextFrame().

00158                                                               {
00159   struct OutputDescriptor& out = fOutput[streamIdTag];
00160 
00161   // Make sure this stream is not already being read:
00162   if (out.isCurrentlyAwaitingData) {
00163     envir() << "MPEG1or2Demux::registerReadInterest(): attempt to read stream id "
00164             << (void*)streamIdTag << " more than once!\n";
00165     abort();
00166   }
00167 
00168   out.to = to; out.maxSize = maxSize;
00169   out.fAfterGettingFunc = afterGettingFunc;
00170   out.afterGettingClientData = afterGettingClientData;
00171   out.fOnCloseFunc = onCloseFunc;
00172   out.onCloseClientData = onCloseClientData;
00173   out.isCurrentlyActive = True;
00174   out.isCurrentlyAwaitingData = True;
00175   // out.frameSize and out.presentationTime will be set when a frame's read
00176 
00177   ++fNumPendingReads;
00178 }

Boolean MPEG1or2Demux::useSavedData ( u_int8_t  streamIdTag,
unsigned char *  to,
unsigned  maxSize,
FramedSource::afterGettingFunc *  afterGettingFunc,
void *  afterGettingClientData 
) [private]

Definition at line 180 of file MPEG1or2Demux.cpp.

References MPEG1or2Demux::OutputDescriptor::SavedData::data, MPEG1or2Demux::OutputDescriptor::SavedData::dataSize, False, fOutput, MPEG1or2Demux::OutputDescriptor::isCurrentlyActive, MPEG1or2Demux::OutputDescriptor::SavedData::next, NULL, MPEG1or2Demux::OutputDescriptor::SavedData::numBytesUsed, MPEG1or2Demux::OutputDescriptor::savedDataHead, MPEG1or2Demux::OutputDescriptor::savedDataTail, MPEG1or2Demux::OutputDescriptor::savedDataTotalSize, and True.

Referenced by getNextFrame().

00183                                                                   {
00184   struct OutputDescriptor& out = fOutput[streamIdTag];
00185   if (out.savedDataHead == NULL) return False; // common case
00186 
00187   unsigned totNumBytesCopied = 0;
00188   while (maxSize > 0 && out.savedDataHead != NULL) {
00189     OutputDescriptor::SavedData& savedData = *(out.savedDataHead);
00190     unsigned char* from = &savedData.data[savedData.numBytesUsed];
00191     unsigned numBytesToCopy = savedData.dataSize - savedData.numBytesUsed;
00192     if (numBytesToCopy > maxSize) numBytesToCopy = maxSize;
00193     memmove(to, from, numBytesToCopy);
00194     to += numBytesToCopy;
00195     maxSize -= numBytesToCopy;
00196     out.savedDataTotalSize -= numBytesToCopy;
00197     totNumBytesCopied += numBytesToCopy;
00198     savedData.numBytesUsed += numBytesToCopy;
00199     if (savedData.numBytesUsed == savedData.dataSize) {
00200       out.savedDataHead = savedData.next;
00201       if (out.savedDataHead == NULL) out.savedDataTail = NULL;
00202       savedData.next = NULL;
00203       delete &savedData;
00204     }
00205   }
00206 
00207   out.isCurrentlyActive = True;
00208   if (afterGettingFunc != NULL) {
00209     struct timeval presentationTime;
00210     presentationTime.tv_sec = 0; presentationTime.tv_usec = 0; // should fix #####
00211     (*afterGettingFunc)(afterGettingClientData, totNumBytesCopied,
00212                         0 /* numTruncatedBytes */, presentationTime,
00213                         0 /* durationInMicroseconds ?????#####*/);
00214   }
00215   return True;
00216 }

void MPEG1or2Demux::continueReadProcessing ( void *  clientData,
unsigned char *  ptr,
unsigned  size,
struct timeval  presentationTime 
) [static, private]

Definition at line 219 of file MPEG1or2Demux.cpp.

References continueReadProcessing().

Referenced by continueReadProcessing().

00221                                                               {
00222   MPEG1or2Demux* demux = (MPEG1or2Demux*)clientData;
00223   demux->continueReadProcessing();
00224 }

void MPEG1or2Demux::continueReadProcessing (  )  [private]

Definition at line 226 of file MPEG1or2Demux.cpp.

References MPEG1or2Demux::OutputDescriptor::afterGettingClientData, MPEG1or2Demux::OutputDescriptor::fAfterGettingFunc, False, fNumPendingReads, fOutput, fParser, MPEG1or2Demux::OutputDescriptor::frameSize, MPEG1or2Demux::OutputDescriptor::isCurrentlyAwaitingData, NULL, MPEGProgramStreamParser::parse(), and MPEG1or2Demux::OutputDescriptor::presentationTime.

Referenced by getNextFrame().

00226                                            {
00227   while (fNumPendingReads > 0) {
00228     unsigned char acquiredStreamIdTag = fParser->parse();
00229 
00230     if (acquiredStreamIdTag != 0) {
00231       // We were able to acquire a frame from the input.
00232       struct OutputDescriptor& newOut = fOutput[acquiredStreamIdTag];
00233       newOut.isCurrentlyAwaitingData = False;
00234         // indicates that we can be read again
00235         // (This needs to be set before the 'after getting' call below,
00236         //  in case it tries to read another frame)
00237 
00238       // Call our own 'after getting' function.  Because we're not a 'leaf'
00239       // source, we can call this directly, without risking infinite recursion.
00240       if (newOut.fAfterGettingFunc != NULL) {
00241         (*newOut.fAfterGettingFunc)(newOut.afterGettingClientData,
00242                                     newOut.frameSize, 0 /* numTruncatedBytes */,
00243                                     newOut.presentationTime,
00244                                     0 /* durationInMicroseconds ?????#####*/);
00245       --fNumPendingReads;
00246       }
00247     } else {
00248       // We were unable to parse a complete frame from the input, because:
00249       // - we had to read more data from the source stream, or
00250       // - we found a frame for a stream that was being read, but whose
00251       //   reader is not ready to get the frame right now, or
00252       // - the source stream has ended.
00253       break;
00254     }
00255   }
00256 }

void MPEG1or2Demux::noteElementaryStreamDeletion ( MPEG1or2DemuxedElementaryStream *  es  )  [private]

Definition at line 117 of file MPEG1or2Demux.cpp.

References Medium::close(), fNumOutstandingESs, and fReclaimWhenLastESDies.

Referenced by MPEG1or2DemuxedElementaryStream::~MPEG1or2DemuxedElementaryStream().

00117                                                                       {
00118   if (--fNumOutstandingESs == 0 && fReclaimWhenLastESDies) {
00119     Medium::close(this);
00120   }
00121 }

Boolean Medium::lookupByName ( UsageEnvironment &  env,
char const *  mediumName,
Medium *&  resultMedium 
) [static, inherited]

Definition at line 65 of file Media.cpp.

References env, False, MediaLookupTable::lookup(), NULL, MediaLookupTable::ourMedia(), UsageEnvironment::setResultMsg(), and True.

Referenced by ServerMediaSession::lookupByName(), RTSPServer::lookupByName(), RTSPClient::lookupByName(), RTCPInstance::lookupByName(), MediaSource::lookupByName(), MediaSink::lookupByName(), MediaSession::lookupByName(), and DarwinInjector::lookupByName().

00066                                                          {
00067   resultMedium = MediaLookupTable::ourMedia(env)->lookup(mediumName);
00068   if (resultMedium == NULL) {
00069     env.setResultMsg("Medium ", mediumName, " does not exist");
00070     return False;
00071   }
00072 
00073   return True;
00074 }

void Medium::close ( UsageEnvironment &  env,
char const *  mediumName 
) [static, inherited]

Definition at line 76 of file Media.cpp.

References env, MediaLookupTable::ourMedia(), and MediaLookupTable::remove().

Referenced by afterPlaying(), Medium::close(), closeMediaSinks(), OnDemandServerMediaSubsession::closeStreamSource(), continueAfterTEARDOWN(), WAVAudioFileSource::createNew(), QuickTimeFileSink::createNew(), QCELPAudioRTPSource::createNew(), MP3HTTPSource::createNew(), MP3FileSource::createNew(), AVIFileSink::createNew(), AMRAudioRTPSource::createNew(), WAVAudioFileServerMediaSubsession::createNewStreamSource(), MPEG1or2DemuxedServerMediaSubsession::createNewStreamSource(), MediaSubsession::deInitiate(), MediaSubsession::initiate(), MPEG1or2ProgramStreamFileDuration(), noteElementaryStreamDeletion(), ByteStreamMultiFileSource::onSourceClosure1(), StreamState::reclaim(), RTSPServer::removeServerMediaSession(), OnDemandServerMediaSubsession::sdpLines(), H264VideoRTPSink::stopPlaying(), subsessionAfterPlaying(), ClientTrickPlayState::updateStateOnScaleChange(), AMRDeinterleaver::~AMRDeinterleaver(), ByteStreamMultiFileSource::~ByteStreamMultiFileSource(), DarwinInjector::~DarwinInjector(), FramedFilter::~FramedFilter(), H264VideoRTPSink::~H264VideoRTPSink(), InputESSourceRecord::~InputESSourceRecord(), ~MPEG1or2Demux(), MPEG1or2FileServerDemux::~MPEG1or2FileServerDemux(), MPEG2TransportFileServerMediaSubsession::~MPEG2TransportFileServerMediaSubsession(), MPEG2TransportStreamFromPESSource::~MPEG2TransportStreamFromPESSource(), ServerMediaSession::~ServerMediaSession(), and ServerMediaSubsession::~ServerMediaSubsession().

00076                                                           {
00077   MediaLookupTable::ourMedia(env)->remove(name);
00078 }

void Medium::close ( Medium *  medium  )  [static, inherited]

Definition at line 80 of file Media.cpp.

References Medium::close(), Medium::envir(), Medium::name(), and NULL.

00080                                  {
00081   if (medium == NULL) return;
00082 
00083   close(medium->envir(), medium->name());
00084 }

UsageEnvironment& Medium::envir (  )  const [inline, inherited]

Definition at line 59 of file Media.hh.

References Medium::fEnviron.

Referenced by QuickTimeFileSink::addArbitraryString(), FileSink::addData(), RTCPInstance::addStreamSocket(), MPEG2IFrameIndexFromTransportStream::addToTail(), StreamParser::afterGettingBytes(), MultiFramedRTPSink::afterGettingFrame1(), InputESSourceRecord::afterGettingFrame1(), MPEG2TransportStreamFramer::afterGettingFrame1(), MPEG2IFrameIndexFromTransportStream::afterGettingFrame1(), HTTPSink::afterGettingFrame1(), BasicUDPSink::afterGettingFrame1(), MPEG4VideoFileServerMediaSubsession::afterPlayingDummy1(), MPEG4VideoStreamParser::analyzeVOLHeader(), announceStream(), MPEG4VideoFileServerMediaSubsession::checkForAuxSDPLine1(), Medium::close(), MPEG2IFrameIndexFromTransportStream::compactParseBuffer(), RTSPClient::connectionHandler1(), RTSPClient::connectToServer(), QuickTimeFileSink::continuePlaying(), HTTPSink::continuePlaying(), H264VideoRTPSink::continuePlaying(), AVIFileSink::continuePlaying(), MPEG4VideoFileServerMediaSubsession::createNewRTPSink(), MPEG2TransportFileServerMediaSubsession::createNewRTPSink(), MPEG1or2VideoFileServerMediaSubsession::createNewRTPSink(), MPEG1or2DemuxedServerMediaSubsession::createNewRTPSink(), H263plusVideoFileServerMediaSubsession::createNewRTPSink(), DVVideoFileServerMediaSubsession::createNewRTPSink(), AMRAudioFileServerMediaSubsession::createNewRTPSink(), ADTSAudioFileServerMediaSubsession::createNewRTPSink(), MPEG4VideoFileServerMediaSubsession::createNewStreamSource(), MPEG2TransportFileServerMediaSubsession::createNewStreamSource(), MPEG1or2VideoFileServerMediaSubsession::createNewStreamSource(), MPEG1or2DemuxedServerMediaSubsession::createNewStreamSource(), H263plusVideoFileServerMediaSubsession::createNewStreamSource(), DVVideoFileServerMediaSubsession::createNewStreamSource(), AMRAudioFileServerMediaSubsession::createNewStreamSource(), ADTSAudioFileServerMediaSubsession::createNewStreamSource(), MPEG2IFrameIndexFromTransportStream::deliverIndexRecord(), SegmentQueue::dequeue(), WAVAudioFileSource::doGetNextFrame(), MPEG2IFrameIndexFromTransportStream::doGetNextFrame(), MP3FileSource::doGetNextFrame(), H264FUAFragmenter::doGetNextFrame(), ByteStreamMultiFileSource::doGetNextFrame(), ByteStreamFileSource::doGetNextFrame(), BasicUDPSource::doGetNextFrame(), AMRAudioFileSource::doGetNextFrame(), ADTSAudioFileSource::doGetNextFrame(), MultiFramedRTPSource::doGetNextFrame1(), MP3FileSource::doGetNextFrame1(), ADUFromMP3Source::doGetNextFrame1(), SIPClient::doInviteStateMachine(), ByteStreamFileSource::doReadFromFile(), MPEG1or2VideoRTPSink::doSpecialFrameHandling(), MP3ADURTPSink::doSpecialFrameHandling(), H263plusVideoRTPSink::doSpecialFrameHandling(), ByteStreamFileSource::doStopGettingFrames(), BasicUDPSource::doStopGettingFrames(), SegmentQueue::enqueueNewSegment(), StreamParser::ensureValidBytes1(), MediaSubsession::env(), SubsessionIOState::envir(), RTSPServer::RTSPClientSession::envir(), RTSPOverHTTPServer::HTTPClientConnection::envir(), RTPInterface::envir(), AVISubsessionIOState::envir(), ServerMediaSession::generateSDPDescription(), RTPSource::getAttributes(), MP3FileSource::getAttributes(), MP3ADUTranscoder::getAttributes(), MediaSource::getAttributes(), MPEG4VideoFileServerMediaSubsession::getAuxSDPLine(), getMPEG1or2TimeCode(), FramedSource::getNextFrame(), getOptions(), DVVideoStreamFramer::getProfile(), SIPClient::getResponse(), SIPClient::getResponseCode(), getSDPDescription(), OnDemandServerMediaSubsession::getStreamParameters(), RTSPClient::handleGET_PARAMETERResponse(), RTSPClient::handleIncomingRequest(), RTSPClient::handlePLAYResponse(), RTSPClient::handleRequestError(), RTSPClient::handleResponseBytes(), RTSPClient::handleSETUPResponse(), RTSPServer::incomingConnectionHandler1(), RTSPOverHTTPServer::incomingConnectionHandler1(), RTSPClient::incomingDataHandler1(), RTCPInstance::incomingReportHandler1(), MP3FileSource::initializeStream(), MediaSession::initializeWithSDP(), MediaSession::initiateByMediaType(), SIPClient::invite1(), DynamicRTSPServer::lookupServerMediaSession(), MPEG4GenericRTPSource::MPEG4GenericRTPSource(), MPEG1or2FileServerDemux::newElementaryStream(), newElementaryStream(), MPEG4GenericBufferedPacket::nextEnclosedFrameSize(), AMRBufferedPacket::nextEnclosedFrameSize(), RTSPClient::openConnection(), MPEG2TransportStreamIndexFile::openFid(), MPEG2IFrameIndexFromTransportStream::parseFrame(), AC3AudioStreamParser::parseFrame(), MPEGProgramStreamParser::parsePackHeader(), MPEGProgramStreamParser::parsePESPacket(), SIPClient::parseResponseCode(), MediaSession::parseSDPLine(), MPEG1or2VideoStreamParser::parseSlice(), MPEGProgramStreamParser::parseSystemHeader(), MPEG4VideoStreamParser::parseVideoObjectLayer(), MPEG4VideoStreamParser::parseVideoObjectPlane(), MPEG4VideoStreamParser::parseVisualObject(), AC3AudioRTPSource::processSpecialHeader(), SIPClient::processURL(), AC3AudioStreamParser::readAndSaveAFrame(), registerReadInterest(), RTCPInstance::reschedule(), RTSPClient::resendCommand(), RTSPClient::resetTCPSockets(), RTSPClient::responseHandlerForHTTP_GET1(), RTSPServer::rtspURLPrefix(), RTCPInstance::schedule(), OnDemandServerMediaSubsession::sdpLines(), SIPClient::sendACK(), SIPClient::sendBYE(), SIPClient::sendINVITE(), MultiFramedRTPSink::sendPacketIfNecessary(), SIPClient::sendRequest(), RTSPClient::sendRequest(), DarwinInjector::setDestination(), RTSPClient::setupHTTPTunneling1(), QuickTimeFileSink::setWord(), AVIFileSink::setWord(), QuickTimeFileSink::setWord64(), SIPClient::SIPClient(), AMRAudioRTPSink::sourceIsCompatibleWithUs(), QuickTimeFileSink::startPlaying(), StreamState::startPlaying(), MediaSink::startPlaying(), AVIFileSink::startPlaying(), startPlayingSession(), PassiveServerMediaSubsession::startStream(), MediaSink::stopPlaying(), tearDownSession(), SIPClient::timerAHandler(), SIPClient::timerBHandler(), SIPClient::timerDHandler(), ClientTrickPlayState::updateStateOnScaleChange(), MPEG2TransportStreamFramer::updateTSPacketDurationEstimate(), BasicUDPSource::~BasicUDPSource(), ByteStreamFileSource::~ByteStreamFileSource(), RTSPOverHTTPServer::HTTPClientConnection::~HTTPClientConnection(), and RTSPServer::~RTSPServer().

00059 {return fEnviron;}

char const* Medium::name (  )  const [inline, inherited]

Definition at line 61 of file Media.hh.

References Medium::fMediumName.

Referenced by QuickTimeFileSink::addAtom_hdlr2(), Medium::close(), MP3ADUTranscoder::createNew(), MP3FromADUSource::createNew(), ADUFromMP3Source::createNew(), and MP3FileSource::initializeStream().

00061 {return fMediumName;}

Boolean Medium::isSource (  )  const [virtual, inherited]

Reimplemented in MediaSource.

Definition at line 86 of file Media.cpp.

References False.

Referenced by MediaSource::lookupByName().

00086                                {
00087   return False; // default implementation
00088 }

Boolean Medium::isSink (  )  const [virtual, inherited]

Reimplemented in MediaSink.

Definition at line 90 of file Media.cpp.

References False.

Referenced by MediaSink::lookupByName().

00090                              {
00091   return False; // default implementation
00092 }

Boolean Medium::isRTCPInstance (  )  const [virtual, inherited]

Reimplemented in RTCPInstance.

Definition at line 94 of file Media.cpp.

References False.

Referenced by RTCPInstance::lookupByName().

00094                                      {
00095   return False; // default implementation
00096 }

Boolean Medium::isRTSPClient (  )  const [virtual, inherited]

Reimplemented in RTSPClient.

Definition at line 98 of file Media.cpp.

References False.

Referenced by RTSPClient::lookupByName().

00098                                    {
00099   return False; // default implementation
00100 }

Boolean Medium::isRTSPServer (  )  const [virtual, inherited]

Reimplemented in RTSPServer.

Definition at line 102 of file Media.cpp.

References False.

Referenced by RTSPServer::lookupByName().

00102                                    {
00103   return False; // default implementation
00104 }

Boolean Medium::isMediaSession (  )  const [virtual, inherited]

Reimplemented in MediaSession.

Definition at line 106 of file Media.cpp.

References False.

Referenced by MediaSession::lookupByName().

00106                                      {
00107   return False; // default implementation
00108 }

Boolean Medium::isServerMediaSession (  )  const [virtual, inherited]

Reimplemented in ServerMediaSession.

Definition at line 110 of file Media.cpp.

References False.

Referenced by ServerMediaSession::lookupByName().

00110                                            {
00111   return False; // default implementation
00112 }

Boolean Medium::isDarwinInjector (  )  const [virtual, inherited]

Reimplemented in DarwinInjector.

Definition at line 114 of file Media.cpp.

References False.

Referenced by DarwinInjector::lookupByName().

00114                                        {
00115   return False; // default implementation
00116 }

TaskToken& Medium::nextTask (  )  [inline, protected, inherited]

Definition at line 77 of file Media.hh.

References Medium::fNextTask.

Referenced by BasicUDPSink::afterGettingFrame1(), MPEG4VideoFileServerMediaSubsession::afterPlayingDummy1(), MPEG4VideoFileServerMediaSubsession::checkForAuxSDPLine1(), WAVAudioFileSource::doGetNextFrame(), MP3FileSource::doGetNextFrame(), AMRAudioFileSource::doGetNextFrame(), ADTSAudioFileSource::doGetNextFrame(), MultiFramedRTPSource::doGetNextFrame1(), ByteStreamFileSource::doReadFromFile(), RTCPInstance::reschedule(), RTCPInstance::schedule(), MultiFramedRTPSink::sendPacketIfNecessary(), and MediaSink::stopPlaying().

00077                         {
00078         return fNextTask;
00079   }

Friends And Related Function Documentation

friend class MPEG1or2DemuxedElementaryStream [friend]

Definition at line 106 of file MPEG1or2Demux.hh.

Referenced by newElementaryStream().

friend class MPEGProgramStreamParser [friend]

Definition at line 147 of file MPEG1or2Demux.hh.

Field Documentation

FramedSource* MPEG1or2Demux::fInputSource [private]

Definition at line 110 of file MPEG1or2Demux.hh.

Referenced by inputSource(), and ~MPEG1or2Demux().

SCR MPEG1or2Demux::fLastSeenSCR [private]

Definition at line 111 of file MPEG1or2Demux.hh.

Referenced by lastSeenSCR(), and MPEGProgramStreamParser::parsePackHeader().

unsigned char MPEG1or2Demux::fMPEGversion [private]

Definition at line 112 of file MPEG1or2Demux.hh.

Referenced by MPEGProgramStreamParser::isSpecialStreamId(), mpegVersion(), MPEGProgramStreamParser::parsePackHeader(), and MPEGProgramStreamParser::parsePESPacket().

unsigned char MPEG1or2Demux::fNextAudioStreamNumber [private]

Definition at line 114 of file MPEG1or2Demux.hh.

Referenced by newAudioStream().

unsigned char MPEG1or2Demux::fNextVideoStreamNumber [private]

Definition at line 115 of file MPEG1or2Demux.hh.

Referenced by newVideoStream().

Boolean MPEG1or2Demux::fReclaimWhenLastESDies [private]

Definition at line 116 of file MPEG1or2Demux.hh.

Referenced by noteElementaryStreamDeletion().

unsigned MPEG1or2Demux::fNumOutstandingESs [private]

Definition at line 117 of file MPEG1or2Demux.hh.

Referenced by newElementaryStream(), and noteElementaryStreamDeletion().

OutputDescriptor_t MPEG1or2Demux::fOutput[256] [private]

Definition at line 140 of file MPEG1or2Demux.hh.

Referenced by continueReadProcessing(), handleClosure(), newElementaryStream(), MPEGProgramStreamParser::parsePESPacket(), registerReadInterest(), stopGettingFrames(), useSavedData(), and ~MPEG1or2Demux().

unsigned MPEG1or2Demux::fNumPendingReads [private]

Definition at line 142 of file MPEG1or2Demux.hh.

Referenced by continueReadProcessing(), getNextFrame(), handleClosure(), and registerReadInterest().

Boolean MPEG1or2Demux::fHaveUndeliveredData [private]

Definition at line 143 of file MPEG1or2Demux.hh.

Referenced by getNextFrame(), and MPEGProgramStreamParser::parsePESPacket().

class MPEGProgramStreamParser* MPEG1or2Demux::fParser [private]

Definition at line 146 of file MPEG1or2Demux.hh.

Referenced by continueReadProcessing(), flushInput(), and ~MPEG1or2Demux().

The documentation for this class was generated from the following files:
Generated on Fri Sep 3 02:37:30 2010 for live by  doxygen 1.5.2