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

通讯编程

开发平台:

Visual C++

  1. /*
  2.  * flooding.h
  3.  * Copyright (C) 2000 by the University of Southern California
  4.  * $Id: flooding.h,v 1.4 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. /* flooding.h : Chalermek Intanagonwiwat (USC/ISI)  08/16/99    */
  47. /****************************************************************/
  48. // Share api with diffusion and omnicient multicast
  49. // Using diffusion packet header
  50. #ifndef ns_flooding_h
  51. #define ns_flooding_h
  52. #include <assert.h>
  53. #include <math.h>
  54. #include <stdio.h>
  55. #include <signal.h>
  56. #include <float.h>
  57. #include <stdlib.h>
  58. #include <tcl.h>
  59. #include "diff_header.h"
  60. #include "agent.h"
  61. #include "tclcl.h"
  62. #include "ip.h"
  63. #include "config.h"
  64. #include "packet.h"
  65. #include "trace.h"
  66. #include "random.h"
  67. #include "classifier.h"
  68. #include "node.h"
  69. #include "iflist.h"
  70. #include "hash_table.h"
  71. #include "arp.h"
  72. #include "mac.h"
  73. #include "ll.h"
  74. #include "dsr/path.h"
  75. #define THIS_NODE             here_.addr_
  76. #define JITTER                0.11       // (sec) to jitter broadcast
  77. #define SEND_MESSAGE(x,y,z)  send_to_dmux(prepare_message(x,y,z), 0)
  78. // Flooding Entry
  79. class Flooding_Entry {
  80.  public:
  81.   Agent_List *source;
  82.   Agent_List *sink;
  83.   Flooding_Entry() { 
  84.     source       = NULL;
  85.     sink         = NULL;
  86.   }
  87.  void reset();
  88.  void clear_agentlist(Agent_List *);
  89. };
  90. // Flooding Agent
  91. class FloodingAgent : public Agent {
  92.  public:
  93.   FloodingAgent();
  94.   int command(int argc, const char*const* argv);
  95.   void recv(Packet*, Handler*);
  96.   Flooding_Entry routing_table[MAX_DATA_TYPE];
  97.  protected:
  98.   int pk_count;
  99.   Pkt_Hash_Table PktTable;
  100.   Node *node;
  101.   Trace *tracetarget;       // Trace Target
  102.   NsObject *ll;  
  103.   NsObject *port_dmux;
  104.   inline void send_to_dmux(Packet *pkt, Handler *h) { 
  105.     port_dmux->recv(pkt, h); 
  106.   }
  107.   void Terminate();
  108.   void reset();
  109.   void ConsiderNew(Packet *pkt);
  110.  
  111.   Packet *create_packet();
  112.   Packet *prepare_message(unsigned int dtype, ns_addr_t to_addr, int msg_type);
  113.   void DataForSink(Packet *pkt);
  114.   void StopSource();
  115.   void MACprepare(Packet *pkt);
  116.   void MACsend(Packet *pkt, Time delay=0);
  117.   void trace(char *fmt,...);
  118. };
  119. #endif