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

通讯编程

开发平台:

Visual C++

  1. /*
  2.  * diff_sink.h
  3.  * Copyright (C) 2000 by the University of Southern California
  4.  * $Id: diff_sink.h,v 1.5 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_sink.h : Header file for sink agent                     */
  47. /*  By     : Chalermek Intanagonwiwat (USC/ISI)                  */
  48. /*  Last Modified : 8/21/99                                      */
  49. /*****************************************************************/
  50. #ifndef ns_diff_sink_h
  51. #define ns_diff_sink_h
  52. #include "agent.h"
  53. #include "tclcl.h"
  54. #include "packet.h"
  55. #include "ip.h"
  56. #include "diff_header.h"
  57. #include "diffusion.h"
  58. class SinkAgent;
  59. // Timer for packet rate
  60. class Sink_Timer : public TimerHandler {
  61.  public:
  62. Sink_Timer(SinkAgent *a) : TimerHandler() { a_ = a; }
  63.  protected:
  64. virtual void expire(Event *e);
  65. SinkAgent *a_;
  66. };
  67. // For periodic report of avg and var pkt received.
  68. class Report_Timer : public TimerHandler {
  69.  public:
  70. Report_Timer(SinkAgent *a) : TimerHandler() { a_ = a; }
  71.  protected:
  72. virtual void expire(Event *e);
  73. SinkAgent *a_;
  74. };
  75. // Timer for periodic interest
  76. class Periodic_Timer : public TimerHandler {
  77.  public:
  78. Periodic_Timer(SinkAgent *a) : TimerHandler() { a_ = a; }
  79.  protected:
  80. virtual void expire(Event *e);
  81. SinkAgent *a_;
  82. };
  83. // Class SinkAgent as source and sink for directed diffusion
  84. class SinkAgent : public Agent {
  85.  public:
  86.   SinkAgent();
  87.   int command(int argc, const char*const* argv);
  88.   virtual void timeout(int);
  89.   void report();
  90.   void recv(Packet*, Handler*);
  91.   void reset();
  92.   void set_addr(ns_addr_t);
  93.   int get_pk_count();
  94.   void incr_pk_count();
  95.   Packet *create_packet();
  96.  protected:
  97.   bool APP_DUP_;
  98.   bool periodic_;
  99.   bool always_max_rate_;
  100.   int pk_count;
  101.   unsigned int data_type_;
  102.   int num_recv;
  103.   int num_send;
  104.   int RecvPerSec;
  105.   double cum_delay;
  106.   double last_arrival_time;
  107.   Data_Hash_Table DataTable;
  108.   void Terminate();
  109.   void bcast_interest();
  110.   void data_ready();
  111.   void start();
  112.   void stop();
  113.   virtual void sendpkt();
  114.   int running_;
  115.   int random_;
  116.   int maxpkts_;
  117.   double interval_;
  118.   int simple_report_rate;
  119.   int data_counter;
  120.  
  121.   Sink_Timer sink_timer_;
  122.   Periodic_Timer periodic_timer_;
  123.   Report_Timer report_timer_;
  124.   friend class Periodic_Timer;
  125. };
  126. #endif