testProgs/testAMRAudioStreamer.cpp File Reference

#include "liveMedia.hh"
#include "BasicUsageEnvironment.hh"
#include "GroupsockHelper.hh"

Include dependency graph for testAMRAudioStreamer.cpp:

Go to the source code of this file.

Functions
void	play ()
int	main (int argc, char **argv)
void	afterPlaying (void *)
Variables
UsageEnvironment *	env
char const *	inputFileName = "test.amr"
AMRAudioFileSource *	audioSource
RTPSink *	audioSink

---

Function Documentation

void afterPlaying

(

void *

)

Definition at line 98 of file testAMRAudioStreamer.cpp.

                                        {
  *env << "...done reading from file\n";

  audioSink->stopPlaying();
  Medium::close(audioSource);
  // Note that this also closes the input file that this source read from.

  play();
}

int main	(	int	argc,
		char **	argv
	)

Definition at line 32 of file testAMRAudioStreamer.cpp.

References RTSPServer::addServerMediaSession(), ServerMediaSession::addSubsession(), audioSink, chooseRandomIPv4SSMAddress(), PassiveServerMediaSubsession::createNew(), ServerMediaSession::createNew(), RTSPServer::createNew(), RTCPInstance::createNew(), AMRAudioRTPSink::createNew(), BasicUsageEnvironment::createNew(), BasicTaskScheduler::createNew(), TaskScheduler::doEventLoop(), env, exit, UsageEnvironment::getResultMsg(), inputFileName, Groupsock::multicastSendOnly(), NULL, play(), rtspServer, RTSPServer::rtspURL(), UsageEnvironment::taskScheduler(), and True.

                                {
  // Begin by setting up our usage environment:
  TaskScheduler* scheduler = BasicTaskScheduler::createNew();
  env = BasicUsageEnvironment::createNew(*scheduler);

  // Create 'groupsocks' for RTP and RTCP:
  struct in_addr destinationAddress;
  destinationAddress.s_addr = chooseRandomIPv4SSMAddress(*env);
  // Note: This is a multicast address.  If you wish instead to stream
  // using unicast, then you should use the "testOnDemandRTSPServer"
  // test program - not this test program - as a model.

  const unsigned short rtpPortNum = 16666;
  const unsigned short rtcpPortNum = rtpPortNum+1;
  const unsigned char ttl = 255;

  const Port rtpPort(rtpPortNum);
  const Port rtcpPort(rtcpPortNum);

  Groupsock rtpGroupsock(*env, destinationAddress, rtpPort, ttl);
  rtpGroupsock.multicastSendOnly(); // we're a SSM source
  Groupsock rtcpGroupsock(*env, destinationAddress, rtcpPort, ttl);
  rtcpGroupsock.multicastSendOnly(); // we're a SSM source

  // Create a 'AMR Audio RTP' sink from the RTP 'groupsock':
  audioSink = AMRAudioRTPSink::createNew(*env, &rtpGroupsock, 96);

  // Create (and start) a 'RTCP instance' for this RTP sink:
  const unsigned estimatedSessionBandwidth = 10; // in kbps; for RTCP b/w share
  const unsigned maxCNAMElen = 100;
  unsigned char CNAME[maxCNAMElen+1];
  gethostname((char*)CNAME, maxCNAMElen);
  CNAME[maxCNAMElen] = '\0'; // just in case
  RTCPInstance* rtcp
    = RTCPInstance::createNew(*env, &rtcpGroupsock,
                              estimatedSessionBandwidth, CNAME,
                              audioSink, NULL /* we're a server */,
                              True /* we're a SSM source */);
  // Note: This starts RTCP running automatically

  // Create and start a RTSP server to serve this stream.
  RTSPServer* rtspServer = RTSPServer::createNew(*env, 8554);
  if (rtspServer == NULL) {
    *env << "Failed to create RTSP server: " << env->getResultMsg() << "\n";
    exit(1);
  }
  ServerMediaSession* sms
    = ServerMediaSession::createNew(*env, "testStream", inputFileName,
                   "Session streamed by \"testAMRAudioStreamer\"",
                                           True /*SSM*/);
  sms->addSubsession(PassiveServerMediaSubsession::createNew(*audioSink, rtcp));
  rtspServer->addServerMediaSession(sms);

  char* url = rtspServer->rtspURL(sms);
  *env << "Play this stream using the URL \"" << url << "\"\n";
  delete[] url;

  // Start the streaming:
  *env << "Beginning streaming...\n";
  play();

  env->taskScheduler().doEventLoop(); // does not return

  return 0; // only to prevent compiler warning
}

void play

(

)

Definition at line 108 of file testAMRAudioStreamer.cpp.

References afterPlaying(), audioSink, audioSource, AMRAudioFileSource::createNew(), env, exit, UsageEnvironment::getResultMsg(), inputFileName, NULL, and MediaSink::startPlaying().

Referenced by afterPlaying(), and main().

            {
  // Open the input file as an 'AMR audio file source':
  AMRAudioFileSource* audioSource
    = AMRAudioFileSource::createNew(*env, inputFileName);
  if (audioSource == NULL) {
    *env << "Unable to open file \"" << inputFileName
         << "\" as an AMR audio file source: "
         << env->getResultMsg() << "\n";
    exit(1);
  }

  // Finally, start playing:
  *env << "Beginning to read from file...\n";
  audioSink->startPlaying(*audioSource, afterPlaying, audioSink);
}

---

Variable Documentation

RTPSink* audioSink

Definition at line 28 of file testAMRAudioStreamer.cpp.

Referenced by afterPlaying(), main(), and play().

AMRAudioFileSource* audioSource

Definition at line 27 of file testAMRAudioStreamer.cpp.

Referenced by afterPlaying(), MPEG1or2DemuxedServerMediaSubsession::createNewRTPSink(), AC3AudioFileServerMediaSubsession::createNewRTPSink(), and play().

UsageEnvironment* env

Definition at line 25 of file testAMRAudioStreamer.cpp.

char const* inputFileName = "test.amr"

Definition at line 26 of file testAMRAudioStreamer.cpp.

Referenced by main(), and play().

---