StreamState Class Reference

Collaboration diagram for StreamState:

[legend]

Public Member Functions
	StreamState (OnDemandServerMediaSubsession &master, Port const &serverRTPPort, Port const &serverRTCPPort, RTPSink *rtpSink, BasicUDPSink *udpSink, unsigned totalBW, FramedSource *mediaSource, Groupsock *rtpGS, Groupsock *rtcpGS)
virtual	~StreamState ()
void	startPlaying (Destinations *destinations, TaskFunc *rtcpRRHandler, void *rtcpRRHandlerClientData)
void	pause ()
void	endPlaying (Destinations *destinations)
void	reclaim ()
unsigned &	referenceCount ()
Port const &	serverRTPPort () const
Port const &	serverRTCPPort () const
RTPSink *	rtpSink () const
float	streamDuration () const
FramedSource *	mediaSource () const
Private Attributes
OnDemandServerMediaSubsession &	fMaster
Boolean	fAreCurrentlyPlaying
unsigned	fReferenceCount
Port	fServerRTPPort
Port	fServerRTCPPort
RTPSink *	fRTPSink
BasicUDPSink *	fUDPSink
float	fStreamDuration
unsigned	fTotalBW
RTCPInstance *	fRTCPInstance
FramedSource *	fMediaSource
Groupsock *	fRTPgs
Groupsock *	fRTCPgs

---

Detailed Description

Definition at line 100 of file OnDemandServerMediaSubsession.cpp.

---

Constructor & Destructor Documentation

StreamState::StreamState	(	OnDemandServerMediaSubsession &	master,
		Port const &	serverRTPPort,
		Port const &	serverRTCPPort,
		RTPSink *	rtpSink,
		BasicUDPSink *	udpSink,
		unsigned	totalBW,
		FramedSource *	mediaSource,
		Groupsock *	rtpGS,
		Groupsock *	rtcpGS
	)

Definition at line 409 of file OnDemandServerMediaSubsession.cpp.

  : fMaster(master), fAreCurrentlyPlaying(False), fReferenceCount(1),
    fServerRTPPort(serverRTPPort), fServerRTCPPort(serverRTCPPort),
    fRTPSink(rtpSink), fUDPSink(udpSink), fStreamDuration(master.duration()),
    fTotalBW(totalBW), fRTCPInstance(NULL) /* created later */,
    fMediaSource(mediaSource), fRTPgs(rtpGS), fRTCPgs(rtcpGS) {
}

StreamState::~StreamState

(

)

[virtual]

Definition at line 421 of file OnDemandServerMediaSubsession.cpp.

References reclaim().

                          {
  reclaim();
}

---

Member Function Documentation

void StreamState::startPlaying	(	Destinations *	destinations,
		TaskFunc *	rtcpRRHandler,
		void *	rtcpRRHandlerClientData
	)

Definition at line 426 of file OnDemandServerMediaSubsession.cpp.

References Groupsock::addDestination(), Destinations::addr, RTCPInstance::addStreamSocket(), RTPSink::addStreamSocket(), afterPlayingStreamState(), RTCPInstance::createNew(), Medium::envir(), fAreCurrentlyPlaying, OnDemandServerMediaSubsession::fCNAME, fMaster, fMediaSource, fRTCPgs, fRTCPInstance, fRTPgs, fRTPSink, fTotalBW, fUDPSink, Destinations::isTCP, NULL, Destinations::rtcpChannelId, Destinations::rtcpPort, Destinations::rtpChannelId, Destinations::rtpPort, RTCPInstance::setSpecificRRHandler(), MediaSink::startPlaying(), Destinations::tcpSocketNum, and True.

