ccRTP
rtplisten.cpp
// rtplisten
// Listen for RTP packets.
// Copyright (C) 2001-2015 Federico Montesino <fedemp@altern.org>
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation; either version 2 of the License, or
// (at your option) any later version.
//
// This program is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
// GNU General Public License for more details.
//
// You should have received a copy of the GNU General Public License
// along with this program; if not, write to the Free Software
// Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
#include <cstdlib>
#include <ccrtp/rtp.h>
#ifdef CCXX_NAMESPACES
using namespace ost;
using namespace std;
#endif
class Listener: RTPSession
{
public:
Listener(InetMcastAddress& ima, tpport_t port) :
RTPSession(ima,port) {}
Listener(InetHostAddress& ia, tpport_t port) :
RTPSession(ia,port) {}
void listen()
{
cout << "My SSRC identifier is: "
<< hex << (int)getLocalSSRC() << endl;
"rtplisten demo app.");
setExpireTimeout(1000000);
for (;;) {
const AppDataUnit* adu;
while ( (adu = getData(getFirstTimestamp())) ) {
cerr << "I got an app. data unit - "
<< adu->getSize()
<< " payload octets ("
<< "pt " << (int)adu->getType()
<< ") from "
<< hex << (int)adu->getSource().getID()
<< "@" << dec <<
<< ":"
<< endl;
delete adu;
}
Thread::sleep(7);
}
}
// redefined from IncomingDataQueue
void onNewSyncSource(const SyncSource& src)
{
cout << "* New synchronization source: " <<
hex << (int)src.getID() << endl;
}
// redefined from QueueRTCPManager
void onGotSR(SyncSource& source, SendReport& SR, uint8 blocks)
{
RTPSession::onGotSR(source,SR,blocks);
cout << "I got an SR RTCP report from "
<< hex << (int)source.getID() << "@"
<< dec
<< source.getNetworkAddress() << ":"
<< source.getControlTransportPort() << endl;
}
// redefined from QueueRTCPManager
void onGotRR(SyncSource& source, RecvReport& RR, uint8 blocks)
{
RTPSession::onGotRR(source,RR,blocks);
cout << "I got an RR RTCP report from "
<< hex << (int)source.getID() << "@"
<< dec
<< source.getNetworkAddress() << ":"
<< source.getControlTransportPort() << endl;
}
// redefined from QueueRTCPManager
bool onGotSDESChunk(SyncSource& source, SDESChunk& chunk, size_t len)
{
bool result = RTPSession::onGotSDESChunk(source,chunk,len);
cout << "I got a SDES chunk from "
<< hex << (int)source.getID() << "@"
<< dec
<< source.getNetworkAddress() << ":"
<< " ("
<< ") " << endl;
return result;
}
void onGotGoodbye(const SyncSource& source, const std::string& reason)
{
cout << "I got a Goodbye packet from "
<< hex << (int)source.getID() << "@"
<< dec
<< source.getNetworkAddress() << ":"
<< source.getControlTransportPort() << endl;
cout << " Goodbye reason: \"" << reason << "\"" << endl;
}
};
int main(int argc, char *argv[])
{
cout << "rtplisten" << endl;
if (argc != 3) {
cerr << "Syntax: " << " ip port" << endl;
exit(1);
}
InetMcastAddress ima;
try {
ima = InetMcastAddress(argv[1]);
} catch (...) { }
Listener *foo;
tpport_t port = atoi(argv[2]);
if ( ima.isInetAddress() ) {
foo = new Listener(ima,port);
cout << "Listening on multicast address " << ima << ":" <<
port << endl;
} else {
InetHostAddress ia(argv[1]);
foo = new Listener(ia,atoi(argv[2]));
cout << "Listening on unicast address " << ia << ":" <<
port << endl;
}
cout << "Press Ctrl-C to finish." << endl;
foo->listen();
delete foo;
return 0;
}
Interface (envelope) to data received over RTP packets.
Definition queuebase.h:69
PayloadType getType() const
Definition queuebase.h:94
size_t getSize() const
Definition queuebase.h:112
const SyncSource & getSource() const
Definition queuebase.h:119
uint32 getFirstTimestamp(const SyncSource *src=NULL) const
Get timestamp of first packet waiting in the queue.
const AppDataUnit * getData(uint32 stamp, const SyncSource *src=NULL)
Retreive data from a specific timestamped packet if such a packet is currently available in the recei...
virtual void onNewSyncSource(const SyncSource &)
Virtual called when a new synchronization source has joined the session.
Definition iqueue.h:1185
void setExpireTimeout(microtimeout_t to)
Set the "expired" timer for expiring packets pending in the send queue which have gone unsent and are...
Definition oqueue.h:379
const std::string & getSDESItem(SDESItemType type) const
Get the value of an SDES item.
Definition sources.h:140
virtual bool onGotSDESChunk(SyncSource &source, SDESChunk &chunk, size_t len)
Plug-in for handling of SDES chunks.
virtual void onGotSR(SyncSource &source, SendReport &SR, uint8 blocks)
Plug-in for processing (acquire information carried in) an incoming RTCP Sender Report.
virtual void onGotRR(SyncSource &source, RecvReport &RR, uint8 blocks)
Plug-in for processing (acquire information carried in) an incoming RTCP Receiver Report.
void setSDESItem(SDESItemType item, const std::string &val)
Definition sources.h:382
uint32 getLocalSSRC() const
Definition queuebase.h:184
bool setPayloadFormat(const PayloadFormat &pf)
Set the payload format in use, for timing and payload type identification purposes.
Definition queuebase.h:177
This template class adds the threading aspect to the RTPSessionBase template in one of the many possi...
Definition rtp.h:421
void startRunning()
Activate stack and start service thread.
Definition rtp.h:508
Static payload format objects.
Definition formats.h:201
Synchronization source in an RTP session.
Definition sources.h:193
tpport_t getDataTransportPort() const
Definition sources.h:271
tpport_t getControlTransportPort() const
Definition sources.h:274
Participant * getParticipant() const
Get the participant this synchronization source is asociated to.
Definition sources.h:268
uint32 getID() const
Definition sources.h:257
const InetAddress & getNetworkAddress() const
Definition sources.h:277
@ sptPCMU
ITU-T G.711. mu-law audio 8 Khz (RFC 1890)
Definition formats.h:75
@ SDESItemTypeTOOL
Application or tool.
Definition rtcppkt.h:72
@ SDESItemTypeCNAME
Canonical end-point identifier.
Definition rtcppkt.h:67
SingleThreadRTPSession RTPSession
Uses two pairs of sockets for RTP data and RTCP transmission/reception.
Definition rtp.h:601
__EXPORT RTPApplication & defaultApplication()
Get the RTPApplication object for the "default" application (the only one used by common applications...
Generic and audio/video profile specific RTP interface of ccRTP.