diff_prob.h
上传用户:rrhhcc
上传日期:2015-12-11
资源大小:54129k
文件大小:5k
源码类别:

通讯编程

开发平台:

Visual C++

  1. /*
  2.  * diff_prob.h
  3.  * Copyright (C) 2000 by the University of Southern California
  4.  * $Id: diff_prob.h,v 1.9 2005/08/25 18:58:03 johnh Exp $
  5.  *
  6.  * This program is free software; you can redistribute it and/or
  7.  * modify it under the terms of the GNU General Public License,
  8.  * version 2, as published by the Free Software Foundation.
  9.  *
  10.  * This program is distributed in the hope that it will be useful,
  11.  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  12.  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  13.  * GNU General Public License for more details.
  14.  *
  15.  * You should have received a copy of the GNU General Public License along
  16.  * with this program; if not, write to the Free Software Foundation, Inc.,
  17.  * 59 Temple Place, Suite 330, Boston, MA 02111-1307, USA.
  18.  *
  19.  *
  20.  * The copyright of this module includes the following
  21.  * linking-with-specific-other-licenses addition:
  22.  *
  23.  * In addition, as a special exception, the copyright holders of
  24.  * this module give you permission to combine (via static or
  25.  * dynamic linking) this module with free software programs or
  26.  * libraries that are released under the GNU LGPL and with code
  27.  * included in the standard release of ns-2 under the Apache 2.0
  28.  * license or under otherwise-compatible licenses with advertising
  29.  * requirements (or modified versions of such code, with unchanged
  30.  * license).  You may copy and distribute such a system following the
  31.  * terms of the GNU GPL for this module and the licenses of the
  32.  * other code concerned, provided that you include the source code of
  33.  * that other code when and as the GNU GPL requires distribution of
  34.  * source code.
  35.  *
  36.  * Note that people who make modified versions of this module
  37.  * are not obligated to grant this special exception for their
  38.  * modified versions; it is their choice whether to do so.  The GNU
  39.  * General Public License gives permission to release a modified
  40.  * version without this exception; this exception also makes it
  41.  * possible to release a modified version which carries forward this
  42.  * exception.
  43.  *
  44.  */
  45. /****************************************************************/
  46. /* diff_prob.h : Chalermek Intanagonwiwat (USC/ISI)  08/16/99   */
  47. /****************************************************************/
  48. // Important Note: Work still in progress !!! Major improvement is needed.
  49. #ifndef ns_diff_prob_h
  50. #define ns_diff_prob_h
  51. #include <assert.h>
  52. #include <math.h>
  53. #include <stdio.h>
  54. #include <signal.h>
  55. #include <float.h>
  56. #include <stdlib.h>
  57. #include <tcl.h>
  58. #include "diff_header.h"
  59. #include "agent.h"
  60. #include "tclcl.h"
  61. #include "ip.h"
  62. #include "config.h"
  63. #include "packet.h"
  64. #include "trace.h"
  65. #include "random.h"
  66. #include "classifier.h"
  67. #include "node.h"
  68. #include "iflist.h"
  69. #include "hash_table.h"
  70. #include "arp.h"
  71. #include "mac.h"
  72. #include "ll.h"
  73. #include "dsr/path.h"
  74. #include "routing_table.h"
  75. #include "diffusion.h"
  76. //#define DEBUG_PROB
  77. #define BACKTRACK_            false
  78. #define ENERGY_CHECK          0.05         // (sec) between energy checks
  79. #define INTEREST_DELAY        0.05         // (sec) bw receive and forward
  80. #define MAX_REINFORCE_COUNTER 10           // (pkts) bw pos reinf
  81. class DiffusionProb;
  82. class EnergyTimer : public TimerHandler {
  83. public:
  84. EnergyTimer(DiffusionProb *a, Node *b) : TimerHandler() { 
  85. a_ = a; 
  86. node_ = b;
  87. init_eng_ = node_->energy_model()->energy();
  88. threshold_ = init_eng_ / 2;
  89. }
  90. virtual void expire(Event *e);
  91. protected:
  92. DiffusionProb *a_;
  93. Node *node_;
  94. double init_eng_;
  95. double threshold_;
  96. };
  97. class InterestTimer : public TimerHandler {
  98. public:
  99.   InterestTimer(DiffusionProb *a, Pkt_Hash_Entry *hashPtr, Packet *pkt) : 
  100.     TimerHandler() 
  101.   { 
  102.       a_ = a; 
  103.       hashPtr_ = hashPtr;
  104.       pkt_ = pkt;
  105.   }
  106.   virtual ~InterestTimer() {
  107.     if (pkt_ != NULL) 
  108.       Packet::free(pkt_);
  109.   }
  110.   virtual void expire(Event *e);
  111. protected:
  112.   DiffusionProb *a_;
  113.   Pkt_Hash_Entry *hashPtr_;
  114.   Packet *pkt_;
  115. };
  116. class DiffusionProb : public DiffusionAgent {
  117.  public:
  118.   DiffusionProb();
  119.   void recv(Packet*, Handler*);
  120.  protected:
  121.   int num_neg_bcast_send;
  122.   int num_neg_bcast_rcv;
  123.   EnergyTimer *energy_timer;
  124.   bool is_low_power;
  125.   void Start();
  126.   void consider_old(Packet *);
  127.   void consider_new(Packet *);
  128.   void add_outlist(unsigned int, From_List *);
  129.   void data_request_all(unsigned int dtype);
  130.   void CreateIOList(Pkt_Hash_Entry *, unsigned int);
  131.   void UpdateIOList(From_List *, unsigned int);
  132.   void Print_IOlist();
  133.   void CalGradient(unsigned int);
  134.   void IncGradient(unsigned int, ns_addr_t);
  135.   void DecGradient(unsigned int, ns_addr_t);
  136.   void ForwardData(Packet *);
  137.   void ForwardTxFailed(Packet *);
  138.   void ReTxData(Packet *);
  139.   void GenPosReinf(unsigned int);
  140.   void FwdPosReinf(unsigned int, Packet *);
  141.   void InterfaceDown(int, ns_addr_t);
  142.   void SendInhibit(int);
  143.   void SendNegReinf();
  144.   void InterestPropagate(Packet *pkt, Pkt_Hash_Entry *hashPtr);
  145.   void xmitFailed(Packet *pkt);
  146.   friend class InterestTimer;
  147.   friend class EnergyTimer;
  148. };
  149. #endif