Referenced by OnDemandServerMediaSubsession::startStream().

                                                                       {
  if (dests == NULL) return;
  if (!fAreCurrentlyPlaying && fMediaSource != NULL) {
    if (fRTPSink != NULL) {
      fRTPSink->startPlaying(*fMediaSource, afterPlayingStreamState, this);
      fAreCurrentlyPlaying = True;
    } else if (fUDPSink != NULL) {
      fUDPSink->startPlaying(*fMediaSource, afterPlayingStreamState, this);
      fAreCurrentlyPlaying = True;
    }
  }

  if (fRTCPInstance == NULL && fRTPSink != NULL) {
    // Create (and start) a 'RTCP instance' for this RTP sink:
    fRTCPInstance
      = RTCPInstance::createNew(fRTPSink->envir(), fRTCPgs,
                                fTotalBW, (unsigned char*)fMaster.fCNAME,
                                fRTPSink, NULL /* we're a server */);
        // Note: This starts RTCP running automatically
  }

  if (dests->isTCP) {
    // Change RTP and RTCP to use the TCP socket instead of UDP:
    if (fRTPSink != NULL) {
      fRTPSink->addStreamSocket(dests->tcpSocketNum, dests->rtpChannelId);
    }
    if (fRTCPInstance != NULL) {
      fRTCPInstance->addStreamSocket(dests->tcpSocketNum, dests->rtcpChannelId);
      fRTCPInstance->setSpecificRRHandler(dests->tcpSocketNum, dests->rtcpChannelId,
                                          rtcpRRHandler, rtcpRRHandlerClientData);
    }
  } else {
    // Tell the RTP and RTCP 'groupsocks' about this destination
    // (in case they don't already have it):
    if (fRTPgs != NULL) fRTPgs->addDestination(dests->addr, dests->rtpPort);
    if (fRTCPgs != NULL) fRTCPgs->addDestination(dests->addr, dests->rtcpPort);
    if (fRTCPInstance != NULL) {
      fRTCPInstance->setSpecificRRHandler(dests->addr.s_addr, dests->rtcpPort,
                                          rtcpRRHandler, rtcpRRHandlerClientData);
    }
  }
}

void StreamState::pause

(

)

Definition at line 470 of file OnDemandServerMediaSubsession.cpp.

References False, fAreCurrentlyPlaying, fRTPSink, fUDPSink, NULL, and MediaSink::stopPlaying().

Referenced by OnDemandServerMediaSubsession::pauseStream().

                        {
  if (fRTPSink != NULL) fRTPSink->stopPlaying();
  if (fUDPSink != NULL) fUDPSink->stopPlaying();
  fAreCurrentlyPlaying = False;
}

void StreamState::endPlaying

(

Destinations *

destinations

)

Definition at line 476 of file OnDemandServerMediaSubsession.cpp.

References Destinations::addr, fRTCPgs, fRTCPInstance, fRTPgs, fRTPSink, Destinations::isTCP, NULL, Groupsock::removeDestination(), RTCPInstance::removeStreamSocket(), RTPSink::removeStreamSocket(), Destinations::rtcpChannelId, Destinations::rtcpPort, Destinations::rtpChannelId, Destinations::rtpPort, RTCPInstance::setSpecificRRHandler(), and Destinations::tcpSocketNum.

Referenced by OnDemandServerMediaSubsession::deleteStream().

                                                {
  if (dests->isTCP) {
    if (fRTPSink != NULL) {
      fRTPSink->removeStreamSocket(dests->tcpSocketNum, dests->rtpChannelId);
    }
    if (fRTCPInstance != NULL) {
      fRTCPInstance->removeStreamSocket(dests->tcpSocketNum, dests->rtcpChannelId);
      fRTCPInstance->setSpecificRRHandler(dests->tcpSocketNum, dests->rtcpChannelId,
                                          NULL, NULL);
    }
  } else {
    // Tell the RTP and RTCP 'groupsocks' to stop using these destinations:
    if (fRTPgs != NULL) fRTPgs->removeDestination(dests->addr, dests->rtpPort);
    if (fRTCPgs != NULL) fRTCPgs->removeDestination(dests->addr, dests->rtcpPort);
    if (fRTCPInstance != NULL) {
      fRTCPInstance->setSpecificRRHandler(dests->addr.s_addr, dests->rtcpPort,
                                          NULL, NULL);
    }
  }
}

void StreamState::reclaim

(

)

Definition at line 497 of file OnDemandServerMediaSubsession.cpp.

References Medium::close(), OnDemandServerMediaSubsession::closeStreamSource(), fMaster, fMediaSource, fRTCPgs, fRTCPInstance, fRTPgs, fRTPSink, fUDPSink, and NULL.

