95 lines
3.3 KiB
C
Executable File
95 lines
3.3 KiB
C
Executable File
/*
|
|
** igmpproxy - IGMP proxy based multicast router
|
|
** Copyright (C) 2005 Johnny Egeland <johnny@rlo.org>
|
|
**
|
|
** 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., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
|
|
**
|
|
**----------------------------------------------------------------------------
|
|
**
|
|
** This software is derived work from the following software. The original
|
|
** source code has been modified from it's original state by the author
|
|
** of igmpproxy.
|
|
**
|
|
** smcroute 0.92 - Copyright (C) 2001 Carsten Schill <carsten@cschill.de>
|
|
** - Licensed under the GNU General Public License, version 2
|
|
**
|
|
** mrouted 3.9-beta3 - COPYRIGHT 1989 by The Board of Trustees of
|
|
** Leland Stanford Junior University.
|
|
** - Original license can be found in the "doc/mrouted-LINCESE" file.
|
|
**
|
|
*/
|
|
/**
|
|
* mcgroup contains functions for joining and leaving multicast groups.
|
|
*
|
|
*/
|
|
|
|
#include "defs.h"
|
|
|
|
|
|
/**
|
|
* Common function for joining or leaving a MCast group.
|
|
*/
|
|
static int joinleave( int Cmd, int UdpSock, struct IfDesc *IfDp, uint32 mcastaddr ) {
|
|
struct ip_mreq CtlReq;
|
|
const char *CmdSt = Cmd == 'j' ? "join" : "leave";
|
|
|
|
CtlReq.imr_multiaddr.s_addr = mcastaddr;
|
|
CtlReq.imr_interface.s_addr = IfDp->InAdr.s_addr;
|
|
|
|
{
|
|
char FmtBu[ 32 ];
|
|
log( LOG_NOTICE, 0, "%sMcGroup: %s on %s", CmdSt,
|
|
inetFmt( mcastaddr, s1 ), IfDp ? IfDp->Name : "<any>" );
|
|
}
|
|
#ifdef TCSUPPORT_IGMP_QOS
|
|
if (setsockopt(UdpSock, IPPROTO_IP, IP_SKB_MARK, (void *)&skb_mark, sizeof(skb_mark))) {
|
|
//tcdbg_printf("%s, set IP_SKB_MARK failed.\n", __FUNCTION__);
|
|
;
|
|
}
|
|
|
|
//tcdbg_printf("%s, set IP_SKB_MARK option.skb_mark is %x\n", __FUNCTION__, skb_mark);
|
|
#endif
|
|
|
|
if( setsockopt( UdpSock, IPPROTO_IP,
|
|
Cmd == 'j' ? IP_ADD_MEMBERSHIP : IP_DROP_MEMBERSHIP,
|
|
(void *)&CtlReq, sizeof( CtlReq ) ) )
|
|
{
|
|
log( LOG_WARNING, errno, "MRT_%s_MEMBERSHIP failed", Cmd == 'j' ? "ADD" : "DROP" );
|
|
return 1;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
/**
|
|
* Joins the MC group with the address 'McAdr' on the interface 'IfName'.
|
|
* The join is bound to the UDP socket 'UdpSock', so if this socket is
|
|
* closed the membership is dropped.
|
|
*
|
|
* @return 0 if the function succeeds, 1 if parameters are wrong or the join fails
|
|
*/
|
|
int joinMcGroup( int UdpSock, struct IfDesc *IfDp, uint32 mcastaddr ) {
|
|
return joinleave( 'j', UdpSock, IfDp, mcastaddr );
|
|
}
|
|
|
|
/**
|
|
* Leaves the MC group with the address 'McAdr' on the interface 'IfName'.
|
|
*
|
|
* @return 0 if the function succeeds, 1 if parameters are wrong or the join fails
|
|
*/
|
|
int leaveMcGroup( int UdpSock, struct IfDesc *IfDp, uint32 mcastaddr ) {
|
|
return joinleave( 'l', UdpSock, IfDp, mcastaddr );
|
|
}
|