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

通讯编程

开发平台:

Visual C++

  1. /*
  2.  * webserver.h
  3.  * Copyright (C) 1999 by the University of Southern California
  4.  * $Id: webserver.h,v 1.5 2005/08/25 18:58:13 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. // Incorporation Polly's web traffic module into the PagePool framework
  47. //
  48. // Simple web server implementation
  49. // Two server scheduling policies supported: fcfs and stf
  50. // Xuan Chen (xuanc@isi.edu)
  51. //
  52. #ifndef ns_webserver_h
  53. #define ns_webserver_h
  54. #include "webtraf.h"
  55. #define NO_DELAY 0
  56. #define FCFS_DELAY 1
  57. #define STF_DELAY 2
  58. // Data structure for incoming jobs (requests)
  59. struct job_s {
  60.   int obj_id;
  61.   Node *clnt;
  62.   Agent *tcp;
  63.   Agent *snk;
  64.   int size;
  65.   void *data;
  66.   job_s *next;
  67. };
  68. class WebTrafPool;
  69. // Data structure for web server
  70. class WebServer : public TimerHandler{
  71.  private:
  72.        void WebServer_init(WebTrafPool *);
  73.  public:
  74. WebServer(WebTrafPool*pool_) { WebServer_init(pool_); };
  75. WebServer() { WebServer_init(NULL); };
  76. // Assign node to server
  77. void set_node(Node *);
  78. // Return server's node
  79. Node* get_node();
  80. // Return server's node id
  81. int get_nid();
  82. // Set server processing rate
  83. void set_rate(double);
  84. // Set server function mode
  85. void set_mode(int);
  86. // Set the limit for job queue
  87. void set_queue_limit(int);
  88. // Handling incoming job
  89. double job_arrival(int, Node *, Agent *, Agent *, int, void *);
  90.  private:
  91. // The web page pool associated with this server
  92. WebTrafPool *web_pool_;
  93. // The node associated with this server
  94. Node *node;
  95. // Server processing rate KB/s
  96. double rate_;
  97. // Flag for web server:
  98. // 0: there's no server processing delay
  99. // 1: server processing delay from FCFS scheduling policy
  100. // 2: server processing delay from STF scheduling policy
  101. int mode_;
  102. // Job queue
  103. job_s *head, *tail;
  104. int queue_size_;
  105. int queue_limit_;
  106. virtual void expire(Event *e);
  107. double job_departure();
  108. // Flag for server status
  109. int busy_;
  110. void schedule_next_job();
  111. };
  112. #endif //ns_webserver_h