开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 通讯/手机编程 > 3G开发 > 查看源码
cmu-trace.cc
资源名称：NS2.rar　[点击查看]
上传用户：sdhqmy
上传日期：2015-12-07
资源大小：63k
文件大小：25k
源码类别：

3G开发

开发平台：

C/C++

cmu-trace.cc：源码内容
  1. /* -*- Mode:C++; c-basic-offset:8; tab-width:8; indent-tabs-mode:t -*- */
  2. /*
  3.  * Copyright (c) 1997 Regents of the University of California.
  4.  * All rights reserved.
  5.  *
  6.  * Redistribution and use in source and binary forms, with or without
  7.  * modification, are permitted provided that the following conditions
  8.  * are met:
  9.  * 1. Redistributions of source code must retain the above copyright
  10.  *    notice, this list of conditions and the following disclaimer.
  11.  * 2. Redistributions in binary form must reproduce the above copyright
  12.  *    notice, this list of conditions and the following disclaimer in the
  13.  *    documentation and/or other materials provided with the distribution.
  14.  * 3. All advertising materials mentioning features or use of this software
  15.  *    must display the following acknowledgement:
  16.  * This product includes software developed by the Computer Systems
  17.  * Engineering Group at Lawrence Berkeley Laboratory.
  18.  * 4. Neither the name of the University nor of the Laboratory may be used
  19.  *    to endorse or promote products derived from this software without
  20.  *    specific prior written permission.
  21.  *
  22.  * THIS SOFTWARE IS PROVIDED BY THE REGENTS AND CONTRIBUTORS ``AS IS'' AND
  23.  * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
  24.  * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
  25.  * ARE DISCLAIMED.  IN NO EVENT SHALL THE REGENTS OR CONTRIBUTORS BE LIABLE
  26.  * FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL
  27.  * DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS
  28.  * OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION)
  29.  * HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT
  30.  * LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY
  31.  * OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF
  32.  * SUCH DAMAGE.
  33.  *
  34.  * Ported from CMU/Monarch's code, appropriate copyright applies.
  35.  * nov'98 -Padma.
  36.  *
  37.  * $Header: /nfs/jade/vint/CVSROOT/ns-2/trace/cmu-trace.cc,v 1.66 2002/04/01 23:07:28 buchheim Exp $
  38.  */
  40. #include <packet.h>
  41. #include <ip.h>
  42. #include <tcp.h>
  43. #include <rtp.h>
  44. #include <arp.h>
  45. #include <dsr/hdr_sr.h> // DSR
  46. #include <mac.h>
  47. #include <mac-802_11.h>
  48. #include <address.h>
  49. #include <tora/tora_packet.h> //TORA
  50. #include <imep/imep_spec.h>         // IMEP
  51. #include <aodv/aodv_packet.h> //AODV
  52. #include <cmu-trace.h>
  53. #include <mobilenode.h>
  55. #include "diffusion/diff_header.h" // DIFFUSION -- Chalermek
  58. //#define LOG_POSITION
  60. //extern char* pt_names[];
  62. static class CMUTraceClass : public TclClass {
  63. public:
  64. CMUTraceClass() : TclClass("CMUTrace") { }
  65. TclObject* create(int, const char*const* argv) {
  66. return (new CMUTrace(argv[4], *argv[5]));
  67. }
  68. } cmutrace_class;
  71. CMUTrace::CMUTrace(const char *s, char t) : Trace(t)
  72. {
  73. bzero(tracename, sizeof(tracename));
  74. strncpy(tracename, s, MAX_ID_LEN);
  76.         if(strcmp(tracename, "RTR") == 0) {
  77.                 tracetype = TR_ROUTER;
  78.         }
  79. else if(strcmp(tracename, "TRP") == 0) {
  80.                 tracetype = TR_ROUTER;
  81.         }
  82.         else if(strcmp(tracename, "MAC") == 0) {
  83.                 tracetype = TR_MAC;
  84.         }
  85.         else if(strcmp(tracename, "IFQ") == 0) {
  86.                 tracetype = TR_IFQ;
  87.         }
  88.         else if(strcmp(tracename, "AGT") == 0) {
  89.                 tracetype = TR_AGENT;
  90.         }
  91.         else {
  92.                 fprintf(stderr, "CMU Trace Initialized with invalid typen");
  93.                 exit(1);
  94.         }
  96. assert(type_ == DROP || type_ == SEND || type_ == RECV);
  98. newtrace_ = 0;
  99. for (int i=0 ; i < MAX_NODE ; i++) 
  100. nodeColor[i] = 3 ;
  101.         node_ = 0;
  102. }
  104. void
  105. CMUTrace::format_mac(Packet *p, const char *why, int offset)
  106. {
  107. struct hdr_cmn *ch = HDR_CMN(p);
  108. struct hdr_ip *ih = HDR_IP(p);
  109. struct hdr_mac802_11 *mh = HDR_MAC802_11(p);
  110. double x = 0.0, y = 0.0, z = 0.0;
  111.        
  112. char op = (char) type_;
  113. Node* thisnode = Node::get_node_by_address(src_);
  114. double energy = -1;
  115. if (thisnode) {
  116.     if (thisnode->energy_model()) {
  117.     energy = thisnode->energy_model()->energy();
  118.     }
  119. }
  121. // hack the IP address to convert pkt format to hostid format
  122. // for now until port ids are removed from IP address. -Padma.
  124. int src = Address::instance().get_nodeaddr(ih->saddr());
  126. if(tracetype == TR_ROUTER && type_ == SEND) {
  127. if(src_ != src)
  128. op = FWRD;
  129. }
  131. // use new tagged format if appropriate
  132. if (pt_->tagged()) {
  133. int next_hop = -1 ;
  134. Node* nextnode = Node::get_node_by_address(ch->next_hop_);
  135.          if (nextnode) next_hop = nextnode->nodeid(); 
  137. if (op == DROP) op = 'd';
  138. if (op == SEND) op = '+';
  139. if (op == FWRD) op = 'h';
  140. sprintf(pt_->buffer() + offset,
  141. "%c "TIME_FORMAT" -s %d -d %d -p %s -k %3s -i %d",
  142. op,
  143. Scheduler::instance().clock(),
  144. src_,
  145. next_hop,
  146. packet_info.name(ch->ptype()),
  147. tracename,
  148. ch->uid());
  149. return;
  150. }
  153. // Use new ns trace format to replace the old cmu trace format)
  154. if (newtrace_) {
  155.     
  156.     node_->getLoc(&x, &y, &z);
  157.     // consistence
  158.     if ( op == DROP ) { op = 'd';}
  160.         // basic trace infomation + basic exenstion
  162.     sprintf(pt_->buffer() + offset,
  163.    "%c -t %.9f -Hs %d -Hd %d -Ni %d -Nx %.2f -Ny %.2f -Nz %.2f -Ne %f -Nl %3s -Nw %s ",
  164.     op,                       // event type
  165.     Scheduler::instance().clock(),  // time
  166.     src_,                           // this node
  167.                     ch->next_hop_,                  // next hop
  168.     src_,                           // this node
  169.     x,                              // x coordinate
  170.     y,                              // y coordinate
  171.     z,                              // z coordinate
  172.     energy,                         // energy, -1 = not existing
  173.     tracename,                      // trace level
  174.                     why);                            // reason
  176.     // mac layer extension
  178.     offset = strlen(pt_->buffer());
  180.     sprintf(pt_->buffer() + offset, 
  181.     "-Ma %x -Md %x -Ms %x -Mt %x ",
  182.     mh->dh_duration,
  183.     ETHER_ADDR(mh->dh_da),
  184.     ETHER_ADDR(mh->dh_sa),
  185.     GET_ETHER_TYPE(mh->dh_body));
  186.     
  187.      return;
  188. }
  191. #ifdef LOG_POSITION
  192.         double x = 0.0, y = 0.0, z = 0.0;
  193.         node_->getLoc(&x, &y, &z);
  194. #endif
  196. sprintf(pt_->buffer() + offset,
  197. #ifdef LOG_POSITION
  198. "%c %.9f %d (%6.2f %6.2f) %3s %4s %d %s %d [%x %x %x %x] ",
  199. #else
  200. "%c %.9f _%d_ %3s %4s %d %s %d [%x %x %x %x] ",
  201. #endif
  202. op,
  203. Scheduler::instance().clock(),
  204.                 src_,                           // this node
  205. #ifdef LOG_POSITION
  206.                 x,
  207.                 y,
  208. #endif
  209. tracename,
  210. why,
  212.                 //ch->uid(),                      // identifier for this event
  214. //JUNGMIN : add channel info
  215. mh->dh_fc.fc_channel, //channel info
  217. ((ch->ptype() == PT_MAC) ? (
  218.   (mh->dh_fc.fc_subtype == MAC_Subtype_RTS) ? "RTS"  :
  219.   (mh->dh_fc.fc_subtype == MAC_Subtype_CTS) ? "CTS"  :
  220.   (mh->dh_fc.fc_subtype == MAC_Subtype_ACK) ? "ACK"  :
  221.   (mh->dh_fc.fc_subtype == MAC_Subtype_DRTS) ? "DRTS"  :
  222.   (mh->dh_fc.fc_subtype == MAC_Subtype_DCTS) ? "DCTS"  :
  223.   (mh->dh_fc.fc_subtype == MAC_Subtype_DRSH) ? "DRSH"  :
  224.   (mh->dh_fc.fc_subtype == MAC_Subtype_Beacon) ? "BCON" :
  225.   (mh->dh_fc.fc_subtype == MAC_Subtype_ATIM) ? "ATIM" :
  226.   (mh->dh_fc.fc_subtype == MAC_Subtype_ATIMACK) ? "AACK" :
  227.   (mh->dh_fc.fc_subtype == MAC_Subtype_ATIMRSH) ? "ARSH" :
  228.   "UNKN"
  229.   ) : packet_info.name(ch->ptype())),
  230. //end of JUNGMIN
  232. ch->size(),
  234. //*((u_int16_t*) &mh->dh_fc),
  235. mh->dh_duration,
  236. ETHER_ADDR(mh->dh_da),
  237. ETHER_ADDR(mh->dh_sa),
  238. GET_ETHER_TYPE(mh->dh_body));
  240. offset = strlen(pt_->buffer());
  242. if (thisnode) {
  243. if (thisnode->energy_model()) {
  244. sprintf(pt_->buffer() + offset,
  245. "[energy %f] ",
  246. thisnode->energy_model()->energy());
  247. }
  248.         }
  249. }
  251. void
  252. CMUTrace::format_ip(Packet *p, int offset)
  253. {
  254.         struct hdr_cmn *ch = HDR_CMN(p);
  255. struct hdr_ip *ih = HDR_IP(p);
  257. // hack the IP address to convert pkt format to hostid format
  258. // for now until port ids are removed from IP address. -Padma.
  259. int src = Address::instance().get_nodeaddr(ih->saddr());
  260. int dst = Address::instance().get_nodeaddr(ih->daddr());
  262. if (pt_->tagged()) {
  263. // Need to determine tag names for this data
  264. //sprintf(pt_->buffer() + offset,
  265. // "",
  266. // );
  267. } else if (newtrace_) {
  268.     sprintf(pt_->buffer() + offset,
  269.     "-Is %d.%d -Id %d.%d -It %s -Il %d -If %d -Ii %d -Iv %d ",
  270.     src,                           // packet src
  271.     ih->sport(),                   // src port
  272.     dst,                           // packet dest
  273.     ih->dport(),                   // dst port
  274.     packet_info.name(ch->ptype()),  // packet type
  275.     ch->size(),                     // packet size
  276.     ih->flowid(),                   // flow id
  277.     ch->uid(),                      // unique id
  278.     ih->ttl_);                      // ttl
  279. } else {
  280.     sprintf(pt_->buffer() + offset, "------- [%d:%d %d:%d %d %d] ",
  281. src, ih->sport(),
  282. dst, ih->dport(),
  283. ih->ttl_, (ch->next_hop_ < 0) ? 0 : ch->next_hop_);
  284. }
  285. }
  287. void
  288. CMUTrace::format_arp(Packet *p, int offset)
  289. {
  290. struct hdr_arp *ah = HDR_ARP(p);
  292. if (pt_->tagged()) {
  293. // Need to determine tag names for this data
  294. //sprintf(pt_->buffer() + offset,
  295. // "",
  296. // );
  297. } else if (newtrace_) {
  298.     sprintf(pt_->buffer() + offset,
  299.     "-P arp -Po %s -Pms %d -Ps %d -Pmd %d -Pd %d ",
  300.     ah->arp_op == ARPOP_REQUEST ?  "REQUEST" : "REPLY",
  301.     ah->arp_sha,
  302.     ah->arp_spa,
  303.     ah->arp_tha,
  304.     ah->arp_tpa);
  305. } else {
  307.     sprintf(pt_->buffer() + offset,
  308. "------- [%s %d/%d %d/%d]",
  309. ah->arp_op == ARPOP_REQUEST ?  "REQUEST" : "REPLY",
  310. ah->arp_sha,
  311. ah->arp_spa,
  312. ah->arp_tha,
  313. ah->arp_tpa);
  314. }
  315. }
  317. void
  318. CMUTrace::format_dsr(Packet *p, int offset)
  319. {
  320. hdr_sr *srh = hdr_sr::access(p);
  322. if (pt_->tagged()) {
  323. // Need to determine tag names for this data
  324. //sprintf(pt_->buffer() + offset,
  325. // "",
  326. // );
  327. } else if (newtrace_) {
  328.     sprintf(pt_->buffer() + offset, 
  329. "-P dsr -Ph %d -Pq %d -Ps %d -Pp %d -Pn %d -Pl %d -Pe %d->%d -Pw %d -Pm %d -Pc %d -Pb %d->%d ",
  330.     srh->num_addrs(),                   // how many nodes travered
  332. srh->route_request(),
  333. srh->rtreq_seq(),
  335. srh->route_reply(),
  336. srh->rtreq_seq(),
  337. srh->route_reply_len(),
  338. // the dest of the src route
  339. srh->reply_addrs()[0].addr,
  340. srh->reply_addrs()[srh->route_reply_len()-1].addr,
  342. srh->route_error(),
  343. srh->num_route_errors(),
  344. srh->down_links()[srh->num_route_errors() - 1].tell_addr,
  345. srh->down_links()[srh->num_route_errors() - 1].from_addr,
  346. srh->down_links()[srh->num_route_errors() - 1].to_addr);
  348.    return;
  349. }
  350. sprintf(pt_->buffer() + offset, 
  351. "%d [%d %d] [%d %d %d %d->%d] [%d %d %d %d->%d]",
  352. srh->num_addrs(),
  354. srh->route_request(),
  355. srh->rtreq_seq(),
  357. srh->route_reply(),
  358. srh->rtreq_seq(),
  359. srh->route_reply_len(),
  360. // the dest of the src route
  361. srh->reply_addrs()[0].addr,
  362. srh->reply_addrs()[srh->route_reply_len()-1].addr,
  364. srh->route_error(),
  365. srh->num_route_errors(),
  366. srh->down_links()[srh->num_route_errors() - 1].tell_addr,
  367. srh->down_links()[srh->num_route_errors() - 1].from_addr,
  368. srh->down_links()[srh->num_route_errors() - 1].to_addr);
  369. }
  371. void
  372. CMUTrace::format_msg(Packet *, int)
  373. {
  374. }
  376. void
  377. CMUTrace::format_tcp(Packet *p, int offset)
  378. {
  379. struct hdr_cmn *ch = HDR_CMN(p);
  380. struct hdr_tcp *th = HDR_TCP(p);
  382. if (pt_->tagged()) {
  383. // Need to determine tag names for this data
  384. //sprintf(pt_->buffer() + offset,
  385. // "",
  386. // );
  387. } else if (newtrace_) {
  388.     sprintf(pt_->buffer() + offset,
  389. "-Pn tcp -Ps %d -Pa %d -Pf %d -Po %d ",
  390. th->seqno_,
  391. th->ackno_,
  392. ch->num_forwards(),
  393. ch->opt_num_forwards());
  395. } else {
  396.     sprintf(pt_->buffer() + offset,
  397. "[%d %d] %d %d",
  398. th->seqno_,
  399. th->ackno_,
  400. ch->num_forwards(),
  401. ch->opt_num_forwards());
  402. }
  403. }
  405. void
  406. CMUTrace::format_rtp(Packet *p, int offset)
  407. {
  408. struct hdr_cmn *ch = HDR_CMN(p);
  409. struct hdr_rtp *rh = HDR_RTP(p);
  410. struct hdr_ip *ih = HDR_IP(p);
  411.         Node* thisnode = Node::get_node_by_address(src_);
  413. //hacking, needs to change later, 
  414.         int dst = Address::instance().get_nodeaddr(ih->daddr());
  416. if (dst == src_){
  417. // I just received a cbr data packet
  418. if (thisnode->energy_model() && 
  419.     thisnode->energy_model()->powersavingflag()) {
  420. thisnode->energy_model()->set_node_state(EnergyModel::INROUTE);
  421. }
  422.         }
  424. if (pt_->tagged()) {
  425. // Need to determine tag names for this data
  426. //sprintf(pt_->buffer() + offset,
  427. // "",
  428. // );
  429. } else if (newtrace_) {
  430. sprintf(pt_->buffer() + offset,
  431. "-Pn cbr -Pi %d -Pf %d -Po %d ",
  432. rh->seqno_,
  433. ch->num_forwards(),
  434. ch->opt_num_forwards());
  435. } else {
  436. sprintf(pt_->buffer() + offset,
  437. "[%d] %d %d",
  438. rh->seqno_,
  439. ch->num_forwards(),
  440. ch->opt_num_forwards());
  441. }
  442. }
  444. void
  445. CMUTrace::format_imep(Packet *p, int offset)
  446. {
  447.         struct hdr_imep *im = HDR_IMEP(p);
  449. #define U_INT16_T(x)    *((u_int16_t*) &(x))
  451. if (pt_->tagged()) {
  452. // Need to determine tag names for this data
  453. //sprintf(pt_->buffer() + offset,
  454. // "",
  455. // );
  456. } else if (newtrace_) {
  457.     sprintf(pt_->buffer() + offset,
  458.                 "-P imep -Pa %c -Ph %c -Po %c -Pl 0x%04x ] ",
  459.                 (im->imep_block_flags & BLOCK_FLAG_ACK) ? 'A' : '-',
  460.                 (im->imep_block_flags & BLOCK_FLAG_HELLO) ? 'H' : '-',
  461.                 (im->imep_block_flags & BLOCK_FLAG_OBJECT) ? 'O' : '-',
  462.                 U_INT16_T(im->imep_length));
  463. } else {
  464.             sprintf(pt_->buffer() + offset,
  465.                 "[%c %c %c 0x%04x] ",
  466.                 (im->imep_block_flags & BLOCK_FLAG_ACK) ? 'A' : '-',
  467.                 (im->imep_block_flags & BLOCK_FLAG_HELLO) ? 'H' : '-',
  468.                 (im->imep_block_flags & BLOCK_FLAG_OBJECT) ? 'O' : '-',
  469.                 U_INT16_T(im->imep_length));
  470. }
  471. #undef U_INT16_T
  472. }
  475. void
  476. CMUTrace::format_tora(Packet *p, int offset)
  477. {
  478.         struct hdr_tora *th = HDR_TORA(p);
  479.         struct hdr_tora_qry *qh = HDR_TORA_QRY(p);
  480.         struct hdr_tora_upd *uh = HDR_TORA_UPD(p);
  481.         struct hdr_tora_clr *ch = HDR_TORA_CLR(p);
  483.         switch(th->th_type) {
  485.         case TORATYPE_QRY:
  487. if (pt_->tagged()) {
  488. // Need to determine tag names for this data
  489. //sprintf(pt_->buffer() + offset,
  490. // "",
  491. // );
  492. } else if (newtrace_) {
  493.     sprintf(pt_->buffer() + offset,
  494. "-P tora -Pt 0x%x -Pd %d -Pc QUERY ",
  495.                         qh->tq_type, qh->tq_dst);
  497.                 } else {
  499.                     sprintf(pt_->buffer() + offset, "[0x%x %d] (QUERY)",
  500.                         qh->tq_type, qh->tq_dst);
  501. }
  502.                 break;
  504.         case TORATYPE_UPD:
  506. if (pt_->tagged()) {
  507. // Need to determine tag names for this data
  508. //sprintf(pt_->buffer() + offset,
  509. // "",
  510. // );
  511. } else if (newtrace_) {
  512.     sprintf(pt_->buffer() + offset,
  513.                         "-P tora -Pt 0x%x -Pd %d (%f %d %d %d %d) -Pc UPDATE ",
  514.                         uh->tu_type,
  515.                         uh->tu_dst,
  516.                         uh->tu_tau,
  517.                         uh->tu_oid,
  518.                         uh->tu_r,
  519.                         uh->tu_delta,
  520.                         uh->tu_id);
  521. } else {
  522.                     sprintf(pt_->buffer() + offset,
  523.                         "-Pt 0x%x -Pd %d -Pa %f -Po %d -Pr %d -Pe %d -Pi %d -Pc UPDATE ",
  524.                         uh->tu_type,
  525.                         uh->tu_dst,
  526.                         uh->tu_tau,
  527.                         uh->tu_oid,
  528.                         uh->tu_r,
  529.                         uh->tu_delta,
  530.                         uh->tu_id);
  531. }
  532.                 break;
  534.         case TORATYPE_CLR:
  535. if (pt_->tagged()) {
  536. // Need to determine tag names for this data
  537. //sprintf(pt_->buffer() + offset,
  538. // "",
  539. // );
  540. } else if (newtrace_) {
  541.     sprintf(pt_->buffer() + offset, 
  542. "-P tora -Pt 0x%x -Pd %d -Pa %f -Po %d -Pc CLEAR ",
  543.                         ch->tc_type,
  544.                         ch->tc_dst,
  545.                         ch->tc_tau,
  546.                         ch->tc_oid);
  547. } else {
  548.                     sprintf(pt_->buffer() + offset, "[0x%x %d %f %d] (CLEAR)",
  549.                         ch->tc_type,
  550.                         ch->tc_dst,
  551.                         ch->tc_tau,
  552.                         ch->tc_oid);
  553. }
  554.                 break;
  555.         }
  556. }
  558. void
  559. CMUTrace::format_aodv(Packet *p, int offset)
  560. {
  561.         struct hdr_aodv *ah = HDR_AODV(p);
  562.         struct hdr_aodv_request *rq = HDR_AODV_REQUEST(p);
  563.         struct hdr_aodv_reply *rp = HDR_AODV_REPLY(p);
  566.         switch(ah->ah_type) {
  567.         case AODVTYPE_RREQ:
  569. if (pt_->tagged()) {
  570. // Need to determine tag names for this data
  571. //sprintf(pt_->buffer() + offset,
  572. // "",
  573. // );
  574. } else if (newtrace_) {
  576.     sprintf(pt_->buffer() + offset,
  577. "-P aodv -Pt 0x%x -Ph %d -Pb %d -Pd %d -Pds %d -Ps %d -Pss %d -Pc REQUEST ",
  578. rq->rq_type,
  579.                         rq->rq_hop_count,
  580.                         rq->rq_bcast_id,
  581.                         rq->rq_dst,
  582.                         rq->rq_dst_seqno,
  583.                         rq->rq_src,
  584.                         rq->rq_src_seqno);
  587. } else {
  589.     sprintf(pt_->buffer() + offset,
  590. "[0x%x %d %d [%d %d] [%d %d]] (REQUEST)",
  591. rq->rq_type,
  592.                         rq->rq_hop_count,
  593.                         rq->rq_bcast_id,
  594.                         rq->rq_dst,
  595.                         rq->rq_dst_seqno,
  596.                         rq->rq_src,
  597.                         rq->rq_src_seqno);
  598. }
  599.                 break;
  601.         case AODVTYPE_RREP:
  602.         case AODVTYPE_HELLO:
  603. case AODVTYPE_RERR:
  605. if (pt_->tagged()) {
  606. // Need to determine tag names for this data
  607. //sprintf(pt_->buffer() + offset,
  608. // "",
  609. // );
  610. } else if (newtrace_) {
  612. sprintf(pt_->buffer() + offset,
  613.     "-P aodv -Pt 0x%x -Ph %d -Pd %d -Pds %d -Pl %f -Pc %s ",
  614. rp->rp_type,
  615. rp->rp_hop_count,
  616. rp->rp_dst,
  617. rp->rp_dst_seqno,
  618. rp->rp_lifetime,
  619. rp->rp_type == AODVTYPE_RREP ? "REPLY" :
  620. (rp->rp_type == AODVTYPE_RERR ? "ERROR" :
  621.  "HELLO"));
  622.         } else {
  624. sprintf(pt_->buffer() + offset,
  625. "[0x%x %d [%d %d] %f] (%s)",
  626. rp->rp_type,
  627. rp->rp_hop_count,
  628. rp->rp_dst,
  629. rp->rp_dst_seqno,
  630. rp->rp_lifetime,
  631. rp->rp_type == AODVTYPE_RREP ? "REPLY" :
  632. (rp->rp_type == AODVTYPE_RERR ? "ERROR" :
  633.  "HELLO"));
  634. }
  635.                 break;
  637.         default:
  638. #ifdef WIN32
  639.                 fprintf(stderr,
  640.         "CMUTrace::format_aodv: invalid AODV packet typen");
  641. #else
  642. fprintf(stderr,
  643.         "%s: invalid AODV packet typen", __FUNCTION__);
  644. #endif
  645.                 abort();
  646.         }
  647. }
  649. void
  650. CMUTrace::nam_format(Packet *p, int offset)
  651. {
  652. Node* srcnode = 0 ;
  653. Node* dstnode = 0 ;
  654. Node* nextnode = 0 ;
  655.         struct hdr_cmn *ch = HDR_CMN(p);
  656. struct hdr_ip *ih = HDR_IP(p);
  657. char op = (char) type_;
  658. char colors[32];
  659. int next_hop = -1 ;
  661.         int dst = Address::instance().get_nodeaddr(ih->daddr());
  663. nextnode = Node::get_node_by_address(ch->next_hop_);
  664.         if (nextnode) next_hop = nextnode->nodeid(); 
  666. srcnode = Node::get_node_by_address(src_);
  667. dstnode = Node::get_node_by_address(ch->next_hop_);
  669. double distance = 0;
  671.         if ((srcnode) && (dstnode)) {
  672.    MobileNode* tmnode = (MobileNode*)srcnode;
  673.    MobileNode* rmnode = (MobileNode*)dstnode;
  675.    distance = tmnode->propdelay(rmnode) * 300000000 ;
  676. }
  678. double energy = -1;
  679. double initenergy = -1;
  681. //default value for changing node color with respect to energy depletion
  682. double l1 = 0.5; 
  683. double l2 = 0.2;
  685. if (srcnode) {
  686.     if (srcnode->energy_model()) {
  687.     energy = srcnode->energy_model()->energy();
  688.     initenergy = srcnode->energy_model()->initialenergy();
  689.     l1 = srcnode->energy_model()->level1();
  690.     l2 = srcnode->energy_model()->level2();
  691.     }
  692. }
  694.         int energyLevel = 0 ;
  695.         double energyLeft = (double)(energy/initenergy) ;
  697.         if ((energyLeft <= 1 ) && (energyLeft >= l1 )) energyLevel = 3;
  698.         if ((energyLeft >= l2 ) && (energyLeft < l1 )) energyLevel = 2;
  699.         if ((energyLeft > 0 ) && (energyLeft < l2 )) energyLevel = 1;
  701. if (energyLevel == 0) 
  702. strcpy(colors,"-c black -o red");
  703.         else if (energyLevel == 1) 
  704. strcpy(colors,"-c red -o yellow");
  705.         else if (energyLevel == 2) 
  706. strcpy(colors,"-c yellow -o green");
  707.         else if (energyLevel == 3) 
  708. strcpy(colors,"-c green -o black");
  710. // A simple hack for scadds demo (fernandez's visit) -- Chalermek
  711. int pkt_color = 0;
  712. if (ch->ptype()==PT_DIFF) {
  713. hdr_cdiff *dfh= HDR_CDIFF(p);
  714. if (dfh->mess_type != DATA) {
  715. pkt_color = 1;
  716. }
  717. }
  718. // convert to nam format 
  719. if (op == 's') op = 'h' ;
  720. if (op == 'D') op = 'd' ;
  721. if (op == 'h') {
  722.    sprintf(pt_->nbuffer(),
  723. "+ -t %.9f -s %d -d %d -p %s -e %d -c 2 -a %d -i %d -k %3s ",
  724. Scheduler::instance().clock(),
  725. src_,                           // this node
  726. next_hop,
  727. packet_info.name(ch->ptype()),
  728. ch->size(),
  729. pkt_color,   
  730. ch->uid(),
  731. tracename);
  733.    offset = strlen(pt_->nbuffer());
  734.    pt_->namdump();
  735.    sprintf(pt_->nbuffer() ,
  736. "- -t %.9f -s %d -d %d -p %s -e %d -c 2 -a %d -i %d -k %3s",
  737. Scheduler::instance().clock(),
  738. src_,                           // this node
  739. next_hop,
  740. packet_info.name(ch->ptype()),
  741. ch->size(),
  742. pkt_color,
  743. ch->uid(),
  744. tracename);
  746.    offset = strlen(pt_->nbuffer());
  747.            pt_->namdump();
  748. }
  750.         // if nodes are too far from each other
  751. // nam won't dump SEND event 'cuz it's
  752. // gonna be dropped later anyway
  753. // this value 250 is pre-calculated by using 
  754. // two-ray ground refelction model with fixed
  755. // transmission power 3.652e-10
  756. // if ((type_ == SEND)  && (distance > 250 )) return ;
  758. if(tracetype == TR_ROUTER && type_ == RECV && dst != -1 ) return ;
  759. if(type_ == RECV && dst == -1 )dst = src_ ; //broadcasting event
  761.         if (energy != -1) { //energy model being turned on
  762.    if (nodeColor[src_] != energyLevel ) { //only dump it when node  
  763.        sprintf(pt_->nbuffer() ,                    //color change
  764.           "n -t %.9f -s %d -S COLOR %s",
  765.            Scheduler::instance().clock(),
  766.            src_,                           // this node
  767.            colors);
  768.                offset = strlen(pt_->nbuffer());
  769.                pt_->namdump();
  770.        nodeColor[src_] = energyLevel ;
  771.     }   
  772.         }
  774. sprintf(pt_->nbuffer() ,
  775. "%c -t %.9f -s %d -d %d -p %s -e %d -c 2 -a %d -i %d -k %3s",
  776. op,
  777. Scheduler::instance().clock(),
  778. src_,                           // this node
  779. next_hop,
  780. packet_info.name(ch->ptype()),
  781. ch->size(),
  782. pkt_color,
  783. ch->uid(),
  784. tracename);
  786. offset = strlen(pt_->nbuffer());
  787. pt_->namdump();
  788. }
  790. void CMUTrace::format(Packet* p, const char *why)
  791. {
  793. hdr_cmn *ch = HDR_CMN(p);
  794. int offset = 0;
  796. /*
  797.  * Log the MAC Header
  798.  */
  799. format_mac(p, why, offset);
  801. if (pt_->namchannel()) 
  802. nam_format(p, offset);
  803. offset = strlen(pt_->buffer());
  804. switch(ch->ptype()) {
  805. case PT_MAC:
  806. break;
  807. case PT_ARP:
  808. format_arp(p, offset);
  809. break;
  810. default:
  811. format_ip(p, offset);
  812. offset = strlen(pt_->buffer());
  813. switch(ch->ptype()) {
  814. case PT_AODV:
  815. format_aodv(p, offset);
  816. break;
  817. case PT_TORA:
  818.                         format_tora(p, offset);
  819.                         break;
  820.                 case PT_IMEP:
  821.                         format_imep(p, offset);
  822.                         break;
  823. case PT_DSR:
  824. format_dsr(p, offset);
  825. break;
  826. case PT_MESSAGE:
  827. case PT_UDP:
  828. format_msg(p, offset);
  829. break;
  830. case PT_TCP:
  831. case PT_ACK:
  832. format_tcp(p, offset);
  833. break;
  834. case PT_CBR:
  835. format_rtp(p, offset);
  836. break;
  837.         case PT_DIFF:
  838. break;
  839. case PT_GAF:
  840. break;
  841. default:
  842. fprintf(stderr, "%s - invalid packet type (%s).n",
  843. __PRETTY_FUNCTION__, packet_info.name(ch->ptype()));
  844. exit(1);
  845. }
  846. }
  847. }
  849. int
  850. CMUTrace::command(int argc, const char*const* argv)
  851. {
  853.         if(argc == 3) {
  854.                 if(strcmp(argv[1], "node") == 0) {
  855.                         node_ = (MobileNode*) TclObject::lookup(argv[2]);
  856.                         if(node_ == 0)
  857.                                 return TCL_ERROR;
  858.                         return TCL_OK;
  859.                 }
  860. if (strcmp(argv[1], "newtrace") == 0) {
  861. newtrace_ = atoi(argv[2]);
  862.         return TCL_OK;
  863. }
  864.         }
  865. return Trace::command(argc, argv);
  866. }
  868. /*ARGSUSED*/
  869. void
  870. CMUTrace::recv(Packet *p, Handler *h)
  871. {
  872. if (!node_energy()) {
  873. Packet::free(p);
  874. return;
  875. }
  876.         assert(initialized());
  877.         /*
  878.          * Agent Trace "stamp" the packet with the optimal route on
  879.          * sending.
  880.          */
  881.         if (tracetype == TR_AGENT && type_ == SEND) {
  882.                 God::instance()->stampPacket(p);
  883.         }
  884. #if 0
  885.         /*
  886.          * When the originator of a packet drops the packet, it may or may
  887.          * not have been stamped by GOD.  Stamp it before logging the
  888.          * information.
  889.          */
  890.         if(src_ == src && type_ == DROP) {
  891.                 God::instance()->stampPacket(p);
  892.         }
  893. #endif
  895. format(p, "---");
  896. pt_->dump();
  897. //namdump();
  898. if(target_ == 0)
  899. Packet::free(p);
  900. else
  901. send(p, h);
  902. }
  904. void
  905. CMUTrace::recv(Packet *p, const char* why)
  906. {
  908.         assert(initialized() && type_ == DROP);
  909. if (!node_energy()) {
  910. Packet::free(p);
  911. return;
  912. }
  913. #if 0
  914.         /*
  915.          * When the originator of a packet drops the packet, it may or may
  916.          * not have been stamped by GOD.  Stamp it before logging the
  917.          * information.
  918.          */
  919.         if(src_ == ih->saddr()) {
  920.                 God::instance()->stampPacket(p);
  921.         }
  922. #endif
  923. format(p, why);
  924. pt_->dump();
  925. //namdump();
  926. Packet::free(p);
  927. }
  929. int CMUTrace::node_energy()
  930. {
  931. Node* thisnode = Node::get_node_by_address(src_);
  932. double energy = 1;
  933. if (thisnode) {
  934. if (thisnode->energy_model()) {
  935. energy = thisnode->energy_model()->energy();
  936. }
  937. } 
  938. if (energy > 0) return 1;
  939. return 0;
  940. }