From 42cc2e53cab204ffb440a2686404ca99c8d8f443 Mon Sep 17 00:00:00 2001
From: wessels <>
Date: Tue, 17 Jun 1997 04:02:04 +0000
Subject: [PATCH] adding

---
 src/multicast.cc | 111 +++++++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 111 insertions(+)
 create mode 100644 src/multicast.cc

diff --git a/src/multicast.cc b/src/multicast.cc
new file mode 100644
index 0000000000..a3d8438a91
--- /dev/null
+++ b/src/multicast.cc
@@ -0,0 +1,111 @@
+
+/*
+ * $Id: multicast.cc,v 1.1 1997/06/16 22:02:04 wessels Exp $
+ *
+ * DEBUG: section 5     Socket Functions
+ * AUTHOR: Martin Hamilton
+ *
+ * SQUID Internet Object Cache  http://squid.nlanr.net/Squid/
+ * --------------------------------------------------------
+ *
+ *  Squid is the result of efforts by numerous individuals from the
+ *  Internet community.  Development is led by Duane Wessels of the
+ *  National Laboratory for Applied Network Research and funded by
+ *  the National Science Foundation.
+ *
+ *  This program is free software; you can redistribute it and/or modify
+ *  it under the terms of the GNU General Public License as published by
+ *  the Free Software Foundation; either version 2 of the License, or
+ *  (at your option) any later version.
+ *  
+ *  This program is distributed in the hope that it will be useful,
+ *  but WITHOUT ANY WARRANTY; without even the implied warranty of
+ *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ *  GNU General Public License for more details.
+ *  
+ *  You should have received a copy of the GNU General Public License
+ *  along with this program; if not, write to the Free Software
+ *  Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
+ *  
+ */
+
+#include "squid.h"
+
+int
+mcastSetTtl(int fd, int mcast_ttl)
+{
+#ifdef IP_MULTICAST_TTL
+    char ttl = (char) mcast_ttl;
+    if (setsockopt(fd, IPPROTO_IP, IP_MULTICAST_TTL, &ttl, 1) < 0)
+	debug(50, 1) ("comm_set_mcast_ttl: FD %d, TTL: %d: %s\n",
+	    fd, mcast_ttl, xstrerror());
+#endif
+    return 0;
+}
+
+void
+mcastJoinGroups(const ipcache_addrs * ia, void *data)
+{
+#ifdef IP_MULTICAST_TTL
+    int fd = theInIcpConnection;
+    struct ip_mreq mr;
+    int i;
+    int x;
+    char c = 0;
+    if (ia == NULL) {
+	debug(5, 0) ("comm_join_mcast_groups: Unknown host\n");
+	return;
+    }
+    for (i = 0; i < (int) ia->count; i++) {
+	debug(5, 10) ("Listening for ICP requests on %s\n",
+	    inet_ntoa(*(ia->in_addrs + i)));
+	mr.imr_multiaddr.s_addr = (ia->in_addrs + i)->s_addr;
+	mr.imr_interface.s_addr = INADDR_ANY;
+	x = setsockopt(fd, IPPROTO_IP, IP_ADD_MEMBERSHIP,
+	    (char *) &mr, sizeof(struct ip_mreq));
+	if (x < 0)
+	    debug(5, 1) ("comm_join_mcast_groups: FD %d, [%s]\n",
+		fd, inet_ntoa(*(ia->in_addrs + i)));
+	x = setsockopt(fd, IPPROTO_IP, IP_MULTICAST_LOOP, &c, 1);
+	if (x < 0)
+	    debug(5, 1) ("Can't disable multicast loopback: %s\n", xstrerror());
+    }
+#endif
+}
+
+void
+mcastJoinVizSock(void)
+{
+#if defined(IP_ADD_MEMBERSHIP) && defined(IP_MULTICAST_TTL)
+    int x;
+    if (Config.vizHack.addr.s_addr > inet_addr("224.0.0.0")) {
+	struct ip_mreq mr;
+	char ttl = (char) Config.vizHack.mcast_ttl;
+	memset(&mr, '\0', sizeof(struct ip_mreq));
+	mr.imr_multiaddr.s_addr = Config.vizHack.addr.s_addr;
+	mr.imr_interface.s_addr = INADDR_ANY;
+	x = setsockopt(vizSock,
+	    IPPROTO_IP,
+	    IP_ADD_MEMBERSHIP,
+	    (char *) &mr,
+	    sizeof(struct ip_mreq));
+	if (x < 0)
+	    debug(50, 1) ("IP_ADD_MEMBERSHIP: FD %d, addr %s: %s\n",
+		vizSock, inet_ntoa(Config.vizHack.addr), xstrerror());
+	x = setsockopt(vizSock,
+	    IPPROTO_IP,
+	    IP_MULTICAST_TTL,
+	    &ttl,
+	    sizeof(char));
+	if (x < 0)
+	    debug(50, 1) ("IP_MULTICAST_TTL: FD %d, TTL %d: %s\n",
+		vizSock, Config.vizHack.mcast_ttl, xstrerror());
+	ttl = 0;
+	x = sizeof(char);
+	getsockopt(vizSock, IPPROTO_IP, IP_MULTICAST_TTL, &ttl, &x);
+	debug(1, 0) ("vizSock on FD %d, ttl=%d\n", vizSock, (int) ttl);
+    }
+#else
+        debug(1, 0) ("vizSock: Could not join multicast group\n");
+#endif
+}
-- 
2.47.2