CMUPriQueue Class Reference

#include <dsr-priqueue.h>

Inheritance diagram for CMUPriQueue:

[legend]Collaboration diagram for CMUPriQueue:

[legend]List of all members.


Public Member Functions
	CMUPriQueue ()
int	command (int argc, const char const argv)
void	recv (Packet p, Handler )
void	prq_resume (void)
void	Terminate (void)
Packet *	prq_get_nexthop (nsaddr_t id)
int	prq_isfull (Packet *p)
int	prq_length (void)
NsObject *	target ()
virtual void	drop (Packet *p)
virtual void	recv (Packet p, const char s)
virtual void	recvOnly (Packet *)
virtual void	delay_bind_init_all ()
virtual int	delay_bind_dispatch (const char varName, const char localName, TclObject *tracer)
int	isdebug () const
virtual void	debug (const char *fmt,...)
Protected Member Functions
void	trace (char *fmt,...)
void	log_stats (void)
virtual void	drop (Packet p, const char s)
void	send (Packet p, Handler h)
virtual void	reset ()
void	handle (Event *)
Protected Attributes
int	qlen_logthresh_
int	fw_logthresh_
int	last_ifqlen_ [IFQ_MAX]
int	stat_send_
int	stat_recv_
int	stat_blocked_
NsObject *	target_
NsObject *	drop_
int	debug_
Private Member Functions
int	prq_assign_queue (Packet *p)
void	prq_enqueue (Packet *p)
Packet *	prq_dequeue (void)
void	prq_validate (void)
Private Attributes
ifqueue	prq_snd_ [IFQ_MAX]
nsaddr_t	prq_ipaddr_
Trace *	prq_logtarget_
int	prq_blocked_
CMUPriQueueHandler	prq_qh_

Constructor & Destructor Documentation

CMUPriQueue::CMUPriQueue ( )

Definition at line 34 of file dsr-priqueue.cc.
References fw_logthresh_, ifqueue::ifq_drops, ifqueue::ifq_head, ifqueue::ifq_len, IFQ_MAX, IFQ_MAXLEN, ifqueue::ifq_maxlen, ifqueue::ifq_tail, last_ifqlen_, prq_blocked_, prq_ipaddr_, prq_logtarget_, prq_snd_, qlen_logthresh_, stat_blocked_, stat_recv_, and stat_send_.

00034 : Connector(), prq_qh_(this) 00035 { 00036 int i; 00037 00038 for(i = 0; i < IFQ_MAX; i++) { 00039 prq_snd_[i].ifq_head = prq_snd_[i].ifq_tail = 0; 00040 prq_snd_[i].ifq_len = 0; 00041 prq_snd_[i].ifq_maxlen = IFQ_MAXLEN; 00042 prq_snd_[i].ifq_drops = 0; 00043 00044 last_ifqlen_[i] = 0; 00045 } 00046 prq_logtarget_ = 0; // no logging target by default 00047 prq_ipaddr_ = 0; 00048 prq_blocked_ = 0; 00049 00050 bind("qlen_logthresh_", &qlen_logthresh_); 00051 bind("fw_logthresh_", &fw_logthresh_); 00052 assert(qlen_logthresh_ > 0 && fw_logthresh_ > 0); 00053 00054 bzero(last_ifqlen_, sizeof(last_ifqlen_)); 00055 stat_send_ = stat_recv_ = stat_blocked_ = 0; 00056 }

Member Function Documentation

int CMUPriQueue::command ( int argc,

const char *const * argv

) [virtual]

Reimplemented from Connector.
Definition at line 59 of file dsr-priqueue.cc.
References Connector::command(), prq_ipaddr_, prq_logtarget_, and Terminate().

00060 { 00061 if (argc == 2 && strcasecmp(argv[1], "reset") == 0) { 00062 Terminate(); 00063 //FALL-THROUGH to give parents a chance to reset 00064 } else if(argc == 3) { 00065 if(strcmp(argv[1], "logtarget") == 0) { 00066 prq_logtarget_ = (Trace*) TclObject::lookup(argv[2]); 00067 assert(prq_logtarget_); 00068 return (TCL_OK); 00069 } 00070 else if(strcmp(argv[1], "ipaddr") == 0) { 00071 prq_ipaddr_ = atoi(argv[2]); 00072 assert(prq_ipaddr_ > 0); 00073 return (TCL_OK); 00074 } 00075 } 00076 return Connector::command(argc, argv); 00077 }