RTPAgent Class Reference

#include <rtp.h>

List of all members.

Public Member Functions
	RTPAgent ()
virtual void	timeout (int)
virtual void	recv (Packet *p, Handler *)
virtual int	command (int argc, const char *const *argv)
void	advanceby (int delta)
virtual void	sendmsg (int nbytes, const char *flags=0)
Protected Member Functions
virtual void	sendpkt ()
virtual void	makepkt (Packet *)
void	rate_change ()
virtual void	start ()
virtual void	stop ()
virtual void	finish ()
Protected Attributes
RTPSession *	session_
double	lastpkttime_
int	seqno_
int	running_
int	random_
int	maxpkts_
double	interval_
RTPTimer	rtp_timer_
double	timestamp_

---

Detailed Description

this class generates the RTP packets and controls the transmission rate through the RTP timer and the update rate function

Definition at line 398 of file rtp.h.

---

Constructor & Destructor Documentation

RTPAgent::RTPAgent

(

)

constructor initializes the RTPAgent intance

Definition at line 66 of file rtp.cc.

References interval_, maxpkts_, random_, seqno_, and timestamp_.

                   : Agent(PT_RTP), session_(0), lastpkttime_(-1e6),
    running_(0),  rtp_timer_(this)
{
        bind("seqno_", &seqno_);
        bind_time("interval_", &interval_);
        bind("packetSize_", &size_);
        bind("maxpkts_", &maxpkts_);
        bind("random_", &random_);
        timestamp_ = 0;
        
}

---

Member Function Documentation

void RTPAgent::timeout

(

int

)

[virtual]

when the RTPTimer times out the RTP Agent sends an RTP packet when there is a session (multicast session) the sending source is apdating the number of RTP packets that sends

Definition at line 132 of file rtp.cc.

References interval_, RTPSession::localsrc_update(), RTPSession::localsrc_update_nbytes(), random_, rtp_timer_, running_, sendpkt(), and session_.

Referenced by RTPTimer::expire().

{
        if (running_) {
                sendpkt();
                if (session_)
                        session_->localsrc_update(size_);
                        session_->localsrc_update_nbytes(size_);
                        
                double t = interval_;
                if (random_)
                        /* add some zero-mean white noise */
                        t += interval_ * Random::uniform(-0.5, 0.5);
                rtp_timer_.resched(t);
        }
}

void RTPAgent::recv	(	Packet *	p,
		Handler *
	)			[virtual]

the receive method for RTP packets. It simples passes the packet to the instance of the RTPSession class. Ottherwise the mothod does nothing

Definition at line 173 of file rtp.cc.

References RTPSession::recv(), and session_.

{
        if (session_)
                session_->recv(p, 0);
        else
                Packet::free(p);
}

int RTPAgent::command	(	int	argc,
		const char *const *	argv
	)			[virtual]

Definition at line 181 of file rtp.cc.

References advanceby(), rate_change(), seqno_, session_, start(), and stop().

{
        if (argc == 2) {
                if (strcmp(argv[1], "rate-change") == 0) {
                        rate_change();
                        return (TCL_OK);
                } else if (strcmp(argv[1], "start") == 0) {
                        start();
                        return (TCL_OK);
                } else if (strcmp(argv[1], "stop") == 0) {
                        stop();
                        return (TCL_OK);
                }
        } else if (argc == 3) {
                if (strcmp(argv[1], "session") == 0) {
                        session_ = (RTPSession*)TclObject::lookup(argv[2]);
                        return (TCL_OK);
                } else if (strcmp(argv[1], "advance") == 0) {
                        int newseq = atoi(argv[2]);
                        advanceby(newseq - seqno_);
                        return (TCL_OK); 
                } else if (strcmp(argv[1], "advanceby") == 0) {
                        advanceby(atoi(argv[2]));
                        return (TCL_OK);
                }       
        }
        return (Agent::command(argc, argv));
}

void RTPAgent::advanceby

(

int

delta

)

Parameters:

delta

Definition at line 162 of file rtp.cc.

References maxpkts_, running_, seqno_, and start().

Referenced by command().

{
        maxpkts_ += delta;
        if (seqno_ < maxpkts_ && !running_)
                start();
}               

void RTPAgent::sendmsg	(	int	nbytes,
		const char *	flags = 0
	)			[virtual]

sends the packets

Definition at line 94 of file rtp.cc.

References hdr_rtp::access(), finish(), maxpkts_, hdr_rtp::seqno(), seqno_, and start().

