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

代理服务器

开发平台:

Unix_Linux

  1. /*
  2.  * $Id: send-announce.c,v 1.55 1998/12/05 00:54:38 wessels Exp $
  3.  *
  4.  * DEBUG: section 27    Cache Announcer
  5.  * AUTHOR: Duane Wessels
  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. static IPH send_announce;
  36. void
  37. start_announce(void *datanotused)
  38. {
  39.     void *junk;
  40.     if (0 == Config.onoff.announce)
  41. return;
  42.     if (theOutIcpConnection < 0)
  43. return;
  44.     cbdataAdd(junk = xmalloc(1), cbdataXfree, 0);
  45.     ipcache_nbgethostbyname(Config.Announce.host, send_announce, junk);
  46.     eventAdd("send_announce", start_announce, NULL, (double) Config.Announce.period, 1);
  47. }
  48. static void
  49. send_announce(const ipcache_addrs * ia, void *junk)
  50. {
  51.     LOCAL_ARRAY(char, tbuf, 256);
  52.     LOCAL_ARRAY(char, sndbuf, BUFSIZ);
  53.     struct sockaddr_in S;
  54.     char *host = Config.Announce.host;
  55.     char *file = NULL;
  56.     u_short port = Config.Announce.port;
  57.     int l;
  58.     int n;
  59.     int fd;
  60.     int x;
  61.     cbdataFree(junk);
  62.     if (ia == NULL) {
  63. debug(27, 1) ("send_announce: Unknown host '%s'n", host);
  64. return;
  65.     }
  66.     debug(27, 1) ("Sending Announcement to %sn", host);
  67.     sndbuf[0] = '';
  68.     snprintf(tbuf, 256, "cache_version SQUID/%sn", version_string);
  69.     strcat(sndbuf, tbuf);
  70.     assert(Config.Port.http);
  71.     snprintf(tbuf, 256, "Running on %s %d %dn",
  72. getMyHostname(),
  73. (int) Config.Port.http->i,
  74. (int) Config.Port.icp);
  75.     strcat(sndbuf, tbuf);
  76.     if (Config.adminEmail) {
  77. snprintf(tbuf, 256, "cache_admin: %sn", Config.adminEmail);
  78. strcat(sndbuf, tbuf);
  79.     }
  80.     snprintf(tbuf, 256, "generated %d [%s]n",
  81. (int) squid_curtime,
  82. mkhttpdlogtime(&squid_curtime));
  83.     strcat(sndbuf, tbuf);
  84.     l = strlen(sndbuf);
  85.     if ((file = Config.Announce.file) != NULL) {
  86. fd = file_open(file, O_RDONLY, NULL, NULL, NULL);
  87. if (fd > -1 && (n = read(fd, sndbuf + l, BUFSIZ - l - 1)) > 0) {
  88.     fd_bytes(fd, n, FD_READ);
  89.     l += n;
  90.     sndbuf[l] = '';
  91.     file_close(fd);
  92. } else {
  93.     debug(50, 1) ("send_announce: %s: %sn", file, xstrerror());
  94. }
  95.     }
  96.     memset(&S, '', sizeof(S));
  97.     S.sin_family = AF_INET;
  98.     S.sin_port = htons(port);
  99.     S.sin_addr = ia->in_addrs[0];
  100.     assert(theOutIcpConnection > 0);
  101.     x = comm_udp_sendto(theOutIcpConnection,
  102. &S, sizeof(S),
  103. sndbuf, strlen(sndbuf) + 1);
  104.     if (x < 0)
  105. debug(27, 1) ("send_announce: FD %d: %sn", theOutIcpConnection,
  106.     xstrerror());
  107. }