#include <cstdlib>
#ifdef CCXX_NAMESPACES
using namespace ost;
using namespace std;
#endif
{
public:
Listener(InetMcastAddress& ima, tpport_t port) :
Listener(InetHostAddress& ia, tpport_t port) :
void listen()
{
cout << "My SSRC identifier is: "
<< hex << (int)getLocalSSRC() << endl;
"rtplisten demo app.");
setExpireTimeout(1000000);
startRunning();
for (;;) {
while ( (adu = getData(getFirstTimestamp())) ) {
cerr << "I got an app. data unit - "
<< " payload octets ("
<< ") from "
<< "@" << dec <<
<< ":"
<< endl;
delete adu;
}
Thread::sleep(7);
}
}
{
cout << "* New synchronization source: " <<
hex << (int)src.
getID() << endl;
}
void onGotSR(
SyncSource& source, SendReport& SR, uint8 blocks)
{
cout << "I got an SR RTCP report from "
<< hex << (int)source.
getID() <<
"@"
<< dec
}
void onGotRR(
SyncSource& source, RecvReport& RR, uint8 blocks)
{
cout << "I got an RR RTCP report from "
<< hex << (int)source.
getID() <<
"@"
<< dec
}
bool onGotSDESChunk(
SyncSource& source, SDESChunk& chunk,
size_t len)
{
cout << "I got a SDES chunk from "
<< hex << (int)source.
getID() <<
"@"
<< dec
<< " ("
<< ") " << endl;
return result;
}
void onGotGoodbye(
const SyncSource& source,
const std::string& reason)
{
cout << "I got a Goodbye packet from "
<< hex << (int)source.
getID() <<
"@"
<< dec
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;
}