{
        Packet *p;
        int n;

        assert (size_ > 0);

        if (++seqno_ < maxpkts_) {
                n = nbytes / size_;
        
                if (nbytes == -1) {
                        start();
                        return;
                }
                while (n-- > 0) {
                        p = allocpkt();
                        hdr_rtp* rh = hdr_rtp::access(p);
                        rh->seqno() = seqno_;
                        target_->recv(p);
                }
                n = nbytes % size_;
                if (n > 0) {
                        p = allocpkt();
                        hdr_rtp* rh = hdr_rtp::access(p);
                        rh->seqno() = seqno_;
                        target_->recv(p);
                }
                idle();
        } else {
                finish();
                // xxx: should we deschedule the timer here? */
        };
}

void RTPAgent::sendpkt

(

)

[protected, virtual]

allocates the RTP packet that has to be sent

Definition at line 231 of file rtp.cc.

References lastpkttime_, makepkt(), and timestamp_.

Referenced by rate_change(), start(), and timeout().

{
        Packet* p = allocpkt();
        lastpkttime_ = Scheduler::instance().clock();
        timestamp_ = lastpkttime_;
        makepkt(p);
        target_->recv(p, (Handler*)0);
}

void RTPAgent::makepkt

(

Packet *

p

)

[protected, virtual]

creates the RTP packet and fills in the packet header fields

Definition at line 240 of file rtp.cc.

References hdr_rtp::access(), hdr_rtp::seqno(), seqno_, session_, RTPSession::srcid(), hdr_rtp::srcid(), hdr_rtp::timestamp(), and timestamp_.

Referenced by sendpkt().

{
        
        hdr_rtp *rh = hdr_rtp::access(p);
        /* Fill in srcid_ and seqno */
        rh->seqno() = seqno_++;
        rh->srcid() = session_ ? session_->srcid() : 0;
        rh->timestamp()= timestamp_;
        
        
}

void RTPAgent::rate_change

(

)

[protected]

We modify the rate in this way to get a faster reaction to the a rate change since a rate change from a very low rate to a very fast rate may take an undesireably long time if we have to wait for timeout at the old rate before we can send at the new (faster) rate.

Definition at line 216 of file rtp.cc.

References interval_, lastpkttime_, rtp_timer_, and sendpkt().

Referenced by command().

{
        rtp_timer_.force_cancel();
        
        double t = lastpkttime_ + interval_;
        
        double now = Scheduler::instance().clock();
        if ( t > now)
                rtp_timer_.resched(t - now);
        else {
                sendpkt();
                rtp_timer_.resched(interval_);
        }
}

void RTPAgent::start

(

)

[protected, virtual]

starts the RTP Agent

Definition at line 78 of file rtp.cc.

References interval_, rtp_timer_, running_, and sendpkt().

Referenced by advanceby(), command(), and sendmsg().

{
        running_ = 1;
        sendpkt();
        rtp_timer_.resched(interval_);
}

void RTPAgent::stop

(

)

[protected, virtual]

stops the RTP Agent

Definition at line 86 of file rtp.cc.

References finish(), and rtp_timer_.

Referenced by command().

{
//      printf("inside stop localsrc_ %d\n", session_->localsrc_->srcid());
        rtp_timer_.force_cancel();
        finish();
}

void RTPAgent::finish

(

)

[protected, virtual]

finish() is called when we must stop (either by request or because we're out of packets to send.

Definition at line 152 of file rtp.cc.

References running_.

Referenced by sendmsg(), and stop().

{
        running_ = 0;
        Tcl::instance().evalf("%s done", this->name());
}

---

Member Data Documentation

RTPSession* RTPAgent::session_ [protected]

Definition at line 413 of file rtp.h.

Referenced by command(), makepkt(), recv(), and timeout().

double RTPAgent::lastpkttime_ [protected]

Definition at line 414 of file rtp.h.

Referenced by rate_change(), and sendpkt().

int RTPAgent::seqno_ [protected]

Definition at line 415 of file rtp.h.

Referenced by advanceby(), command(), makepkt(), RTPAgent(), and sendmsg().

int RTPAgent::running_ [protected]

Definition at line 416 of file rtp.h.

Referenced by advanceby(), finish(), start(), and timeout().

int RTPAgent::random_ [protected]

Definition at line 417 of file rtp.h.

Referenced by RTPAgent(), and timeout().

int RTPAgent::maxpkts_ [protected]

Definition at line 418 of file rtp.h.

Referenced by advanceby(), RTPAgent(), and sendmsg().

double RTPAgent::interval_ [protected]

Definition at line 419 of file rtp.h.

Referenced by rate_change(), RTPAgent(), start(), and timeout().

RTPTimer RTPAgent::rtp_timer_ [protected]

Definition at line 420 of file rtp.h.

Referenced by rate_change(), start(), stop(), and timeout().

double RTPAgent::timestamp_ [protected]

Definition at line 421 of file rtp.h.

Referenced by makepkt(), RTPAgent(), and sendpkt().

---

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

• ns-allinone-2.30/ns-2.30/rtp/rtp.h
• ns-allinone-2.30/ns-2.30/rtp/rtp.cc