【正文】 sprintf(buf, %16f id %16d udp %16d\n, local_time, hdr_cmn::access(p)frame_pkt_id_, hdr_cmn::access(p)size()28)。 if (n 0) { …………………………………………………………………………….. hdr_cmn::access(p)sendtime_ = local_time。 target_recv(p)。 fwrite(buf, strlen(buf), 1, BWFile)。 // (smallko) if(openfile!=0){ hdr_cmn::access(p)frame_pkt_id_ = id_++。 } double local_time = Scheduler::instance().clock()。 if (nbytes == 1) { printf(Error: sendmsg() for UDP should not be 1\n)。 //added by smallko if (size_) n = nbytes / size_。 int n。 UdpAgent::UdpAgent()。 mUdpAgent::mUdpAgent() : id_(0), openfile(0) { bind(packetSize_, amp。 endif include include include include include static class mUdpAgentClass : public TclClass { public: mUdpAgentClass() : TclClass(Agent/mUDP) {} TclObject* create(int, const char*const*) { return (new mUdpAgent())。 int openfile。 char BWfile[100]。 virtual int mand(int argc, const char*const* argv)。 } ifndef ns_mudp_h define ns_mudp_h include class mUdpAgent : public UdpAgent { public: mUdpAgent()。 return (TCL_OK)。 strcpy((char*)datadata(), argv[3])。 return (TCL_OK)。 strcpy((char*)datadata(), argv[3])。 } Packet::free(pkt)。 tcl = Tcl::instance()。 hdr_ip* iph = hdr_ip::access(pkt)。 pktuserdata()type() == PACKET_DATA) { // otherwise if it39。 } else if (pktuserdata() amp。 } void UdpAgent::recv(Packet* pkt, Handler*) { if (app_ ) { // If an application is attached, pass the data to the app hdr_cmn* h = hdr_cmn::access(pkt)。 target_recv(p)。 (0 == strcmp(flags, NEW_BURST))) rhflags() |= RTP_M。 // add beginning of talkspurt labels (tcl/ex/) if (flags amp。 rhseqno() = ++seqno_。 hdr_rtp* rh = hdr_rtp::access(p)。 if (n 0) { p = allocpkt()。 target_recv(p)。 (0 ==strcmp(flags, NEW_BURST))) rhflags() |= RTP_M。 // add beginning of talkspurt labels (tcl/ex/) if (flags amp。 rhseqno() = ++seqno_。 hdr_rtp* rh = hdr_rtp::access(p)。 while (n 0) { p = allocpkt()。 return。amp。 return。 n = nbytes / size_。 int n。 } // put in timestamp and sequence number, even though UDP doesn39。 } UdpAgent::UdpAgent(packet_t type) : Agent(type) { bind(packetSize_, amp。 UdpAgent::UdpAgent() : Agent(PT_UDP), seqno_(1) { bind(packetSize_, amp。 endif include include include include include static class UdpAgentClass : public TclClass { public: UdpAgentClass() : TclClass(Agent/UDP) {} TclObject* create(int, const char*const*) { return (new UdpAgent())。 protected: int seqno_。 virtual void recv(Packet* pkt, Handler*)。 virtual void sendmsg(int nbytes, const char *flags = 0) { sendmsg(nbytes, NULL, flags)。 } How UDP works ? The source codes are under apps (, ) ifndef ns_udp_h define ns_udp_h include include include //rtp timestamp needs the samplerate define SAMPLERATE 8000 define RTP_M 0x0080 // marker for significant events class UdpAgent : public Agent { public: UdpAgent()。 else running_ = 0。 /* figure out when to send the next one */ nextPkttime_ = next_interval(size_)。 } void TrafficGenerator::timeout() { if (! running_) return。 if (++seqno_ maxpkts_) return(t)。 if (random_) t += interval_ * Random::uniform(, )。 size) { // Repute interval in case rate_ or size_ has changes interval_ = (double)(size_ 3)/(double)rate_。 timeout()。 } void CBR_Traffic::start() { init()。amp。 } void CBR_Traffic::init() { // pute interpacket interval interval_ = (double)(size_ 3)/(double)rate_ 。 bind(maxpkts_, amp。 bind(packetSize_, amp。 bind(random_, amp。 CBR_Traffic::CBR_Traffic() : seqno_(0) { bind_bw(rate_, amp。 static class CBRTrafficClass : public TclClass { public: CBRTrafficClass() : TclClass(Application/Traffic/CBR) {} TclObject* create(int, const char*const*) { return (new CBR_Traffic())。 int maxpkts_。 /* packet interarrival time during burst (sec) */ double random_。 double rate_。 } protected: virtual void start()。)。 $ns detachagent $d $sink $ns at finish $ns run How CBR works? ? The source code is under tools () include include include include ― /* * Constant bit rate traffic source. Parameterized by interval, (optional) * random noise in the interval, and packet size. */ class CBR_Traffic : public TrafficGenerator { public: CBR_Traffic()。 以背景執(zhí)行的方式去執(zhí)行 NAM exec nam amp。 Schedule Record after $time interval sec } proc finish {} { global ns nf nd f0 f1 f2 $ns flushtrace close $nf close $nd close $f0 close $f1 close $f2 Plot Recorded Statistics exec xgraph geometry 800x400 amp。 } } $awk –f cbrdelay set term png medium 000000 set output set ylabel EndtoEnd delay(sec) set xlabel Start transmission time(sec) set xrang [0:5] set xtics 0, , 5 set yrang [0:] set ytics 0, , set title CBR endtoend delay plot cbrdelay title CBR with linespoints lt 1 pt 8 $gnuplot gnuplot load ?‘ set ns [new Simulator] $ns color 1 Blue $ns color 2 Red set nf [open w] $ns namtraceall $nf set nd [open w] $ns traceall $nd set f0 [open w] set f1 [open w] set f2 [open w] set last_ack 0 proc record {} { global ns null tcp f0 f1 f2 last_ack set time 。 packet_duration = end start。 packet_id++ ) { start = start_time[packet_id]。 } } END { 當(dāng)資料列全部讀取完後，開始計算有效封包的端點到端點延遲時間 for ( packet_id = 0。 action != d ) { if ( action == r ) {