Referenced by afterPlayingStreamState(), and ~StreamState().

                          {
  // Delete allocated media objects
  Medium::close(fRTCPInstance) /* will send a RTCP BYE */; fRTCPInstance = NULL;
  Medium::close(fRTPSink); fRTPSink = NULL;
  Medium::close(fUDPSink); fUDPSink = NULL;

  fMaster.closeStreamSource(fMediaSource); fMediaSource = NULL;

  delete fRTPgs; fRTPgs = NULL;
  delete fRTCPgs; fRTCPgs = NULL;
}

unsigned& StreamState::referenceCount

(

)

[inline]

Definition at line 115 of file OnDemandServerMediaSubsession.cpp.

Referenced by OnDemandServerMediaSubsession::deleteStream().

{ return fReferenceCount; }

Port const& StreamState::serverRTPPort

(

)

const [inline]

Definition at line 117 of file OnDemandServerMediaSubsession.cpp.

{ return fServerRTPPort; }

Port const& StreamState::serverRTCPPort

(

)

const [inline]

Definition at line 118 of file OnDemandServerMediaSubsession.cpp.

{ return fServerRTCPPort; }

RTPSink* StreamState::rtpSink

(

)

const [inline]

Definition at line 120 of file OnDemandServerMediaSubsession.cpp.

Referenced by OnDemandServerMediaSubsession::startStream().

{ return fRTPSink; }

float StreamState::streamDuration

(

)

const [inline]

Definition at line 122 of file OnDemandServerMediaSubsession.cpp.

Referenced by afterPlayingStreamState().

{ return fStreamDuration; }

FramedSource* StreamState::mediaSource

(

)

const [inline]

Definition at line 124 of file OnDemandServerMediaSubsession.cpp.

Referenced by OnDemandServerMediaSubsession::seekStream(), and OnDemandServerMediaSubsession::setStreamScale().

{ return fMediaSource; }

---

Field Documentation

OnDemandServerMediaSubsession& StreamState::fMaster [private]

Definition at line 127 of file OnDemandServerMediaSubsession.cpp.

Referenced by reclaim(), and startPlaying().

Boolean StreamState::fAreCurrentlyPlaying [private]

Definition at line 128 of file OnDemandServerMediaSubsession.cpp.

Referenced by pause(), and startPlaying().

unsigned StreamState::fReferenceCount [private]

Definition at line 129 of file OnDemandServerMediaSubsession.cpp.

Port StreamState::fServerRTPPort [private]

Definition at line 131 of file OnDemandServerMediaSubsession.cpp.

Port StreamState::fServerRTCPPort [private]

Definition at line 131 of file OnDemandServerMediaSubsession.cpp.

RTPSink* StreamState::fRTPSink [private]

Definition at line 133 of file OnDemandServerMediaSubsession.cpp.

Referenced by endPlaying(), pause(), reclaim(), and startPlaying().

BasicUDPSink* StreamState::fUDPSink [private]

Definition at line 134 of file OnDemandServerMediaSubsession.cpp.

Referenced by pause(), reclaim(), and startPlaying().

float StreamState::fStreamDuration [private]

Definition at line 136 of file OnDemandServerMediaSubsession.cpp.

unsigned StreamState::fTotalBW [private]

Definition at line 137 of file OnDemandServerMediaSubsession.cpp.

Referenced by startPlaying().

RTCPInstance* StreamState::fRTCPInstance [private]

Definition at line 137 of file OnDemandServerMediaSubsession.cpp.

Referenced by endPlaying(), reclaim(), and startPlaying().

FramedSource* StreamState::fMediaSource [private]

Definition at line 139 of file OnDemandServerMediaSubsession.cpp.

Referenced by reclaim(), and startPlaying().

Groupsock* StreamState::fRTPgs [private]

Definition at line 141 of file OnDemandServerMediaSubsession.cpp.

Referenced by endPlaying(), reclaim(), and startPlaying().

Groupsock* StreamState::fRTCPgs [private]

Definition at line 141 of file OnDemandServerMediaSubsession.cpp.

Referenced by endPlaying(), reclaim(), and startPlaying().

---

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

• liveMedia/OnDemandServerMediaSubsession.cpp

---