Annotation of embedaddon/igmpproxy/src/mroute-api.c, revision 1.1
1.1 ! misho 1: /*
! 2: ** igmpproxy - IGMP proxy based multicast router
! 3: ** Copyright (C) 2005 Johnny Egeland <johnny@rlo.org>
! 4: **
! 5: ** This program is free software; you can redistribute it and/or modify
! 6: ** it under the terms of the GNU General Public License as published by
! 7: ** the Free Software Foundation; either version 2 of the License, or
! 8: ** (at your option) any later version.
! 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
! 16: ** along with this program; if not, write to the Free Software
! 17: ** Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
! 18: **
! 19: **----------------------------------------------------------------------------
! 20: **
! 21: ** This software is derived work from the following software. The original
! 22: ** source code has been modified from it's original state by the author
! 23: ** of igmpproxy.
! 24: **
! 25: ** smcroute 0.92 - Copyright (C) 2001 Carsten Schill <carsten@cschill.de>
! 26: ** - Licensed under the GNU General Public License, version 2
! 27: **
! 28: ** mrouted 3.9-beta3 - COPYRIGHT 1989 by The Board of Trustees of
! 29: ** Leland Stanford Junior University.
! 30: ** - Original license can be found in the Stanford.txt file.
! 31: **
! 32: */
! 33: /**
! 34: * mroute-api.c
! 35: *
! 36: * This module contains the interface routines to the Linux mrouted API
! 37: */
! 38:
! 39:
! 40: #include "igmpproxy.h"
! 41:
! 42: // MAX_MC_VIFS from mclab.h must have same value as MAXVIFS from mroute.h
! 43: #if MAX_MC_VIFS != MAXVIFS
! 44: # error "constants don't match, correct mclab.h"
! 45: #endif
! 46:
! 47: // need an IGMP socket as interface for the mrouted API
! 48: // - receives the IGMP messages
! 49: int MRouterFD; /* socket for all network I/O */
! 50: char *recv_buf; /* input packet buffer */
! 51: char *send_buf; /* output packet buffer */
! 52:
! 53:
! 54: // my internal virtual interfaces descriptor vector
! 55: static struct VifDesc {
! 56: struct IfDesc *IfDp;
! 57: } VifDescVc[ MAXVIFS ];
! 58:
! 59:
! 60:
! 61: /*
! 62: ** Initialises the mrouted API and locks it by this exclusively.
! 63: **
! 64: ** returns: - 0 if the functions succeeds
! 65: ** - the errno value for non-fatal failure condition
! 66: */
! 67: int enableMRouter()
! 68: {
! 69: int Va = 1;
! 70:
! 71: if ( (MRouterFD = socket(AF_INET, SOCK_RAW, IPPROTO_IGMP)) < 0 )
! 72: my_log( LOG_ERR, errno, "IGMP socket open" );
! 73:
! 74: if ( setsockopt( MRouterFD, IPPROTO_IP, MRT_INIT,
! 75: (void *)&Va, sizeof( Va ) ) )
! 76: return errno;
! 77:
! 78: return 0;
! 79: }
! 80:
! 81: /*
! 82: ** Diables the mrouted API and relases by this the lock.
! 83: **
! 84: */
! 85: void disableMRouter()
! 86: {
! 87: if ( setsockopt( MRouterFD, IPPROTO_IP, MRT_DONE, NULL, 0 )
! 88: || close( MRouterFD )
! 89: ) {
! 90: MRouterFD = 0;
! 91: my_log( LOG_ERR, errno, "MRT_DONE/close" );
! 92: }
! 93:
! 94: MRouterFD = 0;
! 95: }
! 96:
! 97: /*
! 98: ** Adds the interface '*IfDp' as virtual interface to the mrouted API
! 99: **
! 100: */
! 101: void addVIF( struct IfDesc *IfDp )
! 102: {
! 103: struct vifctl VifCtl;
! 104: struct VifDesc *VifDp;
! 105:
! 106: /* search free VifDesc
! 107: */
! 108: for ( VifDp = VifDescVc; VifDp < VCEP( VifDescVc ); VifDp++ ) {
! 109: if ( ! VifDp->IfDp )
! 110: break;
! 111: }
! 112:
! 113: /* no more space
! 114: */
! 115: if ( VifDp >= VCEP( VifDescVc ) )
! 116: my_log( LOG_ERR, ENOMEM, "addVIF, out of VIF space" );
! 117:
! 118: VifDp->IfDp = IfDp;
! 119:
! 120: VifCtl.vifc_vifi = VifDp - VifDescVc;
! 121: VifCtl.vifc_flags = 0; /* no tunnel, no source routing, register ? */
! 122: VifCtl.vifc_threshold = VifDp->IfDp->threshold; // Packet TTL must be at least 1 to pass them
! 123: VifCtl.vifc_rate_limit = VifDp->IfDp->ratelimit; // Ratelimit
! 124:
! 125: VifCtl.vifc_lcl_addr.s_addr = VifDp->IfDp->InAdr.s_addr;
! 126: VifCtl.vifc_rmt_addr.s_addr = INADDR_ANY;
! 127:
! 128: // Set the index...
! 129: VifDp->IfDp->index = VifCtl.vifc_vifi;
! 130:
! 131: my_log( LOG_NOTICE, 0, "adding VIF, Ix %d Fl 0x%x IP 0x%08x %s, Threshold: %d, Ratelimit: %d",
! 132: VifCtl.vifc_vifi, VifCtl.vifc_flags, VifCtl.vifc_lcl_addr.s_addr, VifDp->IfDp->Name,
! 133: VifCtl.vifc_threshold, VifCtl.vifc_rate_limit);
! 134:
! 135: struct SubnetList *currSubnet;
! 136: for(currSubnet = IfDp->allowednets; currSubnet; currSubnet = currSubnet->next) {
! 137: my_log(LOG_DEBUG, 0, " Network for [%s] : %s",
! 138: IfDp->Name,
! 139: inetFmts(currSubnet->subnet_addr, currSubnet->subnet_mask, s1));
! 140: }
! 141:
! 142: if ( setsockopt( MRouterFD, IPPROTO_IP, MRT_ADD_VIF,
! 143: (char *)&VifCtl, sizeof( VifCtl ) ) )
! 144: my_log( LOG_ERR, errno, "MRT_ADD_VIF" );
! 145:
! 146: }
! 147:
! 148: /*
! 149: ** Adds the multicast routed '*Dp' to the kernel routes
! 150: **
! 151: ** returns: - 0 if the function succeeds
! 152: ** - the errno value for non-fatal failure condition
! 153: */
! 154: int addMRoute( struct MRouteDesc *Dp )
! 155: {
! 156: struct mfcctl CtlReq;
! 157: int rc;
! 158:
! 159: CtlReq.mfcc_origin = Dp->OriginAdr;
! 160: CtlReq.mfcc_mcastgrp = Dp->McAdr;
! 161: CtlReq.mfcc_parent = Dp->InVif;
! 162:
! 163: /* copy the TTL vector
! 164: */
! 165:
! 166: memcpy( CtlReq.mfcc_ttls, Dp->TtlVc, sizeof( CtlReq.mfcc_ttls ) );
! 167:
! 168: {
! 169: char FmtBuO[ 32 ], FmtBuM[ 32 ];
! 170:
! 171: my_log( LOG_NOTICE, 0, "Adding MFC: %s -> %s, InpVIf: %d",
! 172: fmtInAdr( FmtBuO, CtlReq.mfcc_origin ),
! 173: fmtInAdr( FmtBuM, CtlReq.mfcc_mcastgrp ),
! 174: (int)CtlReq.mfcc_parent
! 175: );
! 176: }
! 177:
! 178: rc = setsockopt( MRouterFD, IPPROTO_IP, MRT_ADD_MFC,
! 179: (void *)&CtlReq, sizeof( CtlReq ) );
! 180: if (rc)
! 181: my_log( LOG_WARNING, errno, "MRT_ADD_MFC" );
! 182:
! 183: return rc;
! 184: }
! 185:
! 186: /*
! 187: ** Removes the multicast routed '*Dp' from the kernel routes
! 188: **
! 189: ** returns: - 0 if the function succeeds
! 190: ** - the errno value for non-fatal failure condition
! 191: */
! 192: int delMRoute( struct MRouteDesc *Dp )
! 193: {
! 194: struct mfcctl CtlReq;
! 195: int rc;
! 196:
! 197: CtlReq.mfcc_origin = Dp->OriginAdr;
! 198: CtlReq.mfcc_mcastgrp = Dp->McAdr;
! 199: CtlReq.mfcc_parent = Dp->InVif;
! 200:
! 201: /* clear the TTL vector
! 202: */
! 203: memset( CtlReq.mfcc_ttls, 0, sizeof( CtlReq.mfcc_ttls ) );
! 204:
! 205: {
! 206: char FmtBuO[ 32 ], FmtBuM[ 32 ];
! 207:
! 208: my_log( LOG_NOTICE, 0, "Removing MFC: %s -> %s, InpVIf: %d",
! 209: fmtInAdr( FmtBuO, CtlReq.mfcc_origin ),
! 210: fmtInAdr( FmtBuM, CtlReq.mfcc_mcastgrp ),
! 211: (int)CtlReq.mfcc_parent
! 212: );
! 213: }
! 214:
! 215: rc = setsockopt( MRouterFD, IPPROTO_IP, MRT_DEL_MFC,
! 216: (void *)&CtlReq, sizeof( CtlReq ) );
! 217: if (rc)
! 218: my_log( LOG_WARNING, errno, "MRT_DEL_MFC" );
! 219:
! 220: return rc;
! 221: }
! 222:
! 223: /*
! 224: ** Returns for the virtual interface index for '*IfDp'
! 225: **
! 226: ** returns: - the vitrual interface index if the interface is registered
! 227: ** - -1 if no virtual interface exists for the interface
! 228: **
! 229: */
! 230: int getVifIx( struct IfDesc *IfDp )
! 231: {
! 232: struct VifDesc *Dp;
! 233:
! 234: for ( Dp = VifDescVc; Dp < VCEP( VifDescVc ); Dp++ )
! 235: if ( Dp->IfDp == IfDp )
! 236: return Dp - VifDescVc;
! 237:
! 238: return -1;
! 239: }
! 240:
! 241:
! 242:
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to mroute-api.c CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / igmpproxy / src