carp.c
上传用户:liugui
上传日期:2007-01-04
资源大小:822k
文件大小:4k
源码类别:

代理服务器

开发平台:

Unix_Linux

  1. /*
  2.  * $Id: carp.c,v 1.6 1998/08/17 21:55:20 wessels Exp $
  3.  *
  4.  * DEBUG: section 39    Cache Array Routing Protocol
  5.  * AUTHOR: Eric Stern
  6.  *
  7.  * SQUID Internet Object Cache  http://squid.nlanr.net/Squid/
  8.  * ----------------------------------------------------------
  9.  *
  10.  *  Squid is the result of efforts by numerous individuals from the
  11.  *  Internet community.  Development is led by Duane Wessels of the
  12.  *  National Laboratory for Applied Network Research and funded by the
  13.  *  National Science Foundation.  Squid is Copyrighted (C) 1998 by
  14.  *  Duane Wessels and the University of California San Diego.  Please
  15.  *  see the COPYRIGHT file for full details.  Squid incorporates
  16.  *  software developed and/or copyrighted by other sources.  Please see
  17.  *  the CREDITS file for full details.
  18.  *
  19.  *  This program is free software; you can redistribute it and/or modify
  20.  *  it under the terms of the GNU General Public License as published by
  21.  *  the Free Software Foundation; either version 2 of the License, or
  22.  *  (at your option) any later version.
  23.  *  
  24.  *  This program is distributed in the hope that it will be useful,
  25.  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  26.  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  27.  *  GNU General Public License for more details.
  28.  *  
  29.  *  You should have received a copy of the GNU General Public License
  30.  *  along with this program; if not, write to the Free Software
  31.  *  Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111, USA.
  32.  *
  33.  */
  34. #include "squid.h"
  35. #if USE_CARP
  36. void
  37. carpInit(void)
  38. {
  39.     /* calculate load factors */
  40.     int K = 0;
  41.     float a = 0.0;
  42.     float Xn;
  43.     float P_last;
  44.     float X_last;
  45.     int k;
  46.     peer *p;
  47.     for (p = Config.peers; p; p = p->next) {
  48. a += p->carp.load_factor;
  49. K++;
  50.     }
  51.     if (a == 0.0) {
  52. for (p = Config.peers; p; p = p->next)
  53.     p->carp.load_multiplier = 1;
  54. return;
  55.     }
  56.     /*
  57.      * sum of carp-load-factor's for all cache_peer's in squid.conf
  58.      * must equal 1.0
  59.      */
  60.     assert(a == 1.0);
  61.     k = 1;
  62.     P_last = 0;
  63.     p = Config.peers;
  64.     p->carp.load_multiplier = pow(K * p->carp.load_factor, 1 / K);
  65.     Xn = p->carp.load_multiplier;
  66.     P_last = p->carp.load_factor;
  67.     X_last = p->carp.load_multiplier;
  68.     if (!p->next)
  69. return;
  70.     for (p = p->next; p; p = p->next) {
  71. p->carp.load_multiplier = ((K - k + 1) * (p->carp.load_factor - P_last)) / Xn;
  72. p->carp.load_multiplier += pow(X_last, K - k + 1);
  73. p->carp.load_multiplier = pow(p->carp.load_multiplier, 1 / (K - k + 1));
  74. Xn *= p->carp.load_multiplier;
  75. X_last = p->carp.load_multiplier;
  76. k++;
  77. P_last = p->carp.load_factor;
  78.     }
  79. }
  80. peer *
  81. carpSelectParent(request_t * request)
  82. {
  83.     const char *c;
  84.     peer *p = NULL;
  85.     peer *tp;
  86.     unsigned long url_hash = 0;
  87.     unsigned long combined_hash;
  88.     unsigned long high_score = 0;
  89.     const char *url = urlCanonical(request);
  90.     /* calculate url hash */
  91.     debug(39, 2) ("carpSelectParent: CARP Calculating hash for %sn", url);
  92.     for (c = url; *c != 0; c++)
  93. url_hash += (url_hash << 19) + *c;
  94.     /* select peer */
  95.     for (tp = Config.peers; tp; tp = tp->next) {
  96. assert(tp->type == PEER_PARENT);
  97. combined_hash = (url_hash ^ tp->carp.hash);
  98. combined_hash += combined_hash * 0x62531965;
  99. combined_hash = combined_hash << 21;
  100. combined_hash = combined_hash * tp->carp.load_multiplier;
  101. debug(39, 3) ("carpSelectParent: %s combined_hash %dn",
  102.     tp->host, combined_hash);
  103. if ((combined_hash > high_score) && neighborUp(tp)) {
  104.     p = tp;
  105.     high_score = combined_hash;
  106. }
  107.     }
  108.     if (p)
  109. debug(39, 3) ("carpSelectParent: selected CARP %sn", p->host);
  110.     return p;
  111. }
  112. #endif