хБЮМ пНФСЙ НОСАКХЙНБЮК ЯЙПХОР mcastbr2.sh ДКЪ ОПНАПНЯЮ multicast ВЕПЕГ ЬКЧГ
МЮ АЮГЕ FreeBSD ЬРЮРМШЛХ ЯПЕДЯРБЮЛХ netgraph, АЕГ ХЯОНКЭГНБЮМХЪ МЕПЮАНРЮЧЫХУ С
ЛМНЦХУ igmpproxy Х mrouted.

   #!/bin/sh

   # Copyright (c) 2011 Rozhuk Ivan <rozhuk.im@gmail.com>
   # All rights reserved.
   # 
   # Subject to the following obligations and disclaimer of warranty, use and
   # redistribution of this software, in source or object code forms, with or
   # without modifications are expressly permitted by Whistle Communications;
   # provided, however, that:
   # 1. Any and all reproductions of the source or object code must include the
   #    copyright notice above and the following disclaimer of warranties; and
   # 2. No rights are granted, in any manner or form, to use Whistle
   #    Communications, Inc. trademarks, including the mark "WHISTLE
   #    COMMUNICATIONS" on advertising, endorsements, or otherwise except as
   #    such appears in the above copyright notice or in the software.
   # 
   # THIS SOFTWARE IS BEING PROVIDED BY WHISTLE COMMUNICATIONS "AS IS", AND
   # TO THE MAXIMUM EXTENT PERMITTED BY LAW, WHISTLE COMMUNICATIONS MAKES NO
   # REPRESENTATIONS OR WARRANTIES, EXPRESS OR IMPLIED, REGARDING THIS SOFTWARE,
   # INCLUDING WITHOUT LIMITATION, ANY AND ALL IMPLIED WARRANTIES OF
   # MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE, OR NON-INFRINGEMENT.
   # WHISTLE COMMUNICATIONS DOES NOT WARRANT, GUARANTEE, OR MAKE ANY
   # REPRESENTATIONS REGARDING THE USE OF, OR THE RESULTS OF THE USE OF THIS
   # SOFTWARE IN TERMS OF ITS CORRECTNESS, ACCURACY, RELIABILITY OR OTHERWISE.
   # IN NO EVENT SHALL WHISTLE COMMUNICATIONS BE LIABLE FOR ANY DAMAGES
   # RESULTING FROM OR ARISING OUT OF ANY USE OF THIS SOFTWARE, INCLUDING
   # WITHOUT LIMITATION, ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY,
   # PUNITIVE, OR CONSEQUENTIAL DAMAGES, PROCUREMENT OF SUBSTITUTE GOODS OR
   # SERVICES, LOSS OF USE, DATA OR PROFITS, HOWEVER CAUSED AND UNDER ANY
   # THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
   # (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF
   # THIS SOFTWARE, EVEN IF WHISTLE COMMUNICATIONS IS ADVISED OF THE POSSIBILITY
   # OF SUCH DAMAGE.
   #
   # Author: Rozhuk Ivan <rozhuk.im@gmail.com>
   #
   # $FreeBSD: src/sys/netgraph/ng_l2ccp.c,v 1.0.0.1 2010/09/19 08:13:06 kensmith Exp $


   # This script create bridge between two network interfaces
   # downstream - network with clients
   # upstream - network with multicast
   # downstream <-IGMP-> upstream
   # downstream <-UDP<- upstream
   # only packets with multicast dst mac addr forwarded trouth bridge and (!) not pass to network stack



   IF_UPSTREAM="$2"
   IF_DOWNSTREAM="$3"
   BR_NAME="${IF_UPSTREAM}-${IF_DOWNSTREAM}-br"
   PATTERN_MCAST_IGMP="ether[0] & 1 = 1 and (ether[0:4] != 0xffffffff or ether[4:2] != 0xffff) and ip[9] = 2"
   PATTERN_MCAST_IGMP_UDP="ether[0] & 1 = 1 and (ether[0:4] != 0xffffffff or ether[4:2] != 0xffff) and (ip[9] = 17 or ip[9] = 2)"
   # allways NOT MATCH
   BPFPROG_PASSTOUTH="bpf_prog_len=1 bpf_prog=[ { code=6 jt=0 jf=0 k=0 } ]"




   usage_msg()
   {
   echo "usage: start|stop upstreamIF downstreamIF1"
   echo "This create bridge beetwen two IFs for IGMP, and UDP from upstreamIF to downstreamIF1"
   }


   if [ -z "${IF_UPSTREAM}" -o -z "${IF_DOWNSTREAM}" ]; then
   usage_msg
   return 1
   fi
   if ! ifconfig "$IF_UPSTREAM" > /dev/null 2>&1 ; then
   usage_msg
   echo "Invalid upstream interface: ${IF_UPSTREAM}"
   return 1
   fi
   if ! ifconfig "$IF_DOWNSTREAM" > /dev/null 2>&1 ; then
   usage_msg
   echo "Invalid downstream interface: ${IF_DOWNSTREAM}"
   return 1
   fi


   case "$1" in
   start)
   # load modules
   kldload ng_ether > /dev/null 2>&1
   kldload ng_bpf > /dev/null 2>&1

   echo "start bridging beetwen ${IF_UPSTREAM} and ${IF_DOWNSTREAM}"

   BPFPROG_MCAST_IGMP=$( tcpdump -s 65535 -ddd ${PATTERN_MCAST_IGMP} | \
   ( read len ; \
   echo -n "bpf_prog_len=$len " ; \
   echo -n "bpf_prog=[" ; \
   while read code jt jf k ; do \
     echo -n " { code=$code jt=$jt jf=$jf k=$k }" ; \
   done ; \
   echo " ]" ) )

   BPFPROG_MCAST_IGMP_UDP=$( tcpdump -s 65535 -ddd ${PATTERN_MCAST_IGMP_UDP} | \
   ( read len ; \
   echo -n "bpf_prog_len=$len " ; \
   echo -n "bpf_prog=[" ; \
   while read code jt jf k ; do \
     echo -n " { code=$code jt=$jt jf=$jf k=$k }" ; \
   done ; \
   echo " ]" ) )

   # create and connect nodes
   ngctl mkpeer ${IF_UPSTREAM}: bpf lower ${IF_UPSTREAM}-lower
   ngctl name ${IF_UPSTREAM}:lower ${BR_NAME}-bpf
   ngctl connect ${IF_UPSTREAM}: ${BR_NAME}-bpf: upper ${IF_UPSTREAM}-upper
   ngctl connect ${IF_DOWNSTREAM}: ${BR_NAME}-bpf: lower ${IF_DOWNSTREAM}-lower
   ngctl connect ${IF_DOWNSTREAM}: ${BR_NAME}-bpf: upper ${IF_DOWNSTREAM}-upper

   # configure BPF node
   ngctl msg ${BR_NAME}-bpf: setprogram { thisHook=\"${IF_UPSTREAM}-lower\" ifMatch=\"${IF_DOWNSTREAM}-lower\" ifNotMatch=\"${IF_UPSTREAM}-upper\" ${BPFPROG_MCAST_IGMP_UDP} }
   ngctl msg ${BR_NAME}-bpf: setprogram { thisHook=\"${IF_UPSTREAM}-upper\" ifMatch=\"\" ifNotMatch=\"${IF_UPSTREAM}-lower\" ${BPFPROG_PASSTOUTH} }
   ngctl msg ${BR_NAME}-bpf: setprogram { thisHook=\"${IF_DOWNSTREAM}-lower\" ifMatch=\"${IF_UPSTREAM}-lower\" ifNotMatch=\"${IF_DOWNSTREAM}-upper\" ${BPFPROG_MCAST_IGMP} }
   ngctl msg ${BR_NAME}-bpf: setprogram { thisHook=\"${IF_DOWNSTREAM}-upper\" ifMatch=\"\" ifNotMatch=\"${IF_DOWNSTREAM}-lower\" ${BPFPROG_PASSTOUTH} }

   # configure net if
   ngctl msg ${IF_UPSTREAM}: setautosrc 1
   ngctl msg ${IF_UPSTREAM}: setpromisc 1
   #ngctl msg ${IF_DOWNSTREAM}: setautosrc 0
   ngctl msg ${IF_DOWNSTREAM}: setpromisc 1
   ;;
   stop)
   echo "stop"
   # remove hooks and nodes
   ngctl rmhook ${IF_UPSTREAM}: lower
   ngctl rmhook ${IF_UPSTREAM}: upper
   ngctl rmhook ${IF_DOWNSTREAM}: lower
   ngctl rmhook ${IF_DOWNSTREAM}: upper
   ngctl shutdown ${BR_NAME}-bpf:

   # unload modules
   #kldunload ng_ether > /dev/null 2>&1
   #kldunload ng_bpf > /dev/null 2>&1
   ;;
   *)
   usage_msg
   esac


   return 0


яСРЭ ЯЙПХОРЮ: ЛЕФДС ХМРЕПТЕИЯЮЛХ (ng_ether) ЯНГДЮЕРЯЪ ОНДНАХЕ АПХДФЮ Я ng_bpf
ОНЯЕПЕДХМЕ, ЙНРНПШИ ОПНОСЯЙЮЕР ВЕПЕГ ЯЕАЪ РНКЭЙН ЛСКЭРХЙЮЯР. оПХВЕЛ ЩРХ ОЮЙЕРШ
ОПНУНДЪР ОНКМНЯРЭЧ Б НАУНД ЯЕРЕБНЦН ЯРЕЙЮ.


дНОНКМЕМХЕ.

яНГДЮРЭ ЛНЯР ЛЕФДС em0 Х re0, ЦДЕ re0 ОНДЙКЧВ╦М Й ЯЕРХ Я ЛСКЭРХЙЮЯРНЛ:

   mcastbr2.sh start re0 em0

сДЮКХРЭ ЛНЯР:

   mcastbr2.sh stop re0 em0

хЯРНПХЪ

igmpproxy Х mrouted С ЛЕМЪ ПЮАНРЮРЭ НРЙЮГЮКХЯЭ, ОНЯКЕ МЕЯЙНКЭЙХУ ВЮЯНБ ОПНА,
ВРЕМХЪ Х МНБШУ ОПНА Ъ ПЕЬХК МЕ ГЮМХЛЮРЭЯЪ ПЕЛНМРНЛ ЪДПЮ Х ЩРХУ ОПХКНФЕМХИ, Ю
ОПНЯРН БШАНПНВМН ЯАПХДФЕБЮРЭ ДБЮ ЯЕРЕБШУ ХМРЕПТЕИЯЮ:

 - IGMP МЮ multicast ЮДПЕЯЮ ХГ КНЙЮКЙХ Б ЯЕРЭ ОПНБЮИДЕПЮ Х НАПЮРМН;
 - UDP МЮ multicast ЮДПЕЯЮ ХГ ЯЕРХ ОПНБЮИДЕПЮ Б КНЙЮКЙС. аПНЮДЙЮЯР МЕ МСФЕМ, Х МЮОПЮБКЪЕРЯЪ Б ЪДПН ЙЮЙ НАШВМН.

мЕЯЛНРПЪ МЮ ЖХТПС 2, ОН ЯСРХ ЩРЮ РПЕРЭЪ БЕПЯХЪ ЦПЮТЮ, ОНКСВХБЬЮЪ Б ПЕГСКЭРЮРЕ
НОРХЛХГЮЖХХ ОЕПБШУ ДБСУ.

оЕПБЮЪ ЯНДЕПФЮКЮ ng_ether, ng_tee, ng_one2many, ng_bpf.
бРНПЮЪ ЯНДЕПФЮКЮ ng_ether, ng_tee, ng_one2many, ng_bpf.
нЙНМВЮРЕКЭМЮЪ ЯНДЕПФХР: ng_ether, ng_left2right, ng_tee, ng_bpf.

б ОЕПБШУ ДБСУ БЕПЯХЪУ ЯНГДЮБЮКЮЯЭ ЙНОХЪ ОЮЙЕРЮ, Х НДХМ СУНДХК ВЕПЕГ ЛНЯР Б
ДПСЦСЧ ЯЕРЭ КХАН НРАПЮЯШБЮКЯЪ, Ю БРНПНИ ОНОЮДЮК Б ЪДПН. оНЯЙНКЭЙС ЪДПН БЯ╦
ПЮБМН ХУ ДПНОЮКН ЦДЕ РН БМСРПХ Х МЕРЦПЮТ ХУ НВЕМЭ ЛМНЦН НРАПЮЯШБЮК, МХВЕЦН
ОНКЕГМНЦН МЕ ДЕКЮЪ, РН Ъ ПЕЬХК ХУ БННАЫЕ РСДЮ МЕ ОНЯШКЮРЭ Х НПЦЮМХГНБЮРЭ РЮЙ
ВРНАШ МЕ ЯНГДЮБЮРЭ ДСАКХЙЮРНБ Х МЕ СМХВРНФЮРЭ ОЮЙЕРШ.

оПХМЖХО ПЮАНРШ
BPF МЮЯРПНЕМ РЮЙХЛ НАПЮГНЛ ВРНАШ ОПНОСЯЙЮРЭ БЯЕ АЕГ ХЯЙКЧВЕМХЪ ОЮЙЕРШ Я upper
УСЙНБ ng_ether МНД МЮ lower УСЙХ (ОЮЙЕРШ НР ЯХЯРЕЛШ Б ЯЕРЭ). оПХУНДЪЫХЕ ХГ ЯЕРХ
ОЮЙЕРШ Я lower УСЙНБ МНД ОПНБЕПЪЧРЯЪ Б BPF, Х

 - ЕЯКХ ЩРН ЛСКЭРХЙЮЯР;
 - Х МЕ АПНЮДЙЮЯР;
 - Х IGMP [ХКХ UDP Б ЯКСВЮЕ ЕЯКХ ОЮЙЕР НР ЮДЮОРЕПЮ ОНДЙКЧВ╦ММНЦН Й ОПНБЮИДЕПС]

РН РЮЙНИ ОЮЙЕР ЖЕКХЙНЛ ОЕПЕЯШКЮЕРЯЪ МЮ lower УСЙ ДПСЦНЦН ЮДЮОРЕПЮ, ЛХМСЪ
ЯЕРЕБНИ ЯР╦Й НОЕПЮЖХНММНИ ЯХЯРЕЛШ.


рНМЙНЯРХ

1. оПХЬКНЯЭ БЙКЧВХРЭ promisc ПЕФХЛ МЮ НАНХУ ХМРЕПТЕИЯЮУ, ХМЮВЕ ЛСКЭРХЙЮЯР
ДПНОЮЕРЯЪ ЯЮЛХЛ ЯЕРЕБШЛ ЮДЮОРЕПНЛ, ЩРН МНПЛЮКЭМНЕ ОНБЕДЕМХЕ.

2. оПХЬКНЯЭ БЙКЧВХРЭ autosrc МЮ ХМРЕПТЕИЯЕ Б ЯЕРХ ОПНБЮИДЕПЮ, РЮЙ ЙЮЙ С
ОПНБЮИДЕПЮ МЮ ЙНЛЛСРЮРНПЕ МЮЯРПНЕМ Port Security МЮ ОПНОСЯЙЮМХЕ РНКЭЙН НДМНЦН
MAC ЮДПЕЯЮ - ОЕПБНЦН ХГСВЕММНЦН МЮ ОНПРС ОНЯКЕ ОНДМЪРХЪ КХМЙЮ.

3. лНЕЛС ОПНБЮИДЕПС МЕР ДЕКЮ ДН РНЦН ЙЮЙНИ src-ip Б IP ОПХУНДХР НР ЛЕМЪ, ЕЯКХ
АШ АШКН, РН Ъ АШ ОНОПНАНБЮК ЦМЮРЭ РПЮТХЙ Б ЯРНПНМС ОПНБЮИДЕПЮ ВЕПЕГ ng_patch
МНДС, ЙНРНПЮЪ АШ ГЮЛЕМЪКЮ src-ip МЮ МСФМШ, Х БШЯРЮБКЪКЮ CSUM_IP Х CSUM_UDP Б
ГЮЦНКНБЙЕ ОЮЙЕРЮ - ЕЯРЭ ЬЮМЯ ВРН ДПЮИБЕП ЯЕРЕБНЦН ЮДЮОРЕПЮ ЯЮЛ ПЮЯЯВХРЮЕР ЩРХ
ЯСЛЛШ КХАН ВРН НАНПСДНБЮМХЕ ОПНБЮИДЕПЮ ОПНХЦМНПХПСЕР МЕБЕПМСЧ ЙНМРПНКЭМСЧ ЯСЛЛС
Б IGMP ОЮЙЕРЮУ НР ЛЕМЪ. мНДЮ РЮЙФЕ ОНДЙКЧВЮЕРЯЪ НАНХЛХ УСЙЮЛХ Й BPF, БШУНД
МЮЯРПЮХБЮЕРЯЪ МЮ passtrouth (ОЕПЕЯШКЙС БЯЕУ ОЮЙЕРНБ) МЮ lower УСЙ ng_ether МЮ
ЮДЮОРЕПЕ Б ЯЕРХ ОПНБЮИДЕПЮ, Ю БУНД ng_patch ДНКФЕМ АШРЭ match БШУНДНЛ НР lower
МЮ ЮДЮОРЕПЕ Б КНЙЮКЭМНИ ЯЕРХ. рЕ ЯНБЯЕЛ МЕ АНКЭЬЮЪ ЛНДХТХЙЮЖХЪ ЦПЮТЮ.

4. пЮАНРЮЕР МЮ vlan ХМРЕПТЕИЯЮУ.


дКЪ ЯНГДЮМХЪ ЮМЮКНЦХВМНЦН ОН ТСМЙЖХНМЮКС ЛНЯРЮ, Б ЙНРНПНЛ АСДЕР МЕЯЙНКЭЙН
ЯЕРЕБШУ ХМРЕПТЕИЯНБ Б ПЮГМШУ ЯЕРЪУ Я ЛСКЭРХЙЮЯРНЛ Х МЕЯЙНКЭЙН ЯЕРЕБШУ ЮДЮОРЕПНБ
Б ЯЕРЪУ ЙСДЮ ЕЦН МСФМН ОЕПЕОПЮБХРЭ ОНРПЕАСЕРЯЪ МЮ ЙЮФДШИ ЯЕРЕБНИ ЮДЮОРЕП БЕЬЮРЭ
ОН ng_split + ng_one2many Х ОН НДМНИ ng_one2many Я ЙЮФДНИ ЯРНПНМШ ЛНЯРЮ ДКЪ
ПЮЯЯШКЙХ ЙНОХИ ЛСКЭРХЙЮЯРЮ МЮ БЯЕ ХМРЕПТЕИЯШ. upper УСЙХ ng_ether МНД ОН
ОПЕФМЕЛС АСДСР МЮОПЪЛСЧ ОНДЙКЧВЮРЯЪ Й BPF. б ЯКСВЮЕ МЕЯЙНКЭЙХУ ЯЕРЕИ -
ХЯРНВМХЙНБ ЛСКЭРХЙЮЯРЮ АСДЕР ЕЫ╦ ОПНАКЕЛЮ Я БНГЛНФМШЛ ОЕПЕЙПШРХЕЛ ЮДПЕЯМШУ
ОПНЯРПЮМЯРБ, ЙНРНПСЧ ЛНФМН ВЮЯРХВМН ПЮГПЕЬХРЭ МЮЯРПНХБ Б BPF ТХКЭРПЮЖХЧ ОН ЮДПЕЯЮЛ.