12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751175217531754175517561757175817591760176117621763176417651766176717681769177017711772177317741775177617771778177917801781178217831784178517861787178817891790179117921793179417951796179717981799180018011802180318041805180618071808180918101811181218131814181518161817181818191820182118221823182418251826182718281829183018311832183318341835183618371838183918401841184218431844184518461847184818491850185118521853185418551856185718581859186018611862186318641865186618671868186918701871187218731874187518761877187818791880188118821883188418851886188718881889189018911892189318941895189618971898189919001901190219031904190519061907190819091910191119121913191419151916191719181919192019211922192319241925192619271928192919301931193219331934193519361937193819391940194119421943194419451946194719481949195019511952195319541955195619571958195919601961196219631964196519661967196819691970197119721973197419751976197719781979198019811982198319841985198619871988198919901991199219931994199519961997199819992000200120022003200420052006200720082009201020112012201320142015201620172018201920202021202220232024202520262027202820292030203120322033203420352036203720382039204020412042204320442045204620472048204920502051205220532054205520562057205820592060206120622063206420652066206720682069207020712072207320742075207620772078207920802081208220832084208520862087208820892090209120922093209420952096209720982099210021012102210321042105210621072108210921102111211221132114211521162117211821192120212121222123212421252126212721282129213021312132213321342135213621372138213921402141214221432144214521462147214821492150215121522153215421552156215721582159216021612162216321642165216621672168216921702171217221732174217521762177217821792180218121822183218421852186218721882189219021912192219321942195219621972198219922002201220222032204220522062207220822092210221122122213221422152216221722182219222022212222222322242225222622272228222922302231223222332234223522362237223822392240224122422243224422452246224722482249225022512252225322542255225622572258225922602261226222632264226522662267226822692270227122722273227422752276227722782279228022812282228322842285228622872288228922902291229222932294229522962297229822992300230123022303230423052306230723082309231023112312231323142315231623172318231923202321232223232324232523262327232823292330233123322333233423352336233723382339234023412342234323442345234623472348234923502351235223532354235523562357235823592360236123622363236423652366236723682369237023712372237323742375237623772378237923802381238223832384238523862387238823892390239123922393239423952396239723982399240024012402240324042405240624072408240924102411241224132414241524162417241824192420242124222423242424252426242724282429243024312432243324342435243624372438243924402441244224432444244524462447244824492450245124522453245424552456245724582459246024612462246324642465246624672468246924702471247224732474247524762477247824792480248124822483248424852486248724882489249024912492249324942495249624972498249925002501250225032504250525062507250825092510251125122513251425152516251725182519252025212522252325242525252625272528252925302531253225332534253525362537253825392540254125422543254425452546254725482549255025512552255325542555255625572558255925602561256225632564256525662567256825692570257125722573257425752576257725782579258025812582258325842585258625872588258925902591259225932594259525962597259825992600260126022603260426052606260726082609261026112612261326142615261626172618261926202621262226232624262526262627262826292630263126322633263426352636263726382639264026412642264326442645264626472648264926502651265226532654265526562657265826592660266126622663266426652666266726682669267026712672267326742675267626772678267926802681268226832684268526862687268826892690269126922693269426952696269726982699270027012702270327042705270627072708270927102711271227132714271527162717271827192720272127222723272427252726272727282729273027312732273327342735273627372738273927402741274227432744274527462747274827492750275127522753275427552756275727582759276027612762276327642765276627672768276927702771277227732774277527762777277827792780278127822783278427852786278727882789279027912792279327942795279627972798279928002801280228032804280528062807280828092810281128122813281428152816281728182819282028212822282328242825282628272828282928302831283228332834283528362837283828392840284128422843284428452846284728482849285028512852285328542855285628572858285928602861286228632864286528662867286828692870287128722873287428752876287728782879288028812882288328842885288628872888288928902891289228932894289528962897289828992900290129022903290429052906290729082909291029112912291329142915291629172918291929202921292229232924292529262927292829292930293129322933293429352936293729382939294029412942294329442945294629472948294929502951295229532954295529562957295829592960296129622963296429652966296729682969297029712972297329742975297629772978297929802981298229832984298529862987298829892990299129922993299429952996299729982999300030013002300330043005300630073008300930103011301230133014301530163017301830193020302130223023302430253026302730283029303030313032303330343035303630373038303930403041304230433044304530463047304830493050305130523053305430553056305730583059306030613062306330643065306630673068306930703071307230733074307530763077307830793080308130823083308430853086308730883089309030913092309330943095309630973098309931003101310231033104310531063107310831093110311131123113311431153116311731183119312031213122312331243125312631273128312931303131313231333134313531363137313831393140314131423143314431453146314731483149315031513152315331543155315631573158315931603161316231633164316531663167316831693170317131723173317431753176317731783179318031813182318331843185318631873188318931903191319231933194319531963197319831993200320132023203320432053206320732083209321032113212321332143215321632173218321932203221322232233224322532263227322832293230323132323233323432353236323732383239324032413242324332443245324632473248324932503251325232533254325532563257325832593260326132623263326432653266326732683269327032713272327332743275327632773278327932803281328232833284328532863287328832893290329132923293329432953296329732983299330033013302330333043305330633073308330933103311331233133314331533163317331833193320332133223323332433253326332733283329333033313332333333343335333633373338333933403341334233433344334533463347334833493350335133523353335433553356335733583359336033613362336333643365336633673368336933703371337233733374337533763377337833793380338133823383338433853386338733883389339033913392339333943395339633973398339934003401340234033404340534063407340834093410341134123413341434153416341734183419342034213422342334243425342634273428342934303431343234333434343534363437343834393440344134423443344434453446344734483449345034513452345334543455345634573458345934603461346234633464346534663467346834693470347134723473347434753476347734783479348034813482348334843485348634873488348934903491349234933494349534963497349834993500350135023503350435053506350735083509351035113512351335143515351635173518351935203521352235233524352535263527352835293530353135323533353435353536353735383539354035413542354335443545354635473548354935503551355235533554355535563557355835593560356135623563356435653566356735683569357035713572357335743575357635773578357935803581358235833584358535863587358835893590359135923593359435953596359735983599360036013602360336043605360636073608360936103611361236133614361536163617361836193620362136223623362436253626362736283629363036313632363336343635363636373638363936403641364236433644364536463647364836493650365136523653365436553656365736583659366036613662366336643665366636673668366936703671367236733674367536763677367836793680368136823683368436853686368736883689369036913692369336943695369636973698369937003701370237033704370537063707370837093710371137123713371437153716371737183719372037213722372337243725372637273728372937303731373237333734373537363737373837393740374137423743374437453746374737483749375037513752375337543755375637573758375937603761376237633764376537663767376837693770377137723773377437753776377737783779378037813782378337843785378637873788378937903791379237933794379537963797379837993800380138023803380438053806380738083809381038113812381338143815381638173818381938203821382238233824382538263827382838293830383138323833383438353836383738383839384038413842384338443845384638473848384938503851385238533854385538563857385838593860386138623863386438653866386738683869387038713872387338743875387638773878387938803881388238833884388538863887388838893890389138923893389438953896389738983899390039013902390339043905390639073908390939103911391239133914391539163917391839193920392139223923392439253926392739283929393039313932393339343935393639373938393939403941394239433944394539463947394839493950395139523953395439553956395739583959396039613962396339643965396639673968396939703971397239733974397539763977397839793980398139823983398439853986398739883989399039913992399339943995399639973998399940004001400240034004400540064007400840094010401140124013401440154016401740184019402040214022402340244025402640274028402940304031403240334034403540364037403840394040404140424043404440454046404740484049405040514052405340544055405640574058405940604061406240634064406540664067406840694070407140724073407440754076407740784079408040814082408340844085408640874088408940904091409240934094409540964097409840994100410141024103410441054106410741084109411041114112411341144115411641174118411941204121412241234124412541264127412841294130413141324133413441354136413741384139414041414142414341444145414641474148414941504151415241534154415541564157415841594160416141624163416441654166416741684169417041714172417341744175417641774178417941804181418241834184418541864187418841894190419141924193419441954196419741984199420042014202420342044205420642074208420942104211421242134214421542164217421842194220422142224223422442254226422742284229423042314232423342344235423642374238423942404241424242434244424542464247424842494250425142524253425442554256425742584259426042614262426342644265426642674268426942704271427242734274427542764277427842794280428142824283428442854286428742884289429042914292429342944295429642974298429943004301430243034304430543064307430843094310431143124313431443154316431743184319432043214322432343244325432643274328432943304331433243334334433543364337433843394340434143424343434443454346434743484349435043514352435343544355435643574358435943604361436243634364436543664367436843694370437143724373437443754376437743784379438043814382438343844385438643874388438943904391439243934394439543964397439843994400440144024403440444054406440744084409441044114412441344144415441644174418441944204421442244234424442544264427442844294430443144324433443444354436443744384439444044414442444344444445444644474448444944504451445244534454445544564457445844594460446144624463446444654466446744684469447044714472447344744475447644774478447944804481448244834484448544864487448844894490449144924493449444954496449744984499450045014502450345044505450645074508450945104511451245134514451545164517451845194520452145224523452445254526452745284529453045314532453345344535453645374538453945404541454245434544454545464547454845494550455145524553455445554556455745584559456045614562456345644565456645674568456945704571457245734574457545764577457845794580458145824583458445854586458745884589459045914592459345944595459645974598459946004601460246034604460546064607460846094610461146124613461446154616461746184619462046214622462346244625462646274628462946304631463246334634463546364637463846394640464146424643464446454646464746484649465046514652465346544655465646574658465946604661466246634664466546664667466846694670467146724673467446754676467746784679468046814682468346844685468646874688468946904691469246934694469546964697469846994700470147024703470447054706470747084709471047114712471347144715471647174718471947204721472247234724472547264727472847294730473147324733473447354736473747384739474047414742474347444745474647474748474947504751475247534754475547564757475847594760476147624763476447654766476747684769477047714772477347744775477647774778477947804781478247834784478547864787478847894790479147924793479447954796479747984799480048014802480348044805480648074808480948104811481248134814481548164817481848194820482148224823482448254826482748284829483048314832483348344835483648374838483948404841484248434844484548464847484848494850485148524853485448554856485748584859486048614862486348644865486648674868486948704871487248734874487548764877487848794880488148824883488448854886488748884889489048914892489348944895489648974898489949004901490249034904490549064907490849094910491149124913491449154916491749184919492049214922492349244925492649274928492949304931493249334934493549364937493849394940494149424943494449454946 |
- // SPDX-License-Identifier: GPL-2.0-or-later
- /*
- * Bridge multicast support.
- *
- * Copyright (c) 2010 Herbert Xu <[email protected]>
- */
- #include <linux/err.h>
- #include <linux/export.h>
- #include <linux/if_ether.h>
- #include <linux/igmp.h>
- #include <linux/in.h>
- #include <linux/jhash.h>
- #include <linux/kernel.h>
- #include <linux/log2.h>
- #include <linux/netdevice.h>
- #include <linux/netfilter_bridge.h>
- #include <linux/random.h>
- #include <linux/rculist.h>
- #include <linux/skbuff.h>
- #include <linux/slab.h>
- #include <linux/timer.h>
- #include <linux/inetdevice.h>
- #include <linux/mroute.h>
- #include <net/ip.h>
- #include <net/switchdev.h>
- #if IS_ENABLED(CONFIG_IPV6)
- #include <linux/icmpv6.h>
- #include <net/ipv6.h>
- #include <net/mld.h>
- #include <net/ip6_checksum.h>
- #include <net/addrconf.h>
- #endif
- #include "br_private.h"
- #include "br_private_mcast_eht.h"
- static const struct rhashtable_params br_mdb_rht_params = {
- .head_offset = offsetof(struct net_bridge_mdb_entry, rhnode),
- .key_offset = offsetof(struct net_bridge_mdb_entry, addr),
- .key_len = sizeof(struct br_ip),
- .automatic_shrinking = true,
- };
- static const struct rhashtable_params br_sg_port_rht_params = {
- .head_offset = offsetof(struct net_bridge_port_group, rhnode),
- .key_offset = offsetof(struct net_bridge_port_group, key),
- .key_len = sizeof(struct net_bridge_port_group_sg_key),
- .automatic_shrinking = true,
- };
- static void br_multicast_start_querier(struct net_bridge_mcast *brmctx,
- struct bridge_mcast_own_query *query);
- static void br_ip4_multicast_add_router(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx);
- static void br_ip4_multicast_leave_group(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- __be32 group,
- __u16 vid,
- const unsigned char *src);
- static void br_multicast_port_group_rexmit(struct timer_list *t);
- static void
- br_multicast_rport_del_notify(struct net_bridge_mcast_port *pmctx, bool deleted);
- static void br_ip6_multicast_add_router(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx);
- #if IS_ENABLED(CONFIG_IPV6)
- static void br_ip6_multicast_leave_group(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- const struct in6_addr *group,
- __u16 vid, const unsigned char *src);
- #endif
- static struct net_bridge_port_group *
- __br_multicast_add_group(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct br_ip *group,
- const unsigned char *src,
- u8 filter_mode,
- bool igmpv2_mldv1,
- bool blocked);
- static void br_multicast_find_del_pg(struct net_bridge *br,
- struct net_bridge_port_group *pg);
- static void __br_multicast_stop(struct net_bridge_mcast *brmctx);
- static int br_mc_disabled_update(struct net_device *dev, bool value,
- struct netlink_ext_ack *extack);
- static struct net_bridge_port_group *
- br_sg_port_find(struct net_bridge *br,
- struct net_bridge_port_group_sg_key *sg_p)
- {
- lockdep_assert_held_once(&br->multicast_lock);
- return rhashtable_lookup_fast(&br->sg_port_tbl, sg_p,
- br_sg_port_rht_params);
- }
- static struct net_bridge_mdb_entry *br_mdb_ip_get_rcu(struct net_bridge *br,
- struct br_ip *dst)
- {
- return rhashtable_lookup(&br->mdb_hash_tbl, dst, br_mdb_rht_params);
- }
- struct net_bridge_mdb_entry *br_mdb_ip_get(struct net_bridge *br,
- struct br_ip *dst)
- {
- struct net_bridge_mdb_entry *ent;
- lockdep_assert_held_once(&br->multicast_lock);
- rcu_read_lock();
- ent = rhashtable_lookup(&br->mdb_hash_tbl, dst, br_mdb_rht_params);
- rcu_read_unlock();
- return ent;
- }
- static struct net_bridge_mdb_entry *br_mdb_ip4_get(struct net_bridge *br,
- __be32 dst, __u16 vid)
- {
- struct br_ip br_dst;
- memset(&br_dst, 0, sizeof(br_dst));
- br_dst.dst.ip4 = dst;
- br_dst.proto = htons(ETH_P_IP);
- br_dst.vid = vid;
- return br_mdb_ip_get(br, &br_dst);
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static struct net_bridge_mdb_entry *br_mdb_ip6_get(struct net_bridge *br,
- const struct in6_addr *dst,
- __u16 vid)
- {
- struct br_ip br_dst;
- memset(&br_dst, 0, sizeof(br_dst));
- br_dst.dst.ip6 = *dst;
- br_dst.proto = htons(ETH_P_IPV6);
- br_dst.vid = vid;
- return br_mdb_ip_get(br, &br_dst);
- }
- #endif
- struct net_bridge_mdb_entry *br_mdb_get(struct net_bridge_mcast *brmctx,
- struct sk_buff *skb, u16 vid)
- {
- struct net_bridge *br = brmctx->br;
- struct br_ip ip;
- if (!br_opt_get(br, BROPT_MULTICAST_ENABLED) ||
- br_multicast_ctx_vlan_global_disabled(brmctx))
- return NULL;
- if (BR_INPUT_SKB_CB(skb)->igmp)
- return NULL;
- memset(&ip, 0, sizeof(ip));
- ip.proto = skb->protocol;
- ip.vid = vid;
- switch (skb->protocol) {
- case htons(ETH_P_IP):
- ip.dst.ip4 = ip_hdr(skb)->daddr;
- if (brmctx->multicast_igmp_version == 3) {
- struct net_bridge_mdb_entry *mdb;
- ip.src.ip4 = ip_hdr(skb)->saddr;
- mdb = br_mdb_ip_get_rcu(br, &ip);
- if (mdb)
- return mdb;
- ip.src.ip4 = 0;
- }
- break;
- #if IS_ENABLED(CONFIG_IPV6)
- case htons(ETH_P_IPV6):
- ip.dst.ip6 = ipv6_hdr(skb)->daddr;
- if (brmctx->multicast_mld_version == 2) {
- struct net_bridge_mdb_entry *mdb;
- ip.src.ip6 = ipv6_hdr(skb)->saddr;
- mdb = br_mdb_ip_get_rcu(br, &ip);
- if (mdb)
- return mdb;
- memset(&ip.src.ip6, 0, sizeof(ip.src.ip6));
- }
- break;
- #endif
- default:
- ip.proto = 0;
- ether_addr_copy(ip.dst.mac_addr, eth_hdr(skb)->h_dest);
- }
- return br_mdb_ip_get_rcu(br, &ip);
- }
- /* IMPORTANT: this function must be used only when the contexts cannot be
- * passed down (e.g. timer) and must be used for read-only purposes because
- * the vlan snooping option can change, so it can return any context
- * (non-vlan or vlan). Its initial intended purpose is to read timer values
- * from the *current* context based on the option. At worst that could lead
- * to inconsistent timers when the contexts are changed, i.e. src timer
- * which needs to re-arm with a specific delay taken from the old context
- */
- static struct net_bridge_mcast_port *
- br_multicast_pg_to_port_ctx(const struct net_bridge_port_group *pg)
- {
- struct net_bridge_mcast_port *pmctx = &pg->key.port->multicast_ctx;
- struct net_bridge_vlan *vlan;
- lockdep_assert_held_once(&pg->key.port->br->multicast_lock);
- /* if vlan snooping is disabled use the port's multicast context */
- if (!pg->key.addr.vid ||
- !br_opt_get(pg->key.port->br, BROPT_MCAST_VLAN_SNOOPING_ENABLED))
- goto out;
- /* locking is tricky here, due to different rules for multicast and
- * vlans we need to take rcu to find the vlan and make sure it has
- * the BR_VLFLAG_MCAST_ENABLED flag set, it can only change under
- * multicast_lock which must be already held here, so the vlan's pmctx
- * can safely be used on return
- */
- rcu_read_lock();
- vlan = br_vlan_find(nbp_vlan_group_rcu(pg->key.port), pg->key.addr.vid);
- if (vlan && !br_multicast_port_ctx_vlan_disabled(&vlan->port_mcast_ctx))
- pmctx = &vlan->port_mcast_ctx;
- else
- pmctx = NULL;
- rcu_read_unlock();
- out:
- return pmctx;
- }
- /* when snooping we need to check if the contexts should be used
- * in the following order:
- * - if pmctx is non-NULL (port), check if it should be used
- * - if pmctx is NULL (bridge), check if brmctx should be used
- */
- static bool
- br_multicast_ctx_should_use(const struct net_bridge_mcast *brmctx,
- const struct net_bridge_mcast_port *pmctx)
- {
- if (!netif_running(brmctx->br->dev))
- return false;
- if (pmctx)
- return !br_multicast_port_ctx_state_disabled(pmctx);
- else
- return !br_multicast_ctx_vlan_disabled(brmctx);
- }
- static bool br_port_group_equal(struct net_bridge_port_group *p,
- struct net_bridge_port *port,
- const unsigned char *src)
- {
- if (p->key.port != port)
- return false;
- if (!(port->flags & BR_MULTICAST_TO_UNICAST))
- return true;
- return ether_addr_equal(src, p->eth_addr);
- }
- static void __fwd_add_star_excl(struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg,
- struct br_ip *sg_ip)
- {
- struct net_bridge_port_group_sg_key sg_key;
- struct net_bridge_port_group *src_pg;
- struct net_bridge_mcast *brmctx;
- memset(&sg_key, 0, sizeof(sg_key));
- brmctx = br_multicast_port_ctx_get_global(pmctx);
- sg_key.port = pg->key.port;
- sg_key.addr = *sg_ip;
- if (br_sg_port_find(brmctx->br, &sg_key))
- return;
- src_pg = __br_multicast_add_group(brmctx, pmctx,
- sg_ip, pg->eth_addr,
- MCAST_INCLUDE, false, false);
- if (IS_ERR_OR_NULL(src_pg) ||
- src_pg->rt_protocol != RTPROT_KERNEL)
- return;
- src_pg->flags |= MDB_PG_FLAGS_STAR_EXCL;
- }
- static void __fwd_del_star_excl(struct net_bridge_port_group *pg,
- struct br_ip *sg_ip)
- {
- struct net_bridge_port_group_sg_key sg_key;
- struct net_bridge *br = pg->key.port->br;
- struct net_bridge_port_group *src_pg;
- memset(&sg_key, 0, sizeof(sg_key));
- sg_key.port = pg->key.port;
- sg_key.addr = *sg_ip;
- src_pg = br_sg_port_find(br, &sg_key);
- if (!src_pg || !(src_pg->flags & MDB_PG_FLAGS_STAR_EXCL) ||
- src_pg->rt_protocol != RTPROT_KERNEL)
- return;
- br_multicast_find_del_pg(br, src_pg);
- }
- /* When a port group transitions to (or is added as) EXCLUDE we need to add it
- * to all other ports' S,G entries which are not blocked by the current group
- * for proper replication, the assumption is that any S,G blocked entries
- * are already added so the S,G,port lookup should skip them.
- * When a port group transitions from EXCLUDE -> INCLUDE mode or is being
- * deleted we need to remove it from all ports' S,G entries where it was
- * automatically installed before (i.e. where it's MDB_PG_FLAGS_STAR_EXCL).
- */
- void br_multicast_star_g_handle_mode(struct net_bridge_port_group *pg,
- u8 filter_mode)
- {
- struct net_bridge *br = pg->key.port->br;
- struct net_bridge_port_group *pg_lst;
- struct net_bridge_mcast_port *pmctx;
- struct net_bridge_mdb_entry *mp;
- struct br_ip sg_ip;
- if (WARN_ON(!br_multicast_is_star_g(&pg->key.addr)))
- return;
- mp = br_mdb_ip_get(br, &pg->key.addr);
- if (!mp)
- return;
- pmctx = br_multicast_pg_to_port_ctx(pg);
- if (!pmctx)
- return;
- memset(&sg_ip, 0, sizeof(sg_ip));
- sg_ip = pg->key.addr;
- for (pg_lst = mlock_dereference(mp->ports, br);
- pg_lst;
- pg_lst = mlock_dereference(pg_lst->next, br)) {
- struct net_bridge_group_src *src_ent;
- if (pg_lst == pg)
- continue;
- hlist_for_each_entry(src_ent, &pg_lst->src_list, node) {
- if (!(src_ent->flags & BR_SGRP_F_INSTALLED))
- continue;
- sg_ip.src = src_ent->addr.src;
- switch (filter_mode) {
- case MCAST_INCLUDE:
- __fwd_del_star_excl(pg, &sg_ip);
- break;
- case MCAST_EXCLUDE:
- __fwd_add_star_excl(pmctx, pg, &sg_ip);
- break;
- }
- }
- }
- }
- /* called when adding a new S,G with host_joined == false by default */
- static void br_multicast_sg_host_state(struct net_bridge_mdb_entry *star_mp,
- struct net_bridge_port_group *sg)
- {
- struct net_bridge_mdb_entry *sg_mp;
- if (WARN_ON(!br_multicast_is_star_g(&star_mp->addr)))
- return;
- if (!star_mp->host_joined)
- return;
- sg_mp = br_mdb_ip_get(star_mp->br, &sg->key.addr);
- if (!sg_mp)
- return;
- sg_mp->host_joined = true;
- }
- /* set the host_joined state of all of *,G's S,G entries */
- static void br_multicast_star_g_host_state(struct net_bridge_mdb_entry *star_mp)
- {
- struct net_bridge *br = star_mp->br;
- struct net_bridge_mdb_entry *sg_mp;
- struct net_bridge_port_group *pg;
- struct br_ip sg_ip;
- if (WARN_ON(!br_multicast_is_star_g(&star_mp->addr)))
- return;
- memset(&sg_ip, 0, sizeof(sg_ip));
- sg_ip = star_mp->addr;
- for (pg = mlock_dereference(star_mp->ports, br);
- pg;
- pg = mlock_dereference(pg->next, br)) {
- struct net_bridge_group_src *src_ent;
- hlist_for_each_entry(src_ent, &pg->src_list, node) {
- if (!(src_ent->flags & BR_SGRP_F_INSTALLED))
- continue;
- sg_ip.src = src_ent->addr.src;
- sg_mp = br_mdb_ip_get(br, &sg_ip);
- if (!sg_mp)
- continue;
- sg_mp->host_joined = star_mp->host_joined;
- }
- }
- }
- static void br_multicast_sg_del_exclude_ports(struct net_bridge_mdb_entry *sgmp)
- {
- struct net_bridge_port_group __rcu **pp;
- struct net_bridge_port_group *p;
- /* *,G exclude ports are only added to S,G entries */
- if (WARN_ON(br_multicast_is_star_g(&sgmp->addr)))
- return;
- /* we need the STAR_EXCLUDE ports if there are non-STAR_EXCLUDE ports
- * we should ignore perm entries since they're managed by user-space
- */
- for (pp = &sgmp->ports;
- (p = mlock_dereference(*pp, sgmp->br)) != NULL;
- pp = &p->next)
- if (!(p->flags & (MDB_PG_FLAGS_STAR_EXCL |
- MDB_PG_FLAGS_PERMANENT)))
- return;
- /* currently the host can only have joined the *,G which means
- * we treat it as EXCLUDE {}, so for an S,G it's considered a
- * STAR_EXCLUDE entry and we can safely leave it
- */
- sgmp->host_joined = false;
- for (pp = &sgmp->ports;
- (p = mlock_dereference(*pp, sgmp->br)) != NULL;) {
- if (!(p->flags & MDB_PG_FLAGS_PERMANENT))
- br_multicast_del_pg(sgmp, p, pp);
- else
- pp = &p->next;
- }
- }
- void br_multicast_sg_add_exclude_ports(struct net_bridge_mdb_entry *star_mp,
- struct net_bridge_port_group *sg)
- {
- struct net_bridge_port_group_sg_key sg_key;
- struct net_bridge *br = star_mp->br;
- struct net_bridge_mcast_port *pmctx;
- struct net_bridge_port_group *pg;
- struct net_bridge_mcast *brmctx;
- if (WARN_ON(br_multicast_is_star_g(&sg->key.addr)))
- return;
- if (WARN_ON(!br_multicast_is_star_g(&star_mp->addr)))
- return;
- br_multicast_sg_host_state(star_mp, sg);
- memset(&sg_key, 0, sizeof(sg_key));
- sg_key.addr = sg->key.addr;
- /* we need to add all exclude ports to the S,G */
- for (pg = mlock_dereference(star_mp->ports, br);
- pg;
- pg = mlock_dereference(pg->next, br)) {
- struct net_bridge_port_group *src_pg;
- if (pg == sg || pg->filter_mode == MCAST_INCLUDE)
- continue;
- sg_key.port = pg->key.port;
- if (br_sg_port_find(br, &sg_key))
- continue;
- pmctx = br_multicast_pg_to_port_ctx(pg);
- if (!pmctx)
- continue;
- brmctx = br_multicast_port_ctx_get_global(pmctx);
- src_pg = __br_multicast_add_group(brmctx, pmctx,
- &sg->key.addr,
- sg->eth_addr,
- MCAST_INCLUDE, false, false);
- if (IS_ERR_OR_NULL(src_pg) ||
- src_pg->rt_protocol != RTPROT_KERNEL)
- continue;
- src_pg->flags |= MDB_PG_FLAGS_STAR_EXCL;
- }
- }
- static void br_multicast_fwd_src_add(struct net_bridge_group_src *src)
- {
- struct net_bridge_mdb_entry *star_mp;
- struct net_bridge_mcast_port *pmctx;
- struct net_bridge_port_group *sg;
- struct net_bridge_mcast *brmctx;
- struct br_ip sg_ip;
- if (src->flags & BR_SGRP_F_INSTALLED)
- return;
- memset(&sg_ip, 0, sizeof(sg_ip));
- pmctx = br_multicast_pg_to_port_ctx(src->pg);
- if (!pmctx)
- return;
- brmctx = br_multicast_port_ctx_get_global(pmctx);
- sg_ip = src->pg->key.addr;
- sg_ip.src = src->addr.src;
- sg = __br_multicast_add_group(brmctx, pmctx, &sg_ip,
- src->pg->eth_addr, MCAST_INCLUDE, false,
- !timer_pending(&src->timer));
- if (IS_ERR_OR_NULL(sg))
- return;
- src->flags |= BR_SGRP_F_INSTALLED;
- sg->flags &= ~MDB_PG_FLAGS_STAR_EXCL;
- /* if it was added by user-space as perm we can skip next steps */
- if (sg->rt_protocol != RTPROT_KERNEL &&
- (sg->flags & MDB_PG_FLAGS_PERMANENT))
- return;
- /* the kernel is now responsible for removing this S,G */
- del_timer(&sg->timer);
- star_mp = br_mdb_ip_get(src->br, &src->pg->key.addr);
- if (!star_mp)
- return;
- br_multicast_sg_add_exclude_ports(star_mp, sg);
- }
- static void br_multicast_fwd_src_remove(struct net_bridge_group_src *src,
- bool fastleave)
- {
- struct net_bridge_port_group *p, *pg = src->pg;
- struct net_bridge_port_group __rcu **pp;
- struct net_bridge_mdb_entry *mp;
- struct br_ip sg_ip;
- memset(&sg_ip, 0, sizeof(sg_ip));
- sg_ip = pg->key.addr;
- sg_ip.src = src->addr.src;
- mp = br_mdb_ip_get(src->br, &sg_ip);
- if (!mp)
- return;
- for (pp = &mp->ports;
- (p = mlock_dereference(*pp, src->br)) != NULL;
- pp = &p->next) {
- if (!br_port_group_equal(p, pg->key.port, pg->eth_addr))
- continue;
- if (p->rt_protocol != RTPROT_KERNEL &&
- (p->flags & MDB_PG_FLAGS_PERMANENT))
- break;
- if (fastleave)
- p->flags |= MDB_PG_FLAGS_FAST_LEAVE;
- br_multicast_del_pg(mp, p, pp);
- break;
- }
- src->flags &= ~BR_SGRP_F_INSTALLED;
- }
- /* install S,G and based on src's timer enable or disable forwarding */
- static void br_multicast_fwd_src_handle(struct net_bridge_group_src *src)
- {
- struct net_bridge_port_group_sg_key sg_key;
- struct net_bridge_port_group *sg;
- u8 old_flags;
- br_multicast_fwd_src_add(src);
- memset(&sg_key, 0, sizeof(sg_key));
- sg_key.addr = src->pg->key.addr;
- sg_key.addr.src = src->addr.src;
- sg_key.port = src->pg->key.port;
- sg = br_sg_port_find(src->br, &sg_key);
- if (!sg || (sg->flags & MDB_PG_FLAGS_PERMANENT))
- return;
- old_flags = sg->flags;
- if (timer_pending(&src->timer))
- sg->flags &= ~MDB_PG_FLAGS_BLOCKED;
- else
- sg->flags |= MDB_PG_FLAGS_BLOCKED;
- if (old_flags != sg->flags) {
- struct net_bridge_mdb_entry *sg_mp;
- sg_mp = br_mdb_ip_get(src->br, &sg_key.addr);
- if (!sg_mp)
- return;
- br_mdb_notify(src->br->dev, sg_mp, sg, RTM_NEWMDB);
- }
- }
- static void br_multicast_destroy_mdb_entry(struct net_bridge_mcast_gc *gc)
- {
- struct net_bridge_mdb_entry *mp;
- mp = container_of(gc, struct net_bridge_mdb_entry, mcast_gc);
- WARN_ON(!hlist_unhashed(&mp->mdb_node));
- WARN_ON(mp->ports);
- del_timer_sync(&mp->timer);
- kfree_rcu(mp, rcu);
- }
- static void br_multicast_del_mdb_entry(struct net_bridge_mdb_entry *mp)
- {
- struct net_bridge *br = mp->br;
- rhashtable_remove_fast(&br->mdb_hash_tbl, &mp->rhnode,
- br_mdb_rht_params);
- hlist_del_init_rcu(&mp->mdb_node);
- hlist_add_head(&mp->mcast_gc.gc_node, &br->mcast_gc_list);
- queue_work(system_long_wq, &br->mcast_gc_work);
- }
- static void br_multicast_group_expired(struct timer_list *t)
- {
- struct net_bridge_mdb_entry *mp = from_timer(mp, t, timer);
- struct net_bridge *br = mp->br;
- spin_lock(&br->multicast_lock);
- if (hlist_unhashed(&mp->mdb_node) || !netif_running(br->dev) ||
- timer_pending(&mp->timer))
- goto out;
- br_multicast_host_leave(mp, true);
- if (mp->ports)
- goto out;
- br_multicast_del_mdb_entry(mp);
- out:
- spin_unlock(&br->multicast_lock);
- }
- static void br_multicast_destroy_group_src(struct net_bridge_mcast_gc *gc)
- {
- struct net_bridge_group_src *src;
- src = container_of(gc, struct net_bridge_group_src, mcast_gc);
- WARN_ON(!hlist_unhashed(&src->node));
- del_timer_sync(&src->timer);
- kfree_rcu(src, rcu);
- }
- void br_multicast_del_group_src(struct net_bridge_group_src *src,
- bool fastleave)
- {
- struct net_bridge *br = src->pg->key.port->br;
- br_multicast_fwd_src_remove(src, fastleave);
- hlist_del_init_rcu(&src->node);
- src->pg->src_ents--;
- hlist_add_head(&src->mcast_gc.gc_node, &br->mcast_gc_list);
- queue_work(system_long_wq, &br->mcast_gc_work);
- }
- static void br_multicast_destroy_port_group(struct net_bridge_mcast_gc *gc)
- {
- struct net_bridge_port_group *pg;
- pg = container_of(gc, struct net_bridge_port_group, mcast_gc);
- WARN_ON(!hlist_unhashed(&pg->mglist));
- WARN_ON(!hlist_empty(&pg->src_list));
- del_timer_sync(&pg->rexmit_timer);
- del_timer_sync(&pg->timer);
- kfree_rcu(pg, rcu);
- }
- void br_multicast_del_pg(struct net_bridge_mdb_entry *mp,
- struct net_bridge_port_group *pg,
- struct net_bridge_port_group __rcu **pp)
- {
- struct net_bridge *br = pg->key.port->br;
- struct net_bridge_group_src *ent;
- struct hlist_node *tmp;
- rcu_assign_pointer(*pp, pg->next);
- hlist_del_init(&pg->mglist);
- br_multicast_eht_clean_sets(pg);
- hlist_for_each_entry_safe(ent, tmp, &pg->src_list, node)
- br_multicast_del_group_src(ent, false);
- br_mdb_notify(br->dev, mp, pg, RTM_DELMDB);
- if (!br_multicast_is_star_g(&mp->addr)) {
- rhashtable_remove_fast(&br->sg_port_tbl, &pg->rhnode,
- br_sg_port_rht_params);
- br_multicast_sg_del_exclude_ports(mp);
- } else {
- br_multicast_star_g_handle_mode(pg, MCAST_INCLUDE);
- }
- hlist_add_head(&pg->mcast_gc.gc_node, &br->mcast_gc_list);
- queue_work(system_long_wq, &br->mcast_gc_work);
- if (!mp->ports && !mp->host_joined && netif_running(br->dev))
- mod_timer(&mp->timer, jiffies);
- }
- static void br_multicast_find_del_pg(struct net_bridge *br,
- struct net_bridge_port_group *pg)
- {
- struct net_bridge_port_group __rcu **pp;
- struct net_bridge_mdb_entry *mp;
- struct net_bridge_port_group *p;
- mp = br_mdb_ip_get(br, &pg->key.addr);
- if (WARN_ON(!mp))
- return;
- for (pp = &mp->ports;
- (p = mlock_dereference(*pp, br)) != NULL;
- pp = &p->next) {
- if (p != pg)
- continue;
- br_multicast_del_pg(mp, pg, pp);
- return;
- }
- WARN_ON(1);
- }
- static void br_multicast_port_group_expired(struct timer_list *t)
- {
- struct net_bridge_port_group *pg = from_timer(pg, t, timer);
- struct net_bridge_group_src *src_ent;
- struct net_bridge *br = pg->key.port->br;
- struct hlist_node *tmp;
- bool changed;
- spin_lock(&br->multicast_lock);
- if (!netif_running(br->dev) || timer_pending(&pg->timer) ||
- hlist_unhashed(&pg->mglist) || pg->flags & MDB_PG_FLAGS_PERMANENT)
- goto out;
- changed = !!(pg->filter_mode == MCAST_EXCLUDE);
- pg->filter_mode = MCAST_INCLUDE;
- hlist_for_each_entry_safe(src_ent, tmp, &pg->src_list, node) {
- if (!timer_pending(&src_ent->timer)) {
- br_multicast_del_group_src(src_ent, false);
- changed = true;
- }
- }
- if (hlist_empty(&pg->src_list)) {
- br_multicast_find_del_pg(br, pg);
- } else if (changed) {
- struct net_bridge_mdb_entry *mp = br_mdb_ip_get(br, &pg->key.addr);
- if (changed && br_multicast_is_star_g(&pg->key.addr))
- br_multicast_star_g_handle_mode(pg, MCAST_INCLUDE);
- if (WARN_ON(!mp))
- goto out;
- br_mdb_notify(br->dev, mp, pg, RTM_NEWMDB);
- }
- out:
- spin_unlock(&br->multicast_lock);
- }
- static void br_multicast_gc(struct hlist_head *head)
- {
- struct net_bridge_mcast_gc *gcent;
- struct hlist_node *tmp;
- hlist_for_each_entry_safe(gcent, tmp, head, gc_node) {
- hlist_del_init(&gcent->gc_node);
- gcent->destroy(gcent);
- }
- }
- static void __br_multicast_query_handle_vlan(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct sk_buff *skb)
- {
- struct net_bridge_vlan *vlan = NULL;
- if (pmctx && br_multicast_port_ctx_is_vlan(pmctx))
- vlan = pmctx->vlan;
- else if (br_multicast_ctx_is_vlan(brmctx))
- vlan = brmctx->vlan;
- if (vlan && !(vlan->flags & BRIDGE_VLAN_INFO_UNTAGGED)) {
- u16 vlan_proto;
- if (br_vlan_get_proto(brmctx->br->dev, &vlan_proto) != 0)
- return;
- __vlan_hwaccel_put_tag(skb, htons(vlan_proto), vlan->vid);
- }
- }
- static struct sk_buff *br_ip4_multicast_alloc_query(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg,
- __be32 ip_dst, __be32 group,
- bool with_srcs, bool over_lmqt,
- u8 sflag, u8 *igmp_type,
- bool *need_rexmit)
- {
- struct net_bridge_port *p = pg ? pg->key.port : NULL;
- struct net_bridge_group_src *ent;
- size_t pkt_size, igmp_hdr_size;
- unsigned long now = jiffies;
- struct igmpv3_query *ihv3;
- void *csum_start = NULL;
- __sum16 *csum = NULL;
- struct sk_buff *skb;
- struct igmphdr *ih;
- struct ethhdr *eth;
- unsigned long lmqt;
- struct iphdr *iph;
- u16 lmqt_srcs = 0;
- igmp_hdr_size = sizeof(*ih);
- if (brmctx->multicast_igmp_version == 3) {
- igmp_hdr_size = sizeof(*ihv3);
- if (pg && with_srcs) {
- lmqt = now + (brmctx->multicast_last_member_interval *
- brmctx->multicast_last_member_count);
- hlist_for_each_entry(ent, &pg->src_list, node) {
- if (over_lmqt == time_after(ent->timer.expires,
- lmqt) &&
- ent->src_query_rexmit_cnt > 0)
- lmqt_srcs++;
- }
- if (!lmqt_srcs)
- return NULL;
- igmp_hdr_size += lmqt_srcs * sizeof(__be32);
- }
- }
- pkt_size = sizeof(*eth) + sizeof(*iph) + 4 + igmp_hdr_size;
- if ((p && pkt_size > p->dev->mtu) ||
- pkt_size > brmctx->br->dev->mtu)
- return NULL;
- skb = netdev_alloc_skb_ip_align(brmctx->br->dev, pkt_size);
- if (!skb)
- goto out;
- __br_multicast_query_handle_vlan(brmctx, pmctx, skb);
- skb->protocol = htons(ETH_P_IP);
- skb_reset_mac_header(skb);
- eth = eth_hdr(skb);
- ether_addr_copy(eth->h_source, brmctx->br->dev->dev_addr);
- ip_eth_mc_map(ip_dst, eth->h_dest);
- eth->h_proto = htons(ETH_P_IP);
- skb_put(skb, sizeof(*eth));
- skb_set_network_header(skb, skb->len);
- iph = ip_hdr(skb);
- iph->tot_len = htons(pkt_size - sizeof(*eth));
- iph->version = 4;
- iph->ihl = 6;
- iph->tos = 0xc0;
- iph->id = 0;
- iph->frag_off = htons(IP_DF);
- iph->ttl = 1;
- iph->protocol = IPPROTO_IGMP;
- iph->saddr = br_opt_get(brmctx->br, BROPT_MULTICAST_QUERY_USE_IFADDR) ?
- inet_select_addr(brmctx->br->dev, 0, RT_SCOPE_LINK) : 0;
- iph->daddr = ip_dst;
- ((u8 *)&iph[1])[0] = IPOPT_RA;
- ((u8 *)&iph[1])[1] = 4;
- ((u8 *)&iph[1])[2] = 0;
- ((u8 *)&iph[1])[3] = 0;
- ip_send_check(iph);
- skb_put(skb, 24);
- skb_set_transport_header(skb, skb->len);
- *igmp_type = IGMP_HOST_MEMBERSHIP_QUERY;
- switch (brmctx->multicast_igmp_version) {
- case 2:
- ih = igmp_hdr(skb);
- ih->type = IGMP_HOST_MEMBERSHIP_QUERY;
- ih->code = (group ? brmctx->multicast_last_member_interval :
- brmctx->multicast_query_response_interval) /
- (HZ / IGMP_TIMER_SCALE);
- ih->group = group;
- ih->csum = 0;
- csum = &ih->csum;
- csum_start = (void *)ih;
- break;
- case 3:
- ihv3 = igmpv3_query_hdr(skb);
- ihv3->type = IGMP_HOST_MEMBERSHIP_QUERY;
- ihv3->code = (group ? brmctx->multicast_last_member_interval :
- brmctx->multicast_query_response_interval) /
- (HZ / IGMP_TIMER_SCALE);
- ihv3->group = group;
- ihv3->qqic = brmctx->multicast_query_interval / HZ;
- ihv3->nsrcs = htons(lmqt_srcs);
- ihv3->resv = 0;
- ihv3->suppress = sflag;
- ihv3->qrv = 2;
- ihv3->csum = 0;
- csum = &ihv3->csum;
- csum_start = (void *)ihv3;
- if (!pg || !with_srcs)
- break;
- lmqt_srcs = 0;
- hlist_for_each_entry(ent, &pg->src_list, node) {
- if (over_lmqt == time_after(ent->timer.expires,
- lmqt) &&
- ent->src_query_rexmit_cnt > 0) {
- ihv3->srcs[lmqt_srcs++] = ent->addr.src.ip4;
- ent->src_query_rexmit_cnt--;
- if (need_rexmit && ent->src_query_rexmit_cnt)
- *need_rexmit = true;
- }
- }
- if (WARN_ON(lmqt_srcs != ntohs(ihv3->nsrcs))) {
- kfree_skb(skb);
- return NULL;
- }
- break;
- }
- if (WARN_ON(!csum || !csum_start)) {
- kfree_skb(skb);
- return NULL;
- }
- *csum = ip_compute_csum(csum_start, igmp_hdr_size);
- skb_put(skb, igmp_hdr_size);
- __skb_pull(skb, sizeof(*eth));
- out:
- return skb;
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static struct sk_buff *br_ip6_multicast_alloc_query(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg,
- const struct in6_addr *ip6_dst,
- const struct in6_addr *group,
- bool with_srcs, bool over_llqt,
- u8 sflag, u8 *igmp_type,
- bool *need_rexmit)
- {
- struct net_bridge_port *p = pg ? pg->key.port : NULL;
- struct net_bridge_group_src *ent;
- size_t pkt_size, mld_hdr_size;
- unsigned long now = jiffies;
- struct mld2_query *mld2q;
- void *csum_start = NULL;
- unsigned long interval;
- __sum16 *csum = NULL;
- struct ipv6hdr *ip6h;
- struct mld_msg *mldq;
- struct sk_buff *skb;
- unsigned long llqt;
- struct ethhdr *eth;
- u16 llqt_srcs = 0;
- u8 *hopopt;
- mld_hdr_size = sizeof(*mldq);
- if (brmctx->multicast_mld_version == 2) {
- mld_hdr_size = sizeof(*mld2q);
- if (pg && with_srcs) {
- llqt = now + (brmctx->multicast_last_member_interval *
- brmctx->multicast_last_member_count);
- hlist_for_each_entry(ent, &pg->src_list, node) {
- if (over_llqt == time_after(ent->timer.expires,
- llqt) &&
- ent->src_query_rexmit_cnt > 0)
- llqt_srcs++;
- }
- if (!llqt_srcs)
- return NULL;
- mld_hdr_size += llqt_srcs * sizeof(struct in6_addr);
- }
- }
- pkt_size = sizeof(*eth) + sizeof(*ip6h) + 8 + mld_hdr_size;
- if ((p && pkt_size > p->dev->mtu) ||
- pkt_size > brmctx->br->dev->mtu)
- return NULL;
- skb = netdev_alloc_skb_ip_align(brmctx->br->dev, pkt_size);
- if (!skb)
- goto out;
- __br_multicast_query_handle_vlan(brmctx, pmctx, skb);
- skb->protocol = htons(ETH_P_IPV6);
- /* Ethernet header */
- skb_reset_mac_header(skb);
- eth = eth_hdr(skb);
- ether_addr_copy(eth->h_source, brmctx->br->dev->dev_addr);
- eth->h_proto = htons(ETH_P_IPV6);
- skb_put(skb, sizeof(*eth));
- /* IPv6 header + HbH option */
- skb_set_network_header(skb, skb->len);
- ip6h = ipv6_hdr(skb);
- *(__force __be32 *)ip6h = htonl(0x60000000);
- ip6h->payload_len = htons(8 + mld_hdr_size);
- ip6h->nexthdr = IPPROTO_HOPOPTS;
- ip6h->hop_limit = 1;
- ip6h->daddr = *ip6_dst;
- if (ipv6_dev_get_saddr(dev_net(brmctx->br->dev), brmctx->br->dev,
- &ip6h->daddr, 0, &ip6h->saddr)) {
- kfree_skb(skb);
- br_opt_toggle(brmctx->br, BROPT_HAS_IPV6_ADDR, false);
- return NULL;
- }
- br_opt_toggle(brmctx->br, BROPT_HAS_IPV6_ADDR, true);
- ipv6_eth_mc_map(&ip6h->daddr, eth->h_dest);
- hopopt = (u8 *)(ip6h + 1);
- hopopt[0] = IPPROTO_ICMPV6; /* next hdr */
- hopopt[1] = 0; /* length of HbH */
- hopopt[2] = IPV6_TLV_ROUTERALERT; /* Router Alert */
- hopopt[3] = 2; /* Length of RA Option */
- hopopt[4] = 0; /* Type = 0x0000 (MLD) */
- hopopt[5] = 0;
- hopopt[6] = IPV6_TLV_PAD1; /* Pad1 */
- hopopt[7] = IPV6_TLV_PAD1; /* Pad1 */
- skb_put(skb, sizeof(*ip6h) + 8);
- /* ICMPv6 */
- skb_set_transport_header(skb, skb->len);
- interval = ipv6_addr_any(group) ?
- brmctx->multicast_query_response_interval :
- brmctx->multicast_last_member_interval;
- *igmp_type = ICMPV6_MGM_QUERY;
- switch (brmctx->multicast_mld_version) {
- case 1:
- mldq = (struct mld_msg *)icmp6_hdr(skb);
- mldq->mld_type = ICMPV6_MGM_QUERY;
- mldq->mld_code = 0;
- mldq->mld_cksum = 0;
- mldq->mld_maxdelay = htons((u16)jiffies_to_msecs(interval));
- mldq->mld_reserved = 0;
- mldq->mld_mca = *group;
- csum = &mldq->mld_cksum;
- csum_start = (void *)mldq;
- break;
- case 2:
- mld2q = (struct mld2_query *)icmp6_hdr(skb);
- mld2q->mld2q_mrc = htons((u16)jiffies_to_msecs(interval));
- mld2q->mld2q_type = ICMPV6_MGM_QUERY;
- mld2q->mld2q_code = 0;
- mld2q->mld2q_cksum = 0;
- mld2q->mld2q_resv1 = 0;
- mld2q->mld2q_resv2 = 0;
- mld2q->mld2q_suppress = sflag;
- mld2q->mld2q_qrv = 2;
- mld2q->mld2q_nsrcs = htons(llqt_srcs);
- mld2q->mld2q_qqic = brmctx->multicast_query_interval / HZ;
- mld2q->mld2q_mca = *group;
- csum = &mld2q->mld2q_cksum;
- csum_start = (void *)mld2q;
- if (!pg || !with_srcs)
- break;
- llqt_srcs = 0;
- hlist_for_each_entry(ent, &pg->src_list, node) {
- if (over_llqt == time_after(ent->timer.expires,
- llqt) &&
- ent->src_query_rexmit_cnt > 0) {
- mld2q->mld2q_srcs[llqt_srcs++] = ent->addr.src.ip6;
- ent->src_query_rexmit_cnt--;
- if (need_rexmit && ent->src_query_rexmit_cnt)
- *need_rexmit = true;
- }
- }
- if (WARN_ON(llqt_srcs != ntohs(mld2q->mld2q_nsrcs))) {
- kfree_skb(skb);
- return NULL;
- }
- break;
- }
- if (WARN_ON(!csum || !csum_start)) {
- kfree_skb(skb);
- return NULL;
- }
- *csum = csum_ipv6_magic(&ip6h->saddr, &ip6h->daddr, mld_hdr_size,
- IPPROTO_ICMPV6,
- csum_partial(csum_start, mld_hdr_size, 0));
- skb_put(skb, mld_hdr_size);
- __skb_pull(skb, sizeof(*eth));
- out:
- return skb;
- }
- #endif
- static struct sk_buff *br_multicast_alloc_query(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg,
- struct br_ip *ip_dst,
- struct br_ip *group,
- bool with_srcs, bool over_lmqt,
- u8 sflag, u8 *igmp_type,
- bool *need_rexmit)
- {
- __be32 ip4_dst;
- switch (group->proto) {
- case htons(ETH_P_IP):
- ip4_dst = ip_dst ? ip_dst->dst.ip4 : htonl(INADDR_ALLHOSTS_GROUP);
- return br_ip4_multicast_alloc_query(brmctx, pmctx, pg,
- ip4_dst, group->dst.ip4,
- with_srcs, over_lmqt,
- sflag, igmp_type,
- need_rexmit);
- #if IS_ENABLED(CONFIG_IPV6)
- case htons(ETH_P_IPV6): {
- struct in6_addr ip6_dst;
- if (ip_dst)
- ip6_dst = ip_dst->dst.ip6;
- else
- ipv6_addr_set(&ip6_dst, htonl(0xff020000), 0, 0,
- htonl(1));
- return br_ip6_multicast_alloc_query(brmctx, pmctx, pg,
- &ip6_dst, &group->dst.ip6,
- with_srcs, over_lmqt,
- sflag, igmp_type,
- need_rexmit);
- }
- #endif
- }
- return NULL;
- }
- struct net_bridge_mdb_entry *br_multicast_new_group(struct net_bridge *br,
- struct br_ip *group)
- {
- struct net_bridge_mdb_entry *mp;
- int err;
- mp = br_mdb_ip_get(br, group);
- if (mp)
- return mp;
- if (atomic_read(&br->mdb_hash_tbl.nelems) >= br->hash_max) {
- br_mc_disabled_update(br->dev, false, NULL);
- br_opt_toggle(br, BROPT_MULTICAST_ENABLED, false);
- return ERR_PTR(-E2BIG);
- }
- mp = kzalloc(sizeof(*mp), GFP_ATOMIC);
- if (unlikely(!mp))
- return ERR_PTR(-ENOMEM);
- mp->br = br;
- mp->addr = *group;
- mp->mcast_gc.destroy = br_multicast_destroy_mdb_entry;
- timer_setup(&mp->timer, br_multicast_group_expired, 0);
- err = rhashtable_lookup_insert_fast(&br->mdb_hash_tbl, &mp->rhnode,
- br_mdb_rht_params);
- if (err) {
- kfree(mp);
- mp = ERR_PTR(err);
- } else {
- hlist_add_head_rcu(&mp->mdb_node, &br->mdb_list);
- }
- return mp;
- }
- static void br_multicast_group_src_expired(struct timer_list *t)
- {
- struct net_bridge_group_src *src = from_timer(src, t, timer);
- struct net_bridge_port_group *pg;
- struct net_bridge *br = src->br;
- spin_lock(&br->multicast_lock);
- if (hlist_unhashed(&src->node) || !netif_running(br->dev) ||
- timer_pending(&src->timer))
- goto out;
- pg = src->pg;
- if (pg->filter_mode == MCAST_INCLUDE) {
- br_multicast_del_group_src(src, false);
- if (!hlist_empty(&pg->src_list))
- goto out;
- br_multicast_find_del_pg(br, pg);
- } else {
- br_multicast_fwd_src_handle(src);
- }
- out:
- spin_unlock(&br->multicast_lock);
- }
- struct net_bridge_group_src *
- br_multicast_find_group_src(struct net_bridge_port_group *pg, struct br_ip *ip)
- {
- struct net_bridge_group_src *ent;
- switch (ip->proto) {
- case htons(ETH_P_IP):
- hlist_for_each_entry(ent, &pg->src_list, node)
- if (ip->src.ip4 == ent->addr.src.ip4)
- return ent;
- break;
- #if IS_ENABLED(CONFIG_IPV6)
- case htons(ETH_P_IPV6):
- hlist_for_each_entry(ent, &pg->src_list, node)
- if (!ipv6_addr_cmp(&ent->addr.src.ip6, &ip->src.ip6))
- return ent;
- break;
- #endif
- }
- return NULL;
- }
- static struct net_bridge_group_src *
- br_multicast_new_group_src(struct net_bridge_port_group *pg, struct br_ip *src_ip)
- {
- struct net_bridge_group_src *grp_src;
- if (unlikely(pg->src_ents >= PG_SRC_ENT_LIMIT))
- return NULL;
- switch (src_ip->proto) {
- case htons(ETH_P_IP):
- if (ipv4_is_zeronet(src_ip->src.ip4) ||
- ipv4_is_multicast(src_ip->src.ip4))
- return NULL;
- break;
- #if IS_ENABLED(CONFIG_IPV6)
- case htons(ETH_P_IPV6):
- if (ipv6_addr_any(&src_ip->src.ip6) ||
- ipv6_addr_is_multicast(&src_ip->src.ip6))
- return NULL;
- break;
- #endif
- }
- grp_src = kzalloc(sizeof(*grp_src), GFP_ATOMIC);
- if (unlikely(!grp_src))
- return NULL;
- grp_src->pg = pg;
- grp_src->br = pg->key.port->br;
- grp_src->addr = *src_ip;
- grp_src->mcast_gc.destroy = br_multicast_destroy_group_src;
- timer_setup(&grp_src->timer, br_multicast_group_src_expired, 0);
- hlist_add_head_rcu(&grp_src->node, &pg->src_list);
- pg->src_ents++;
- return grp_src;
- }
- struct net_bridge_port_group *br_multicast_new_port_group(
- struct net_bridge_port *port,
- struct br_ip *group,
- struct net_bridge_port_group __rcu *next,
- unsigned char flags,
- const unsigned char *src,
- u8 filter_mode,
- u8 rt_protocol)
- {
- struct net_bridge_port_group *p;
- p = kzalloc(sizeof(*p), GFP_ATOMIC);
- if (unlikely(!p))
- return NULL;
- p->key.addr = *group;
- p->key.port = port;
- p->flags = flags;
- p->filter_mode = filter_mode;
- p->rt_protocol = rt_protocol;
- p->eht_host_tree = RB_ROOT;
- p->eht_set_tree = RB_ROOT;
- p->mcast_gc.destroy = br_multicast_destroy_port_group;
- INIT_HLIST_HEAD(&p->src_list);
- if (!br_multicast_is_star_g(group) &&
- rhashtable_lookup_insert_fast(&port->br->sg_port_tbl, &p->rhnode,
- br_sg_port_rht_params)) {
- kfree(p);
- return NULL;
- }
- rcu_assign_pointer(p->next, next);
- timer_setup(&p->timer, br_multicast_port_group_expired, 0);
- timer_setup(&p->rexmit_timer, br_multicast_port_group_rexmit, 0);
- hlist_add_head(&p->mglist, &port->mglist);
- if (src)
- memcpy(p->eth_addr, src, ETH_ALEN);
- else
- eth_broadcast_addr(p->eth_addr);
- return p;
- }
- void br_multicast_host_join(const struct net_bridge_mcast *brmctx,
- struct net_bridge_mdb_entry *mp, bool notify)
- {
- if (!mp->host_joined) {
- mp->host_joined = true;
- if (br_multicast_is_star_g(&mp->addr))
- br_multicast_star_g_host_state(mp);
- if (notify)
- br_mdb_notify(mp->br->dev, mp, NULL, RTM_NEWMDB);
- }
- if (br_group_is_l2(&mp->addr))
- return;
- mod_timer(&mp->timer, jiffies + brmctx->multicast_membership_interval);
- }
- void br_multicast_host_leave(struct net_bridge_mdb_entry *mp, bool notify)
- {
- if (!mp->host_joined)
- return;
- mp->host_joined = false;
- if (br_multicast_is_star_g(&mp->addr))
- br_multicast_star_g_host_state(mp);
- if (notify)
- br_mdb_notify(mp->br->dev, mp, NULL, RTM_DELMDB);
- }
- static struct net_bridge_port_group *
- __br_multicast_add_group(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct br_ip *group,
- const unsigned char *src,
- u8 filter_mode,
- bool igmpv2_mldv1,
- bool blocked)
- {
- struct net_bridge_port_group __rcu **pp;
- struct net_bridge_port_group *p = NULL;
- struct net_bridge_mdb_entry *mp;
- unsigned long now = jiffies;
- if (!br_multicast_ctx_should_use(brmctx, pmctx))
- goto out;
- mp = br_multicast_new_group(brmctx->br, group);
- if (IS_ERR(mp))
- return ERR_CAST(mp);
- if (!pmctx) {
- br_multicast_host_join(brmctx, mp, true);
- goto out;
- }
- for (pp = &mp->ports;
- (p = mlock_dereference(*pp, brmctx->br)) != NULL;
- pp = &p->next) {
- if (br_port_group_equal(p, pmctx->port, src))
- goto found;
- if ((unsigned long)p->key.port < (unsigned long)pmctx->port)
- break;
- }
- p = br_multicast_new_port_group(pmctx->port, group, *pp, 0, src,
- filter_mode, RTPROT_KERNEL);
- if (unlikely(!p)) {
- p = ERR_PTR(-ENOMEM);
- goto out;
- }
- rcu_assign_pointer(*pp, p);
- if (blocked)
- p->flags |= MDB_PG_FLAGS_BLOCKED;
- br_mdb_notify(brmctx->br->dev, mp, p, RTM_NEWMDB);
- found:
- if (igmpv2_mldv1)
- mod_timer(&p->timer,
- now + brmctx->multicast_membership_interval);
- out:
- return p;
- }
- static int br_multicast_add_group(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct br_ip *group,
- const unsigned char *src,
- u8 filter_mode,
- bool igmpv2_mldv1)
- {
- struct net_bridge_port_group *pg;
- int err;
- spin_lock(&brmctx->br->multicast_lock);
- pg = __br_multicast_add_group(brmctx, pmctx, group, src, filter_mode,
- igmpv2_mldv1, false);
- /* NULL is considered valid for host joined groups */
- err = PTR_ERR_OR_ZERO(pg);
- spin_unlock(&brmctx->br->multicast_lock);
- return err;
- }
- static int br_ip4_multicast_add_group(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- __be32 group,
- __u16 vid,
- const unsigned char *src,
- bool igmpv2)
- {
- struct br_ip br_group;
- u8 filter_mode;
- if (ipv4_is_local_multicast(group))
- return 0;
- memset(&br_group, 0, sizeof(br_group));
- br_group.dst.ip4 = group;
- br_group.proto = htons(ETH_P_IP);
- br_group.vid = vid;
- filter_mode = igmpv2 ? MCAST_EXCLUDE : MCAST_INCLUDE;
- return br_multicast_add_group(brmctx, pmctx, &br_group, src,
- filter_mode, igmpv2);
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static int br_ip6_multicast_add_group(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- const struct in6_addr *group,
- __u16 vid,
- const unsigned char *src,
- bool mldv1)
- {
- struct br_ip br_group;
- u8 filter_mode;
- if (ipv6_addr_is_ll_all_nodes(group))
- return 0;
- memset(&br_group, 0, sizeof(br_group));
- br_group.dst.ip6 = *group;
- br_group.proto = htons(ETH_P_IPV6);
- br_group.vid = vid;
- filter_mode = mldv1 ? MCAST_EXCLUDE : MCAST_INCLUDE;
- return br_multicast_add_group(brmctx, pmctx, &br_group, src,
- filter_mode, mldv1);
- }
- #endif
- static bool br_multicast_rport_del(struct hlist_node *rlist)
- {
- if (hlist_unhashed(rlist))
- return false;
- hlist_del_init_rcu(rlist);
- return true;
- }
- static bool br_ip4_multicast_rport_del(struct net_bridge_mcast_port *pmctx)
- {
- return br_multicast_rport_del(&pmctx->ip4_rlist);
- }
- static bool br_ip6_multicast_rport_del(struct net_bridge_mcast_port *pmctx)
- {
- #if IS_ENABLED(CONFIG_IPV6)
- return br_multicast_rport_del(&pmctx->ip6_rlist);
- #else
- return false;
- #endif
- }
- static void br_multicast_router_expired(struct net_bridge_mcast_port *pmctx,
- struct timer_list *t,
- struct hlist_node *rlist)
- {
- struct net_bridge *br = pmctx->port->br;
- bool del;
- spin_lock(&br->multicast_lock);
- if (pmctx->multicast_router == MDB_RTR_TYPE_DISABLED ||
- pmctx->multicast_router == MDB_RTR_TYPE_PERM ||
- timer_pending(t))
- goto out;
- del = br_multicast_rport_del(rlist);
- br_multicast_rport_del_notify(pmctx, del);
- out:
- spin_unlock(&br->multicast_lock);
- }
- static void br_ip4_multicast_router_expired(struct timer_list *t)
- {
- struct net_bridge_mcast_port *pmctx = from_timer(pmctx, t,
- ip4_mc_router_timer);
- br_multicast_router_expired(pmctx, t, &pmctx->ip4_rlist);
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static void br_ip6_multicast_router_expired(struct timer_list *t)
- {
- struct net_bridge_mcast_port *pmctx = from_timer(pmctx, t,
- ip6_mc_router_timer);
- br_multicast_router_expired(pmctx, t, &pmctx->ip6_rlist);
- }
- #endif
- static void br_mc_router_state_change(struct net_bridge *p,
- bool is_mc_router)
- {
- struct switchdev_attr attr = {
- .orig_dev = p->dev,
- .id = SWITCHDEV_ATTR_ID_BRIDGE_MROUTER,
- .flags = SWITCHDEV_F_DEFER,
- .u.mrouter = is_mc_router,
- };
- switchdev_port_attr_set(p->dev, &attr, NULL);
- }
- static void br_multicast_local_router_expired(struct net_bridge_mcast *brmctx,
- struct timer_list *timer)
- {
- spin_lock(&brmctx->br->multicast_lock);
- if (brmctx->multicast_router == MDB_RTR_TYPE_DISABLED ||
- brmctx->multicast_router == MDB_RTR_TYPE_PERM ||
- br_ip4_multicast_is_router(brmctx) ||
- br_ip6_multicast_is_router(brmctx))
- goto out;
- br_mc_router_state_change(brmctx->br, false);
- out:
- spin_unlock(&brmctx->br->multicast_lock);
- }
- static void br_ip4_multicast_local_router_expired(struct timer_list *t)
- {
- struct net_bridge_mcast *brmctx = from_timer(brmctx, t,
- ip4_mc_router_timer);
- br_multicast_local_router_expired(brmctx, t);
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static void br_ip6_multicast_local_router_expired(struct timer_list *t)
- {
- struct net_bridge_mcast *brmctx = from_timer(brmctx, t,
- ip6_mc_router_timer);
- br_multicast_local_router_expired(brmctx, t);
- }
- #endif
- static void br_multicast_querier_expired(struct net_bridge_mcast *brmctx,
- struct bridge_mcast_own_query *query)
- {
- spin_lock(&brmctx->br->multicast_lock);
- if (!netif_running(brmctx->br->dev) ||
- br_multicast_ctx_vlan_global_disabled(brmctx) ||
- !br_opt_get(brmctx->br, BROPT_MULTICAST_ENABLED))
- goto out;
- br_multicast_start_querier(brmctx, query);
- out:
- spin_unlock(&brmctx->br->multicast_lock);
- }
- static void br_ip4_multicast_querier_expired(struct timer_list *t)
- {
- struct net_bridge_mcast *brmctx = from_timer(brmctx, t,
- ip4_other_query.timer);
- br_multicast_querier_expired(brmctx, &brmctx->ip4_own_query);
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static void br_ip6_multicast_querier_expired(struct timer_list *t)
- {
- struct net_bridge_mcast *brmctx = from_timer(brmctx, t,
- ip6_other_query.timer);
- br_multicast_querier_expired(brmctx, &brmctx->ip6_own_query);
- }
- #endif
- static void br_multicast_select_own_querier(struct net_bridge_mcast *brmctx,
- struct br_ip *ip,
- struct sk_buff *skb)
- {
- if (ip->proto == htons(ETH_P_IP))
- brmctx->ip4_querier.addr.src.ip4 = ip_hdr(skb)->saddr;
- #if IS_ENABLED(CONFIG_IPV6)
- else
- brmctx->ip6_querier.addr.src.ip6 = ipv6_hdr(skb)->saddr;
- #endif
- }
- static void __br_multicast_send_query(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg,
- struct br_ip *ip_dst,
- struct br_ip *group,
- bool with_srcs,
- u8 sflag,
- bool *need_rexmit)
- {
- bool over_lmqt = !!sflag;
- struct sk_buff *skb;
- u8 igmp_type;
- if (!br_multicast_ctx_should_use(brmctx, pmctx) ||
- !br_multicast_ctx_matches_vlan_snooping(brmctx))
- return;
- again_under_lmqt:
- skb = br_multicast_alloc_query(brmctx, pmctx, pg, ip_dst, group,
- with_srcs, over_lmqt, sflag, &igmp_type,
- need_rexmit);
- if (!skb)
- return;
- if (pmctx) {
- skb->dev = pmctx->port->dev;
- br_multicast_count(brmctx->br, pmctx->port, skb, igmp_type,
- BR_MCAST_DIR_TX);
- NF_HOOK(NFPROTO_BRIDGE, NF_BR_LOCAL_OUT,
- dev_net(pmctx->port->dev), NULL, skb, NULL, skb->dev,
- br_dev_queue_push_xmit);
- if (over_lmqt && with_srcs && sflag) {
- over_lmqt = false;
- goto again_under_lmqt;
- }
- } else {
- br_multicast_select_own_querier(brmctx, group, skb);
- br_multicast_count(brmctx->br, NULL, skb, igmp_type,
- BR_MCAST_DIR_RX);
- netif_rx(skb);
- }
- }
- static void br_multicast_read_querier(const struct bridge_mcast_querier *querier,
- struct bridge_mcast_querier *dest)
- {
- unsigned int seq;
- memset(dest, 0, sizeof(*dest));
- do {
- seq = read_seqcount_begin(&querier->seq);
- dest->port_ifidx = querier->port_ifidx;
- memcpy(&dest->addr, &querier->addr, sizeof(struct br_ip));
- } while (read_seqcount_retry(&querier->seq, seq));
- }
- static void br_multicast_update_querier(struct net_bridge_mcast *brmctx,
- struct bridge_mcast_querier *querier,
- int ifindex,
- struct br_ip *saddr)
- {
- write_seqcount_begin(&querier->seq);
- querier->port_ifidx = ifindex;
- memcpy(&querier->addr, saddr, sizeof(*saddr));
- write_seqcount_end(&querier->seq);
- }
- static void br_multicast_send_query(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct bridge_mcast_own_query *own_query)
- {
- struct bridge_mcast_other_query *other_query = NULL;
- struct bridge_mcast_querier *querier;
- struct br_ip br_group;
- unsigned long time;
- if (!br_multicast_ctx_should_use(brmctx, pmctx) ||
- !br_opt_get(brmctx->br, BROPT_MULTICAST_ENABLED) ||
- !brmctx->multicast_querier)
- return;
- memset(&br_group.dst, 0, sizeof(br_group.dst));
- if (pmctx ? (own_query == &pmctx->ip4_own_query) :
- (own_query == &brmctx->ip4_own_query)) {
- querier = &brmctx->ip4_querier;
- other_query = &brmctx->ip4_other_query;
- br_group.proto = htons(ETH_P_IP);
- #if IS_ENABLED(CONFIG_IPV6)
- } else {
- querier = &brmctx->ip6_querier;
- other_query = &brmctx->ip6_other_query;
- br_group.proto = htons(ETH_P_IPV6);
- #endif
- }
- if (!other_query || timer_pending(&other_query->timer))
- return;
- /* we're about to select ourselves as querier */
- if (!pmctx && querier->port_ifidx) {
- struct br_ip zeroip = {};
- br_multicast_update_querier(brmctx, querier, 0, &zeroip);
- }
- __br_multicast_send_query(brmctx, pmctx, NULL, NULL, &br_group, false,
- 0, NULL);
- time = jiffies;
- time += own_query->startup_sent < brmctx->multicast_startup_query_count ?
- brmctx->multicast_startup_query_interval :
- brmctx->multicast_query_interval;
- mod_timer(&own_query->timer, time);
- }
- static void
- br_multicast_port_query_expired(struct net_bridge_mcast_port *pmctx,
- struct bridge_mcast_own_query *query)
- {
- struct net_bridge *br = pmctx->port->br;
- struct net_bridge_mcast *brmctx;
- spin_lock(&br->multicast_lock);
- if (br_multicast_port_ctx_state_stopped(pmctx))
- goto out;
- brmctx = br_multicast_port_ctx_get_global(pmctx);
- if (query->startup_sent < brmctx->multicast_startup_query_count)
- query->startup_sent++;
- br_multicast_send_query(brmctx, pmctx, query);
- out:
- spin_unlock(&br->multicast_lock);
- }
- static void br_ip4_multicast_port_query_expired(struct timer_list *t)
- {
- struct net_bridge_mcast_port *pmctx = from_timer(pmctx, t,
- ip4_own_query.timer);
- br_multicast_port_query_expired(pmctx, &pmctx->ip4_own_query);
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static void br_ip6_multicast_port_query_expired(struct timer_list *t)
- {
- struct net_bridge_mcast_port *pmctx = from_timer(pmctx, t,
- ip6_own_query.timer);
- br_multicast_port_query_expired(pmctx, &pmctx->ip6_own_query);
- }
- #endif
- static void br_multicast_port_group_rexmit(struct timer_list *t)
- {
- struct net_bridge_port_group *pg = from_timer(pg, t, rexmit_timer);
- struct bridge_mcast_other_query *other_query = NULL;
- struct net_bridge *br = pg->key.port->br;
- struct net_bridge_mcast_port *pmctx;
- struct net_bridge_mcast *brmctx;
- bool need_rexmit = false;
- spin_lock(&br->multicast_lock);
- if (!netif_running(br->dev) || hlist_unhashed(&pg->mglist) ||
- !br_opt_get(br, BROPT_MULTICAST_ENABLED))
- goto out;
- pmctx = br_multicast_pg_to_port_ctx(pg);
- if (!pmctx)
- goto out;
- brmctx = br_multicast_port_ctx_get_global(pmctx);
- if (!brmctx->multicast_querier)
- goto out;
- if (pg->key.addr.proto == htons(ETH_P_IP))
- other_query = &brmctx->ip4_other_query;
- #if IS_ENABLED(CONFIG_IPV6)
- else
- other_query = &brmctx->ip6_other_query;
- #endif
- if (!other_query || timer_pending(&other_query->timer))
- goto out;
- if (pg->grp_query_rexmit_cnt) {
- pg->grp_query_rexmit_cnt--;
- __br_multicast_send_query(brmctx, pmctx, pg, &pg->key.addr,
- &pg->key.addr, false, 1, NULL);
- }
- __br_multicast_send_query(brmctx, pmctx, pg, &pg->key.addr,
- &pg->key.addr, true, 0, &need_rexmit);
- if (pg->grp_query_rexmit_cnt || need_rexmit)
- mod_timer(&pg->rexmit_timer, jiffies +
- brmctx->multicast_last_member_interval);
- out:
- spin_unlock(&br->multicast_lock);
- }
- static int br_mc_disabled_update(struct net_device *dev, bool value,
- struct netlink_ext_ack *extack)
- {
- struct switchdev_attr attr = {
- .orig_dev = dev,
- .id = SWITCHDEV_ATTR_ID_BRIDGE_MC_DISABLED,
- .flags = SWITCHDEV_F_DEFER,
- .u.mc_disabled = !value,
- };
- return switchdev_port_attr_set(dev, &attr, extack);
- }
- void br_multicast_port_ctx_init(struct net_bridge_port *port,
- struct net_bridge_vlan *vlan,
- struct net_bridge_mcast_port *pmctx)
- {
- pmctx->port = port;
- pmctx->vlan = vlan;
- pmctx->multicast_router = MDB_RTR_TYPE_TEMP_QUERY;
- timer_setup(&pmctx->ip4_mc_router_timer,
- br_ip4_multicast_router_expired, 0);
- timer_setup(&pmctx->ip4_own_query.timer,
- br_ip4_multicast_port_query_expired, 0);
- #if IS_ENABLED(CONFIG_IPV6)
- timer_setup(&pmctx->ip6_mc_router_timer,
- br_ip6_multicast_router_expired, 0);
- timer_setup(&pmctx->ip6_own_query.timer,
- br_ip6_multicast_port_query_expired, 0);
- #endif
- }
- void br_multicast_port_ctx_deinit(struct net_bridge_mcast_port *pmctx)
- {
- #if IS_ENABLED(CONFIG_IPV6)
- del_timer_sync(&pmctx->ip6_mc_router_timer);
- #endif
- del_timer_sync(&pmctx->ip4_mc_router_timer);
- }
- int br_multicast_add_port(struct net_bridge_port *port)
- {
- int err;
- port->multicast_eht_hosts_limit = BR_MCAST_DEFAULT_EHT_HOSTS_LIMIT;
- br_multicast_port_ctx_init(port, NULL, &port->multicast_ctx);
- err = br_mc_disabled_update(port->dev,
- br_opt_get(port->br,
- BROPT_MULTICAST_ENABLED),
- NULL);
- if (err && err != -EOPNOTSUPP)
- return err;
- port->mcast_stats = netdev_alloc_pcpu_stats(struct bridge_mcast_stats);
- if (!port->mcast_stats)
- return -ENOMEM;
- return 0;
- }
- void br_multicast_del_port(struct net_bridge_port *port)
- {
- struct net_bridge *br = port->br;
- struct net_bridge_port_group *pg;
- HLIST_HEAD(deleted_head);
- struct hlist_node *n;
- /* Take care of the remaining groups, only perm ones should be left */
- spin_lock_bh(&br->multicast_lock);
- hlist_for_each_entry_safe(pg, n, &port->mglist, mglist)
- br_multicast_find_del_pg(br, pg);
- hlist_move_list(&br->mcast_gc_list, &deleted_head);
- spin_unlock_bh(&br->multicast_lock);
- br_multicast_gc(&deleted_head);
- br_multicast_port_ctx_deinit(&port->multicast_ctx);
- free_percpu(port->mcast_stats);
- }
- static void br_multicast_enable(struct bridge_mcast_own_query *query)
- {
- query->startup_sent = 0;
- if (try_to_del_timer_sync(&query->timer) >= 0 ||
- del_timer(&query->timer))
- mod_timer(&query->timer, jiffies);
- }
- static void __br_multicast_enable_port_ctx(struct net_bridge_mcast_port *pmctx)
- {
- struct net_bridge *br = pmctx->port->br;
- struct net_bridge_mcast *brmctx;
- brmctx = br_multicast_port_ctx_get_global(pmctx);
- if (!br_opt_get(br, BROPT_MULTICAST_ENABLED) ||
- !netif_running(br->dev))
- return;
- br_multicast_enable(&pmctx->ip4_own_query);
- #if IS_ENABLED(CONFIG_IPV6)
- br_multicast_enable(&pmctx->ip6_own_query);
- #endif
- if (pmctx->multicast_router == MDB_RTR_TYPE_PERM) {
- br_ip4_multicast_add_router(brmctx, pmctx);
- br_ip6_multicast_add_router(brmctx, pmctx);
- }
- }
- void br_multicast_enable_port(struct net_bridge_port *port)
- {
- struct net_bridge *br = port->br;
- spin_lock_bh(&br->multicast_lock);
- __br_multicast_enable_port_ctx(&port->multicast_ctx);
- spin_unlock_bh(&br->multicast_lock);
- }
- static void __br_multicast_disable_port_ctx(struct net_bridge_mcast_port *pmctx)
- {
- struct net_bridge_port_group *pg;
- struct hlist_node *n;
- bool del = false;
- hlist_for_each_entry_safe(pg, n, &pmctx->port->mglist, mglist)
- if (!(pg->flags & MDB_PG_FLAGS_PERMANENT) &&
- (!br_multicast_port_ctx_is_vlan(pmctx) ||
- pg->key.addr.vid == pmctx->vlan->vid))
- br_multicast_find_del_pg(pmctx->port->br, pg);
- del |= br_ip4_multicast_rport_del(pmctx);
- del_timer(&pmctx->ip4_mc_router_timer);
- del_timer(&pmctx->ip4_own_query.timer);
- del |= br_ip6_multicast_rport_del(pmctx);
- #if IS_ENABLED(CONFIG_IPV6)
- del_timer(&pmctx->ip6_mc_router_timer);
- del_timer(&pmctx->ip6_own_query.timer);
- #endif
- br_multicast_rport_del_notify(pmctx, del);
- }
- void br_multicast_disable_port(struct net_bridge_port *port)
- {
- spin_lock_bh(&port->br->multicast_lock);
- __br_multicast_disable_port_ctx(&port->multicast_ctx);
- spin_unlock_bh(&port->br->multicast_lock);
- }
- static int __grp_src_delete_marked(struct net_bridge_port_group *pg)
- {
- struct net_bridge_group_src *ent;
- struct hlist_node *tmp;
- int deleted = 0;
- hlist_for_each_entry_safe(ent, tmp, &pg->src_list, node)
- if (ent->flags & BR_SGRP_F_DELETE) {
- br_multicast_del_group_src(ent, false);
- deleted++;
- }
- return deleted;
- }
- static void __grp_src_mod_timer(struct net_bridge_group_src *src,
- unsigned long expires)
- {
- mod_timer(&src->timer, expires);
- br_multicast_fwd_src_handle(src);
- }
- static void __grp_src_query_marked_and_rexmit(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg)
- {
- struct bridge_mcast_other_query *other_query = NULL;
- u32 lmqc = brmctx->multicast_last_member_count;
- unsigned long lmqt, lmi, now = jiffies;
- struct net_bridge_group_src *ent;
- if (!netif_running(brmctx->br->dev) ||
- !br_opt_get(brmctx->br, BROPT_MULTICAST_ENABLED))
- return;
- if (pg->key.addr.proto == htons(ETH_P_IP))
- other_query = &brmctx->ip4_other_query;
- #if IS_ENABLED(CONFIG_IPV6)
- else
- other_query = &brmctx->ip6_other_query;
- #endif
- lmqt = now + br_multicast_lmqt(brmctx);
- hlist_for_each_entry(ent, &pg->src_list, node) {
- if (ent->flags & BR_SGRP_F_SEND) {
- ent->flags &= ~BR_SGRP_F_SEND;
- if (ent->timer.expires > lmqt) {
- if (brmctx->multicast_querier &&
- other_query &&
- !timer_pending(&other_query->timer))
- ent->src_query_rexmit_cnt = lmqc;
- __grp_src_mod_timer(ent, lmqt);
- }
- }
- }
- if (!brmctx->multicast_querier ||
- !other_query || timer_pending(&other_query->timer))
- return;
- __br_multicast_send_query(brmctx, pmctx, pg, &pg->key.addr,
- &pg->key.addr, true, 1, NULL);
- lmi = now + brmctx->multicast_last_member_interval;
- if (!timer_pending(&pg->rexmit_timer) ||
- time_after(pg->rexmit_timer.expires, lmi))
- mod_timer(&pg->rexmit_timer, lmi);
- }
- static void __grp_send_query_and_rexmit(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg)
- {
- struct bridge_mcast_other_query *other_query = NULL;
- unsigned long now = jiffies, lmi;
- if (!netif_running(brmctx->br->dev) ||
- !br_opt_get(brmctx->br, BROPT_MULTICAST_ENABLED))
- return;
- if (pg->key.addr.proto == htons(ETH_P_IP))
- other_query = &brmctx->ip4_other_query;
- #if IS_ENABLED(CONFIG_IPV6)
- else
- other_query = &brmctx->ip6_other_query;
- #endif
- if (brmctx->multicast_querier &&
- other_query && !timer_pending(&other_query->timer)) {
- lmi = now + brmctx->multicast_last_member_interval;
- pg->grp_query_rexmit_cnt = brmctx->multicast_last_member_count - 1;
- __br_multicast_send_query(brmctx, pmctx, pg, &pg->key.addr,
- &pg->key.addr, false, 0, NULL);
- if (!timer_pending(&pg->rexmit_timer) ||
- time_after(pg->rexmit_timer.expires, lmi))
- mod_timer(&pg->rexmit_timer, lmi);
- }
- if (pg->filter_mode == MCAST_EXCLUDE &&
- (!timer_pending(&pg->timer) ||
- time_after(pg->timer.expires, now + br_multicast_lmqt(brmctx))))
- mod_timer(&pg->timer, now + br_multicast_lmqt(brmctx));
- }
- /* State Msg type New state Actions
- * INCLUDE (A) IS_IN (B) INCLUDE (A+B) (B)=GMI
- * INCLUDE (A) ALLOW (B) INCLUDE (A+B) (B)=GMI
- * EXCLUDE (X,Y) ALLOW (A) EXCLUDE (X+A,Y-A) (A)=GMI
- */
- static bool br_multicast_isinc_allow(const struct net_bridge_mcast *brmctx,
- struct net_bridge_port_group *pg, void *h_addr,
- void *srcs, u32 nsrcs, size_t addr_size,
- int grec_type)
- {
- struct net_bridge_group_src *ent;
- unsigned long now = jiffies;
- bool changed = false;
- struct br_ip src_ip;
- u32 src_idx;
- memset(&src_ip, 0, sizeof(src_ip));
- src_ip.proto = pg->key.addr.proto;
- for (src_idx = 0; src_idx < nsrcs; src_idx++) {
- memcpy(&src_ip.src, srcs + (src_idx * addr_size), addr_size);
- ent = br_multicast_find_group_src(pg, &src_ip);
- if (!ent) {
- ent = br_multicast_new_group_src(pg, &src_ip);
- if (ent)
- changed = true;
- }
- if (ent)
- __grp_src_mod_timer(ent, now + br_multicast_gmi(brmctx));
- }
- if (br_multicast_eht_handle(brmctx, pg, h_addr, srcs, nsrcs, addr_size,
- grec_type))
- changed = true;
- return changed;
- }
- /* State Msg type New state Actions
- * INCLUDE (A) IS_EX (B) EXCLUDE (A*B,B-A) (B-A)=0
- * Delete (A-B)
- * Group Timer=GMI
- */
- static void __grp_src_isexc_incl(const struct net_bridge_mcast *brmctx,
- struct net_bridge_port_group *pg, void *h_addr,
- void *srcs, u32 nsrcs, size_t addr_size,
- int grec_type)
- {
- struct net_bridge_group_src *ent;
- struct br_ip src_ip;
- u32 src_idx;
- hlist_for_each_entry(ent, &pg->src_list, node)
- ent->flags |= BR_SGRP_F_DELETE;
- memset(&src_ip, 0, sizeof(src_ip));
- src_ip.proto = pg->key.addr.proto;
- for (src_idx = 0; src_idx < nsrcs; src_idx++) {
- memcpy(&src_ip.src, srcs + (src_idx * addr_size), addr_size);
- ent = br_multicast_find_group_src(pg, &src_ip);
- if (ent)
- ent->flags &= ~BR_SGRP_F_DELETE;
- else
- ent = br_multicast_new_group_src(pg, &src_ip);
- if (ent)
- br_multicast_fwd_src_handle(ent);
- }
- br_multicast_eht_handle(brmctx, pg, h_addr, srcs, nsrcs, addr_size,
- grec_type);
- __grp_src_delete_marked(pg);
- }
- /* State Msg type New state Actions
- * EXCLUDE (X,Y) IS_EX (A) EXCLUDE (A-Y,Y*A) (A-X-Y)=GMI
- * Delete (X-A)
- * Delete (Y-A)
- * Group Timer=GMI
- */
- static bool __grp_src_isexc_excl(const struct net_bridge_mcast *brmctx,
- struct net_bridge_port_group *pg, void *h_addr,
- void *srcs, u32 nsrcs, size_t addr_size,
- int grec_type)
- {
- struct net_bridge_group_src *ent;
- unsigned long now = jiffies;
- bool changed = false;
- struct br_ip src_ip;
- u32 src_idx;
- hlist_for_each_entry(ent, &pg->src_list, node)
- ent->flags |= BR_SGRP_F_DELETE;
- memset(&src_ip, 0, sizeof(src_ip));
- src_ip.proto = pg->key.addr.proto;
- for (src_idx = 0; src_idx < nsrcs; src_idx++) {
- memcpy(&src_ip.src, srcs + (src_idx * addr_size), addr_size);
- ent = br_multicast_find_group_src(pg, &src_ip);
- if (ent) {
- ent->flags &= ~BR_SGRP_F_DELETE;
- } else {
- ent = br_multicast_new_group_src(pg, &src_ip);
- if (ent) {
- __grp_src_mod_timer(ent,
- now + br_multicast_gmi(brmctx));
- changed = true;
- }
- }
- }
- if (br_multicast_eht_handle(brmctx, pg, h_addr, srcs, nsrcs, addr_size,
- grec_type))
- changed = true;
- if (__grp_src_delete_marked(pg))
- changed = true;
- return changed;
- }
- static bool br_multicast_isexc(const struct net_bridge_mcast *brmctx,
- struct net_bridge_port_group *pg, void *h_addr,
- void *srcs, u32 nsrcs, size_t addr_size,
- int grec_type)
- {
- bool changed = false;
- switch (pg->filter_mode) {
- case MCAST_INCLUDE:
- __grp_src_isexc_incl(brmctx, pg, h_addr, srcs, nsrcs, addr_size,
- grec_type);
- br_multicast_star_g_handle_mode(pg, MCAST_EXCLUDE);
- changed = true;
- break;
- case MCAST_EXCLUDE:
- changed = __grp_src_isexc_excl(brmctx, pg, h_addr, srcs, nsrcs,
- addr_size, grec_type);
- break;
- }
- pg->filter_mode = MCAST_EXCLUDE;
- mod_timer(&pg->timer, jiffies + br_multicast_gmi(brmctx));
- return changed;
- }
- /* State Msg type New state Actions
- * INCLUDE (A) TO_IN (B) INCLUDE (A+B) (B)=GMI
- * Send Q(G,A-B)
- */
- static bool __grp_src_toin_incl(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg, void *h_addr,
- void *srcs, u32 nsrcs, size_t addr_size,
- int grec_type)
- {
- u32 src_idx, to_send = pg->src_ents;
- struct net_bridge_group_src *ent;
- unsigned long now = jiffies;
- bool changed = false;
- struct br_ip src_ip;
- hlist_for_each_entry(ent, &pg->src_list, node)
- ent->flags |= BR_SGRP_F_SEND;
- memset(&src_ip, 0, sizeof(src_ip));
- src_ip.proto = pg->key.addr.proto;
- for (src_idx = 0; src_idx < nsrcs; src_idx++) {
- memcpy(&src_ip.src, srcs + (src_idx * addr_size), addr_size);
- ent = br_multicast_find_group_src(pg, &src_ip);
- if (ent) {
- ent->flags &= ~BR_SGRP_F_SEND;
- to_send--;
- } else {
- ent = br_multicast_new_group_src(pg, &src_ip);
- if (ent)
- changed = true;
- }
- if (ent)
- __grp_src_mod_timer(ent, now + br_multicast_gmi(brmctx));
- }
- if (br_multicast_eht_handle(brmctx, pg, h_addr, srcs, nsrcs, addr_size,
- grec_type))
- changed = true;
- if (to_send)
- __grp_src_query_marked_and_rexmit(brmctx, pmctx, pg);
- return changed;
- }
- /* State Msg type New state Actions
- * EXCLUDE (X,Y) TO_IN (A) EXCLUDE (X+A,Y-A) (A)=GMI
- * Send Q(G,X-A)
- * Send Q(G)
- */
- static bool __grp_src_toin_excl(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg, void *h_addr,
- void *srcs, u32 nsrcs, size_t addr_size,
- int grec_type)
- {
- u32 src_idx, to_send = pg->src_ents;
- struct net_bridge_group_src *ent;
- unsigned long now = jiffies;
- bool changed = false;
- struct br_ip src_ip;
- hlist_for_each_entry(ent, &pg->src_list, node)
- if (timer_pending(&ent->timer))
- ent->flags |= BR_SGRP_F_SEND;
- memset(&src_ip, 0, sizeof(src_ip));
- src_ip.proto = pg->key.addr.proto;
- for (src_idx = 0; src_idx < nsrcs; src_idx++) {
- memcpy(&src_ip.src, srcs + (src_idx * addr_size), addr_size);
- ent = br_multicast_find_group_src(pg, &src_ip);
- if (ent) {
- if (timer_pending(&ent->timer)) {
- ent->flags &= ~BR_SGRP_F_SEND;
- to_send--;
- }
- } else {
- ent = br_multicast_new_group_src(pg, &src_ip);
- if (ent)
- changed = true;
- }
- if (ent)
- __grp_src_mod_timer(ent, now + br_multicast_gmi(brmctx));
- }
- if (br_multicast_eht_handle(brmctx, pg, h_addr, srcs, nsrcs, addr_size,
- grec_type))
- changed = true;
- if (to_send)
- __grp_src_query_marked_and_rexmit(brmctx, pmctx, pg);
- __grp_send_query_and_rexmit(brmctx, pmctx, pg);
- return changed;
- }
- static bool br_multicast_toin(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg, void *h_addr,
- void *srcs, u32 nsrcs, size_t addr_size,
- int grec_type)
- {
- bool changed = false;
- switch (pg->filter_mode) {
- case MCAST_INCLUDE:
- changed = __grp_src_toin_incl(brmctx, pmctx, pg, h_addr, srcs,
- nsrcs, addr_size, grec_type);
- break;
- case MCAST_EXCLUDE:
- changed = __grp_src_toin_excl(brmctx, pmctx, pg, h_addr, srcs,
- nsrcs, addr_size, grec_type);
- break;
- }
- if (br_multicast_eht_should_del_pg(pg)) {
- pg->flags |= MDB_PG_FLAGS_FAST_LEAVE;
- br_multicast_find_del_pg(pg->key.port->br, pg);
- /* a notification has already been sent and we shouldn't
- * access pg after the delete so we have to return false
- */
- changed = false;
- }
- return changed;
- }
- /* State Msg type New state Actions
- * INCLUDE (A) TO_EX (B) EXCLUDE (A*B,B-A) (B-A)=0
- * Delete (A-B)
- * Send Q(G,A*B)
- * Group Timer=GMI
- */
- static void __grp_src_toex_incl(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg, void *h_addr,
- void *srcs, u32 nsrcs, size_t addr_size,
- int grec_type)
- {
- struct net_bridge_group_src *ent;
- u32 src_idx, to_send = 0;
- struct br_ip src_ip;
- hlist_for_each_entry(ent, &pg->src_list, node)
- ent->flags = (ent->flags & ~BR_SGRP_F_SEND) | BR_SGRP_F_DELETE;
- memset(&src_ip, 0, sizeof(src_ip));
- src_ip.proto = pg->key.addr.proto;
- for (src_idx = 0; src_idx < nsrcs; src_idx++) {
- memcpy(&src_ip.src, srcs + (src_idx * addr_size), addr_size);
- ent = br_multicast_find_group_src(pg, &src_ip);
- if (ent) {
- ent->flags = (ent->flags & ~BR_SGRP_F_DELETE) |
- BR_SGRP_F_SEND;
- to_send++;
- } else {
- ent = br_multicast_new_group_src(pg, &src_ip);
- }
- if (ent)
- br_multicast_fwd_src_handle(ent);
- }
- br_multicast_eht_handle(brmctx, pg, h_addr, srcs, nsrcs, addr_size,
- grec_type);
- __grp_src_delete_marked(pg);
- if (to_send)
- __grp_src_query_marked_and_rexmit(brmctx, pmctx, pg);
- }
- /* State Msg type New state Actions
- * EXCLUDE (X,Y) TO_EX (A) EXCLUDE (A-Y,Y*A) (A-X-Y)=Group Timer
- * Delete (X-A)
- * Delete (Y-A)
- * Send Q(G,A-Y)
- * Group Timer=GMI
- */
- static bool __grp_src_toex_excl(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg, void *h_addr,
- void *srcs, u32 nsrcs, size_t addr_size,
- int grec_type)
- {
- struct net_bridge_group_src *ent;
- u32 src_idx, to_send = 0;
- bool changed = false;
- struct br_ip src_ip;
- hlist_for_each_entry(ent, &pg->src_list, node)
- ent->flags = (ent->flags & ~BR_SGRP_F_SEND) | BR_SGRP_F_DELETE;
- memset(&src_ip, 0, sizeof(src_ip));
- src_ip.proto = pg->key.addr.proto;
- for (src_idx = 0; src_idx < nsrcs; src_idx++) {
- memcpy(&src_ip.src, srcs + (src_idx * addr_size), addr_size);
- ent = br_multicast_find_group_src(pg, &src_ip);
- if (ent) {
- ent->flags &= ~BR_SGRP_F_DELETE;
- } else {
- ent = br_multicast_new_group_src(pg, &src_ip);
- if (ent) {
- __grp_src_mod_timer(ent, pg->timer.expires);
- changed = true;
- }
- }
- if (ent && timer_pending(&ent->timer)) {
- ent->flags |= BR_SGRP_F_SEND;
- to_send++;
- }
- }
- if (br_multicast_eht_handle(brmctx, pg, h_addr, srcs, nsrcs, addr_size,
- grec_type))
- changed = true;
- if (__grp_src_delete_marked(pg))
- changed = true;
- if (to_send)
- __grp_src_query_marked_and_rexmit(brmctx, pmctx, pg);
- return changed;
- }
- static bool br_multicast_toex(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg, void *h_addr,
- void *srcs, u32 nsrcs, size_t addr_size,
- int grec_type)
- {
- bool changed = false;
- switch (pg->filter_mode) {
- case MCAST_INCLUDE:
- __grp_src_toex_incl(brmctx, pmctx, pg, h_addr, srcs, nsrcs,
- addr_size, grec_type);
- br_multicast_star_g_handle_mode(pg, MCAST_EXCLUDE);
- changed = true;
- break;
- case MCAST_EXCLUDE:
- changed = __grp_src_toex_excl(brmctx, pmctx, pg, h_addr, srcs,
- nsrcs, addr_size, grec_type);
- break;
- }
- pg->filter_mode = MCAST_EXCLUDE;
- mod_timer(&pg->timer, jiffies + br_multicast_gmi(brmctx));
- return changed;
- }
- /* State Msg type New state Actions
- * INCLUDE (A) BLOCK (B) INCLUDE (A) Send Q(G,A*B)
- */
- static bool __grp_src_block_incl(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg, void *h_addr,
- void *srcs, u32 nsrcs, size_t addr_size, int grec_type)
- {
- struct net_bridge_group_src *ent;
- u32 src_idx, to_send = 0;
- bool changed = false;
- struct br_ip src_ip;
- hlist_for_each_entry(ent, &pg->src_list, node)
- ent->flags &= ~BR_SGRP_F_SEND;
- memset(&src_ip, 0, sizeof(src_ip));
- src_ip.proto = pg->key.addr.proto;
- for (src_idx = 0; src_idx < nsrcs; src_idx++) {
- memcpy(&src_ip.src, srcs + (src_idx * addr_size), addr_size);
- ent = br_multicast_find_group_src(pg, &src_ip);
- if (ent) {
- ent->flags |= BR_SGRP_F_SEND;
- to_send++;
- }
- }
- if (br_multicast_eht_handle(brmctx, pg, h_addr, srcs, nsrcs, addr_size,
- grec_type))
- changed = true;
- if (to_send)
- __grp_src_query_marked_and_rexmit(brmctx, pmctx, pg);
- return changed;
- }
- /* State Msg type New state Actions
- * EXCLUDE (X,Y) BLOCK (A) EXCLUDE (X+(A-Y),Y) (A-X-Y)=Group Timer
- * Send Q(G,A-Y)
- */
- static bool __grp_src_block_excl(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg, void *h_addr,
- void *srcs, u32 nsrcs, size_t addr_size, int grec_type)
- {
- struct net_bridge_group_src *ent;
- u32 src_idx, to_send = 0;
- bool changed = false;
- struct br_ip src_ip;
- hlist_for_each_entry(ent, &pg->src_list, node)
- ent->flags &= ~BR_SGRP_F_SEND;
- memset(&src_ip, 0, sizeof(src_ip));
- src_ip.proto = pg->key.addr.proto;
- for (src_idx = 0; src_idx < nsrcs; src_idx++) {
- memcpy(&src_ip.src, srcs + (src_idx * addr_size), addr_size);
- ent = br_multicast_find_group_src(pg, &src_ip);
- if (!ent) {
- ent = br_multicast_new_group_src(pg, &src_ip);
- if (ent) {
- __grp_src_mod_timer(ent, pg->timer.expires);
- changed = true;
- }
- }
- if (ent && timer_pending(&ent->timer)) {
- ent->flags |= BR_SGRP_F_SEND;
- to_send++;
- }
- }
- if (br_multicast_eht_handle(brmctx, pg, h_addr, srcs, nsrcs, addr_size,
- grec_type))
- changed = true;
- if (to_send)
- __grp_src_query_marked_and_rexmit(brmctx, pmctx, pg);
- return changed;
- }
- static bool br_multicast_block(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct net_bridge_port_group *pg, void *h_addr,
- void *srcs, u32 nsrcs, size_t addr_size, int grec_type)
- {
- bool changed = false;
- switch (pg->filter_mode) {
- case MCAST_INCLUDE:
- changed = __grp_src_block_incl(brmctx, pmctx, pg, h_addr, srcs,
- nsrcs, addr_size, grec_type);
- break;
- case MCAST_EXCLUDE:
- changed = __grp_src_block_excl(brmctx, pmctx, pg, h_addr, srcs,
- nsrcs, addr_size, grec_type);
- break;
- }
- if ((pg->filter_mode == MCAST_INCLUDE && hlist_empty(&pg->src_list)) ||
- br_multicast_eht_should_del_pg(pg)) {
- if (br_multicast_eht_should_del_pg(pg))
- pg->flags |= MDB_PG_FLAGS_FAST_LEAVE;
- br_multicast_find_del_pg(pg->key.port->br, pg);
- /* a notification has already been sent and we shouldn't
- * access pg after the delete so we have to return false
- */
- changed = false;
- }
- return changed;
- }
- static struct net_bridge_port_group *
- br_multicast_find_port(struct net_bridge_mdb_entry *mp,
- struct net_bridge_port *p,
- const unsigned char *src)
- {
- struct net_bridge *br __maybe_unused = mp->br;
- struct net_bridge_port_group *pg;
- for (pg = mlock_dereference(mp->ports, br);
- pg;
- pg = mlock_dereference(pg->next, br))
- if (br_port_group_equal(pg, p, src))
- return pg;
- return NULL;
- }
- static int br_ip4_multicast_igmp3_report(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct sk_buff *skb,
- u16 vid)
- {
- bool igmpv2 = brmctx->multicast_igmp_version == 2;
- struct net_bridge_mdb_entry *mdst;
- struct net_bridge_port_group *pg;
- const unsigned char *src;
- struct igmpv3_report *ih;
- struct igmpv3_grec *grec;
- int i, len, num, type;
- __be32 group, *h_addr;
- bool changed = false;
- int err = 0;
- u16 nsrcs;
- ih = igmpv3_report_hdr(skb);
- num = ntohs(ih->ngrec);
- len = skb_transport_offset(skb) + sizeof(*ih);
- for (i = 0; i < num; i++) {
- len += sizeof(*grec);
- if (!ip_mc_may_pull(skb, len))
- return -EINVAL;
- grec = (void *)(skb->data + len - sizeof(*grec));
- group = grec->grec_mca;
- type = grec->grec_type;
- nsrcs = ntohs(grec->grec_nsrcs);
- len += nsrcs * 4;
- if (!ip_mc_may_pull(skb, len))
- return -EINVAL;
- switch (type) {
- case IGMPV3_MODE_IS_INCLUDE:
- case IGMPV3_MODE_IS_EXCLUDE:
- case IGMPV3_CHANGE_TO_INCLUDE:
- case IGMPV3_CHANGE_TO_EXCLUDE:
- case IGMPV3_ALLOW_NEW_SOURCES:
- case IGMPV3_BLOCK_OLD_SOURCES:
- break;
- default:
- continue;
- }
- src = eth_hdr(skb)->h_source;
- if (nsrcs == 0 &&
- (type == IGMPV3_CHANGE_TO_INCLUDE ||
- type == IGMPV3_MODE_IS_INCLUDE)) {
- if (!pmctx || igmpv2) {
- br_ip4_multicast_leave_group(brmctx, pmctx,
- group, vid, src);
- continue;
- }
- } else {
- err = br_ip4_multicast_add_group(brmctx, pmctx, group,
- vid, src, igmpv2);
- if (err)
- break;
- }
- if (!pmctx || igmpv2)
- continue;
- spin_lock_bh(&brmctx->br->multicast_lock);
- if (!br_multicast_ctx_should_use(brmctx, pmctx))
- goto unlock_continue;
- mdst = br_mdb_ip4_get(brmctx->br, group, vid);
- if (!mdst)
- goto unlock_continue;
- pg = br_multicast_find_port(mdst, pmctx->port, src);
- if (!pg || (pg->flags & MDB_PG_FLAGS_PERMANENT))
- goto unlock_continue;
- /* reload grec and host addr */
- grec = (void *)(skb->data + len - sizeof(*grec) - (nsrcs * 4));
- h_addr = &ip_hdr(skb)->saddr;
- switch (type) {
- case IGMPV3_ALLOW_NEW_SOURCES:
- changed = br_multicast_isinc_allow(brmctx, pg, h_addr,
- grec->grec_src,
- nsrcs, sizeof(__be32), type);
- break;
- case IGMPV3_MODE_IS_INCLUDE:
- changed = br_multicast_isinc_allow(brmctx, pg, h_addr,
- grec->grec_src,
- nsrcs, sizeof(__be32), type);
- break;
- case IGMPV3_MODE_IS_EXCLUDE:
- changed = br_multicast_isexc(brmctx, pg, h_addr,
- grec->grec_src,
- nsrcs, sizeof(__be32), type);
- break;
- case IGMPV3_CHANGE_TO_INCLUDE:
- changed = br_multicast_toin(brmctx, pmctx, pg, h_addr,
- grec->grec_src,
- nsrcs, sizeof(__be32), type);
- break;
- case IGMPV3_CHANGE_TO_EXCLUDE:
- changed = br_multicast_toex(brmctx, pmctx, pg, h_addr,
- grec->grec_src,
- nsrcs, sizeof(__be32), type);
- break;
- case IGMPV3_BLOCK_OLD_SOURCES:
- changed = br_multicast_block(brmctx, pmctx, pg, h_addr,
- grec->grec_src,
- nsrcs, sizeof(__be32), type);
- break;
- }
- if (changed)
- br_mdb_notify(brmctx->br->dev, mdst, pg, RTM_NEWMDB);
- unlock_continue:
- spin_unlock_bh(&brmctx->br->multicast_lock);
- }
- return err;
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static int br_ip6_multicast_mld2_report(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct sk_buff *skb,
- u16 vid)
- {
- bool mldv1 = brmctx->multicast_mld_version == 1;
- struct net_bridge_mdb_entry *mdst;
- struct net_bridge_port_group *pg;
- unsigned int nsrcs_offset;
- struct mld2_report *mld2r;
- const unsigned char *src;
- struct in6_addr *h_addr;
- struct mld2_grec *grec;
- unsigned int grec_len;
- bool changed = false;
- int i, len, num;
- int err = 0;
- if (!ipv6_mc_may_pull(skb, sizeof(*mld2r)))
- return -EINVAL;
- mld2r = (struct mld2_report *)icmp6_hdr(skb);
- num = ntohs(mld2r->mld2r_ngrec);
- len = skb_transport_offset(skb) + sizeof(*mld2r);
- for (i = 0; i < num; i++) {
- __be16 *_nsrcs, __nsrcs;
- u16 nsrcs;
- nsrcs_offset = len + offsetof(struct mld2_grec, grec_nsrcs);
- if (skb_transport_offset(skb) + ipv6_transport_len(skb) <
- nsrcs_offset + sizeof(__nsrcs))
- return -EINVAL;
- _nsrcs = skb_header_pointer(skb, nsrcs_offset,
- sizeof(__nsrcs), &__nsrcs);
- if (!_nsrcs)
- return -EINVAL;
- nsrcs = ntohs(*_nsrcs);
- grec_len = struct_size(grec, grec_src, nsrcs);
- if (!ipv6_mc_may_pull(skb, len + grec_len))
- return -EINVAL;
- grec = (struct mld2_grec *)(skb->data + len);
- len += grec_len;
- switch (grec->grec_type) {
- case MLD2_MODE_IS_INCLUDE:
- case MLD2_MODE_IS_EXCLUDE:
- case MLD2_CHANGE_TO_INCLUDE:
- case MLD2_CHANGE_TO_EXCLUDE:
- case MLD2_ALLOW_NEW_SOURCES:
- case MLD2_BLOCK_OLD_SOURCES:
- break;
- default:
- continue;
- }
- src = eth_hdr(skb)->h_source;
- if ((grec->grec_type == MLD2_CHANGE_TO_INCLUDE ||
- grec->grec_type == MLD2_MODE_IS_INCLUDE) &&
- nsrcs == 0) {
- if (!pmctx || mldv1) {
- br_ip6_multicast_leave_group(brmctx, pmctx,
- &grec->grec_mca,
- vid, src);
- continue;
- }
- } else {
- err = br_ip6_multicast_add_group(brmctx, pmctx,
- &grec->grec_mca, vid,
- src, mldv1);
- if (err)
- break;
- }
- if (!pmctx || mldv1)
- continue;
- spin_lock_bh(&brmctx->br->multicast_lock);
- if (!br_multicast_ctx_should_use(brmctx, pmctx))
- goto unlock_continue;
- mdst = br_mdb_ip6_get(brmctx->br, &grec->grec_mca, vid);
- if (!mdst)
- goto unlock_continue;
- pg = br_multicast_find_port(mdst, pmctx->port, src);
- if (!pg || (pg->flags & MDB_PG_FLAGS_PERMANENT))
- goto unlock_continue;
- h_addr = &ipv6_hdr(skb)->saddr;
- switch (grec->grec_type) {
- case MLD2_ALLOW_NEW_SOURCES:
- changed = br_multicast_isinc_allow(brmctx, pg, h_addr,
- grec->grec_src, nsrcs,
- sizeof(struct in6_addr),
- grec->grec_type);
- break;
- case MLD2_MODE_IS_INCLUDE:
- changed = br_multicast_isinc_allow(brmctx, pg, h_addr,
- grec->grec_src, nsrcs,
- sizeof(struct in6_addr),
- grec->grec_type);
- break;
- case MLD2_MODE_IS_EXCLUDE:
- changed = br_multicast_isexc(brmctx, pg, h_addr,
- grec->grec_src, nsrcs,
- sizeof(struct in6_addr),
- grec->grec_type);
- break;
- case MLD2_CHANGE_TO_INCLUDE:
- changed = br_multicast_toin(brmctx, pmctx, pg, h_addr,
- grec->grec_src, nsrcs,
- sizeof(struct in6_addr),
- grec->grec_type);
- break;
- case MLD2_CHANGE_TO_EXCLUDE:
- changed = br_multicast_toex(brmctx, pmctx, pg, h_addr,
- grec->grec_src, nsrcs,
- sizeof(struct in6_addr),
- grec->grec_type);
- break;
- case MLD2_BLOCK_OLD_SOURCES:
- changed = br_multicast_block(brmctx, pmctx, pg, h_addr,
- grec->grec_src, nsrcs,
- sizeof(struct in6_addr),
- grec->grec_type);
- break;
- }
- if (changed)
- br_mdb_notify(brmctx->br->dev, mdst, pg, RTM_NEWMDB);
- unlock_continue:
- spin_unlock_bh(&brmctx->br->multicast_lock);
- }
- return err;
- }
- #endif
- static bool br_multicast_select_querier(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct br_ip *saddr)
- {
- int port_ifidx = pmctx ? pmctx->port->dev->ifindex : 0;
- struct timer_list *own_timer, *other_timer;
- struct bridge_mcast_querier *querier;
- switch (saddr->proto) {
- case htons(ETH_P_IP):
- querier = &brmctx->ip4_querier;
- own_timer = &brmctx->ip4_own_query.timer;
- other_timer = &brmctx->ip4_other_query.timer;
- if (!querier->addr.src.ip4 ||
- ntohl(saddr->src.ip4) <= ntohl(querier->addr.src.ip4))
- goto update;
- break;
- #if IS_ENABLED(CONFIG_IPV6)
- case htons(ETH_P_IPV6):
- querier = &brmctx->ip6_querier;
- own_timer = &brmctx->ip6_own_query.timer;
- other_timer = &brmctx->ip6_other_query.timer;
- if (ipv6_addr_cmp(&saddr->src.ip6, &querier->addr.src.ip6) <= 0)
- goto update;
- break;
- #endif
- default:
- return false;
- }
- if (!timer_pending(own_timer) && !timer_pending(other_timer))
- goto update;
- return false;
- update:
- br_multicast_update_querier(brmctx, querier, port_ifidx, saddr);
- return true;
- }
- static struct net_bridge_port *
- __br_multicast_get_querier_port(struct net_bridge *br,
- const struct bridge_mcast_querier *querier)
- {
- int port_ifidx = READ_ONCE(querier->port_ifidx);
- struct net_bridge_port *p;
- struct net_device *dev;
- if (port_ifidx == 0)
- return NULL;
- dev = dev_get_by_index_rcu(dev_net(br->dev), port_ifidx);
- if (!dev)
- return NULL;
- p = br_port_get_rtnl_rcu(dev);
- if (!p || p->br != br)
- return NULL;
- return p;
- }
- size_t br_multicast_querier_state_size(void)
- {
- return nla_total_size(0) + /* nest attribute */
- nla_total_size(sizeof(__be32)) + /* BRIDGE_QUERIER_IP_ADDRESS */
- nla_total_size(sizeof(int)) + /* BRIDGE_QUERIER_IP_PORT */
- nla_total_size_64bit(sizeof(u64)) + /* BRIDGE_QUERIER_IP_OTHER_TIMER */
- #if IS_ENABLED(CONFIG_IPV6)
- nla_total_size(sizeof(struct in6_addr)) + /* BRIDGE_QUERIER_IPV6_ADDRESS */
- nla_total_size(sizeof(int)) + /* BRIDGE_QUERIER_IPV6_PORT */
- nla_total_size_64bit(sizeof(u64)) + /* BRIDGE_QUERIER_IPV6_OTHER_TIMER */
- #endif
- 0;
- }
- /* protected by rtnl or rcu */
- int br_multicast_dump_querier_state(struct sk_buff *skb,
- const struct net_bridge_mcast *brmctx,
- int nest_attr)
- {
- struct bridge_mcast_querier querier = {};
- struct net_bridge_port *p;
- struct nlattr *nest;
- if (!br_opt_get(brmctx->br, BROPT_MULTICAST_ENABLED) ||
- br_multicast_ctx_vlan_global_disabled(brmctx))
- return 0;
- nest = nla_nest_start(skb, nest_attr);
- if (!nest)
- return -EMSGSIZE;
- rcu_read_lock();
- if (!brmctx->multicast_querier &&
- !timer_pending(&brmctx->ip4_other_query.timer))
- goto out_v6;
- br_multicast_read_querier(&brmctx->ip4_querier, &querier);
- if (nla_put_in_addr(skb, BRIDGE_QUERIER_IP_ADDRESS,
- querier.addr.src.ip4)) {
- rcu_read_unlock();
- goto out_err;
- }
- p = __br_multicast_get_querier_port(brmctx->br, &querier);
- if (timer_pending(&brmctx->ip4_other_query.timer) &&
- (nla_put_u64_64bit(skb, BRIDGE_QUERIER_IP_OTHER_TIMER,
- br_timer_value(&brmctx->ip4_other_query.timer),
- BRIDGE_QUERIER_PAD) ||
- (p && nla_put_u32(skb, BRIDGE_QUERIER_IP_PORT, p->dev->ifindex)))) {
- rcu_read_unlock();
- goto out_err;
- }
- out_v6:
- #if IS_ENABLED(CONFIG_IPV6)
- if (!brmctx->multicast_querier &&
- !timer_pending(&brmctx->ip6_other_query.timer))
- goto out;
- br_multicast_read_querier(&brmctx->ip6_querier, &querier);
- if (nla_put_in6_addr(skb, BRIDGE_QUERIER_IPV6_ADDRESS,
- &querier.addr.src.ip6)) {
- rcu_read_unlock();
- goto out_err;
- }
- p = __br_multicast_get_querier_port(brmctx->br, &querier);
- if (timer_pending(&brmctx->ip6_other_query.timer) &&
- (nla_put_u64_64bit(skb, BRIDGE_QUERIER_IPV6_OTHER_TIMER,
- br_timer_value(&brmctx->ip6_other_query.timer),
- BRIDGE_QUERIER_PAD) ||
- (p && nla_put_u32(skb, BRIDGE_QUERIER_IPV6_PORT,
- p->dev->ifindex)))) {
- rcu_read_unlock();
- goto out_err;
- }
- out:
- #endif
- rcu_read_unlock();
- nla_nest_end(skb, nest);
- if (!nla_len(nest))
- nla_nest_cancel(skb, nest);
- return 0;
- out_err:
- nla_nest_cancel(skb, nest);
- return -EMSGSIZE;
- }
- static void
- br_multicast_update_query_timer(struct net_bridge_mcast *brmctx,
- struct bridge_mcast_other_query *query,
- unsigned long max_delay)
- {
- if (!timer_pending(&query->timer))
- query->delay_time = jiffies + max_delay;
- mod_timer(&query->timer, jiffies + brmctx->multicast_querier_interval);
- }
- static void br_port_mc_router_state_change(struct net_bridge_port *p,
- bool is_mc_router)
- {
- struct switchdev_attr attr = {
- .orig_dev = p->dev,
- .id = SWITCHDEV_ATTR_ID_PORT_MROUTER,
- .flags = SWITCHDEV_F_DEFER,
- .u.mrouter = is_mc_router,
- };
- switchdev_port_attr_set(p->dev, &attr, NULL);
- }
- static struct net_bridge_port *
- br_multicast_rport_from_node(struct net_bridge_mcast *brmctx,
- struct hlist_head *mc_router_list,
- struct hlist_node *rlist)
- {
- struct net_bridge_mcast_port *pmctx;
- #if IS_ENABLED(CONFIG_IPV6)
- if (mc_router_list == &brmctx->ip6_mc_router_list)
- pmctx = hlist_entry(rlist, struct net_bridge_mcast_port,
- ip6_rlist);
- else
- #endif
- pmctx = hlist_entry(rlist, struct net_bridge_mcast_port,
- ip4_rlist);
- return pmctx->port;
- }
- static struct hlist_node *
- br_multicast_get_rport_slot(struct net_bridge_mcast *brmctx,
- struct net_bridge_port *port,
- struct hlist_head *mc_router_list)
- {
- struct hlist_node *slot = NULL;
- struct net_bridge_port *p;
- struct hlist_node *rlist;
- hlist_for_each(rlist, mc_router_list) {
- p = br_multicast_rport_from_node(brmctx, mc_router_list, rlist);
- if ((unsigned long)port >= (unsigned long)p)
- break;
- slot = rlist;
- }
- return slot;
- }
- static bool br_multicast_no_router_otherpf(struct net_bridge_mcast_port *pmctx,
- struct hlist_node *rnode)
- {
- #if IS_ENABLED(CONFIG_IPV6)
- if (rnode != &pmctx->ip6_rlist)
- return hlist_unhashed(&pmctx->ip6_rlist);
- else
- return hlist_unhashed(&pmctx->ip4_rlist);
- #else
- return true;
- #endif
- }
- /* Add port to router_list
- * list is maintained ordered by pointer value
- * and locked by br->multicast_lock and RCU
- */
- static void br_multicast_add_router(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct hlist_node *rlist,
- struct hlist_head *mc_router_list)
- {
- struct hlist_node *slot;
- if (!hlist_unhashed(rlist))
- return;
- slot = br_multicast_get_rport_slot(brmctx, pmctx->port, mc_router_list);
- if (slot)
- hlist_add_behind_rcu(rlist, slot);
- else
- hlist_add_head_rcu(rlist, mc_router_list);
- /* For backwards compatibility for now, only notify if we
- * switched from no IPv4/IPv6 multicast router to a new
- * IPv4 or IPv6 multicast router.
- */
- if (br_multicast_no_router_otherpf(pmctx, rlist)) {
- br_rtr_notify(pmctx->port->br->dev, pmctx, RTM_NEWMDB);
- br_port_mc_router_state_change(pmctx->port, true);
- }
- }
- /* Add port to router_list
- * list is maintained ordered by pointer value
- * and locked by br->multicast_lock and RCU
- */
- static void br_ip4_multicast_add_router(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx)
- {
- br_multicast_add_router(brmctx, pmctx, &pmctx->ip4_rlist,
- &brmctx->ip4_mc_router_list);
- }
- /* Add port to router_list
- * list is maintained ordered by pointer value
- * and locked by br->multicast_lock and RCU
- */
- static void br_ip6_multicast_add_router(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx)
- {
- #if IS_ENABLED(CONFIG_IPV6)
- br_multicast_add_router(brmctx, pmctx, &pmctx->ip6_rlist,
- &brmctx->ip6_mc_router_list);
- #endif
- }
- static void br_multicast_mark_router(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct timer_list *timer,
- struct hlist_node *rlist,
- struct hlist_head *mc_router_list)
- {
- unsigned long now = jiffies;
- if (!br_multicast_ctx_should_use(brmctx, pmctx))
- return;
- if (!pmctx) {
- if (brmctx->multicast_router == MDB_RTR_TYPE_TEMP_QUERY) {
- if (!br_ip4_multicast_is_router(brmctx) &&
- !br_ip6_multicast_is_router(brmctx))
- br_mc_router_state_change(brmctx->br, true);
- mod_timer(timer, now + brmctx->multicast_querier_interval);
- }
- return;
- }
- if (pmctx->multicast_router == MDB_RTR_TYPE_DISABLED ||
- pmctx->multicast_router == MDB_RTR_TYPE_PERM)
- return;
- br_multicast_add_router(brmctx, pmctx, rlist, mc_router_list);
- mod_timer(timer, now + brmctx->multicast_querier_interval);
- }
- static void br_ip4_multicast_mark_router(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx)
- {
- struct timer_list *timer = &brmctx->ip4_mc_router_timer;
- struct hlist_node *rlist = NULL;
- if (pmctx) {
- timer = &pmctx->ip4_mc_router_timer;
- rlist = &pmctx->ip4_rlist;
- }
- br_multicast_mark_router(brmctx, pmctx, timer, rlist,
- &brmctx->ip4_mc_router_list);
- }
- static void br_ip6_multicast_mark_router(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx)
- {
- #if IS_ENABLED(CONFIG_IPV6)
- struct timer_list *timer = &brmctx->ip6_mc_router_timer;
- struct hlist_node *rlist = NULL;
- if (pmctx) {
- timer = &pmctx->ip6_mc_router_timer;
- rlist = &pmctx->ip6_rlist;
- }
- br_multicast_mark_router(brmctx, pmctx, timer, rlist,
- &brmctx->ip6_mc_router_list);
- #endif
- }
- static void
- br_ip4_multicast_query_received(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct bridge_mcast_other_query *query,
- struct br_ip *saddr,
- unsigned long max_delay)
- {
- if (!br_multicast_select_querier(brmctx, pmctx, saddr))
- return;
- br_multicast_update_query_timer(brmctx, query, max_delay);
- br_ip4_multicast_mark_router(brmctx, pmctx);
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static void
- br_ip6_multicast_query_received(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct bridge_mcast_other_query *query,
- struct br_ip *saddr,
- unsigned long max_delay)
- {
- if (!br_multicast_select_querier(brmctx, pmctx, saddr))
- return;
- br_multicast_update_query_timer(brmctx, query, max_delay);
- br_ip6_multicast_mark_router(brmctx, pmctx);
- }
- #endif
- static void br_ip4_multicast_query(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct sk_buff *skb,
- u16 vid)
- {
- unsigned int transport_len = ip_transport_len(skb);
- const struct iphdr *iph = ip_hdr(skb);
- struct igmphdr *ih = igmp_hdr(skb);
- struct net_bridge_mdb_entry *mp;
- struct igmpv3_query *ih3;
- struct net_bridge_port_group *p;
- struct net_bridge_port_group __rcu **pp;
- struct br_ip saddr = {};
- unsigned long max_delay;
- unsigned long now = jiffies;
- __be32 group;
- spin_lock(&brmctx->br->multicast_lock);
- if (!br_multicast_ctx_should_use(brmctx, pmctx))
- goto out;
- group = ih->group;
- if (transport_len == sizeof(*ih)) {
- max_delay = ih->code * (HZ / IGMP_TIMER_SCALE);
- if (!max_delay) {
- max_delay = 10 * HZ;
- group = 0;
- }
- } else if (transport_len >= sizeof(*ih3)) {
- ih3 = igmpv3_query_hdr(skb);
- if (ih3->nsrcs ||
- (brmctx->multicast_igmp_version == 3 && group &&
- ih3->suppress))
- goto out;
- max_delay = ih3->code ?
- IGMPV3_MRC(ih3->code) * (HZ / IGMP_TIMER_SCALE) : 1;
- } else {
- goto out;
- }
- if (!group) {
- saddr.proto = htons(ETH_P_IP);
- saddr.src.ip4 = iph->saddr;
- br_ip4_multicast_query_received(brmctx, pmctx,
- &brmctx->ip4_other_query,
- &saddr, max_delay);
- goto out;
- }
- mp = br_mdb_ip4_get(brmctx->br, group, vid);
- if (!mp)
- goto out;
- max_delay *= brmctx->multicast_last_member_count;
- if (mp->host_joined &&
- (timer_pending(&mp->timer) ?
- time_after(mp->timer.expires, now + max_delay) :
- try_to_del_timer_sync(&mp->timer) >= 0))
- mod_timer(&mp->timer, now + max_delay);
- for (pp = &mp->ports;
- (p = mlock_dereference(*pp, brmctx->br)) != NULL;
- pp = &p->next) {
- if (timer_pending(&p->timer) ?
- time_after(p->timer.expires, now + max_delay) :
- try_to_del_timer_sync(&p->timer) >= 0 &&
- (brmctx->multicast_igmp_version == 2 ||
- p->filter_mode == MCAST_EXCLUDE))
- mod_timer(&p->timer, now + max_delay);
- }
- out:
- spin_unlock(&brmctx->br->multicast_lock);
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static int br_ip6_multicast_query(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct sk_buff *skb,
- u16 vid)
- {
- unsigned int transport_len = ipv6_transport_len(skb);
- struct mld_msg *mld;
- struct net_bridge_mdb_entry *mp;
- struct mld2_query *mld2q;
- struct net_bridge_port_group *p;
- struct net_bridge_port_group __rcu **pp;
- struct br_ip saddr = {};
- unsigned long max_delay;
- unsigned long now = jiffies;
- unsigned int offset = skb_transport_offset(skb);
- const struct in6_addr *group = NULL;
- bool is_general_query;
- int err = 0;
- spin_lock(&brmctx->br->multicast_lock);
- if (!br_multicast_ctx_should_use(brmctx, pmctx))
- goto out;
- if (transport_len == sizeof(*mld)) {
- if (!pskb_may_pull(skb, offset + sizeof(*mld))) {
- err = -EINVAL;
- goto out;
- }
- mld = (struct mld_msg *) icmp6_hdr(skb);
- max_delay = msecs_to_jiffies(ntohs(mld->mld_maxdelay));
- if (max_delay)
- group = &mld->mld_mca;
- } else {
- if (!pskb_may_pull(skb, offset + sizeof(*mld2q))) {
- err = -EINVAL;
- goto out;
- }
- mld2q = (struct mld2_query *)icmp6_hdr(skb);
- if (!mld2q->mld2q_nsrcs)
- group = &mld2q->mld2q_mca;
- if (brmctx->multicast_mld_version == 2 &&
- !ipv6_addr_any(&mld2q->mld2q_mca) &&
- mld2q->mld2q_suppress)
- goto out;
- max_delay = max(msecs_to_jiffies(mldv2_mrc(mld2q)), 1UL);
- }
- is_general_query = group && ipv6_addr_any(group);
- if (is_general_query) {
- saddr.proto = htons(ETH_P_IPV6);
- saddr.src.ip6 = ipv6_hdr(skb)->saddr;
- br_ip6_multicast_query_received(brmctx, pmctx,
- &brmctx->ip6_other_query,
- &saddr, max_delay);
- goto out;
- } else if (!group) {
- goto out;
- }
- mp = br_mdb_ip6_get(brmctx->br, group, vid);
- if (!mp)
- goto out;
- max_delay *= brmctx->multicast_last_member_count;
- if (mp->host_joined &&
- (timer_pending(&mp->timer) ?
- time_after(mp->timer.expires, now + max_delay) :
- try_to_del_timer_sync(&mp->timer) >= 0))
- mod_timer(&mp->timer, now + max_delay);
- for (pp = &mp->ports;
- (p = mlock_dereference(*pp, brmctx->br)) != NULL;
- pp = &p->next) {
- if (timer_pending(&p->timer) ?
- time_after(p->timer.expires, now + max_delay) :
- try_to_del_timer_sync(&p->timer) >= 0 &&
- (brmctx->multicast_mld_version == 1 ||
- p->filter_mode == MCAST_EXCLUDE))
- mod_timer(&p->timer, now + max_delay);
- }
- out:
- spin_unlock(&brmctx->br->multicast_lock);
- return err;
- }
- #endif
- static void
- br_multicast_leave_group(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct br_ip *group,
- struct bridge_mcast_other_query *other_query,
- struct bridge_mcast_own_query *own_query,
- const unsigned char *src)
- {
- struct net_bridge_mdb_entry *mp;
- struct net_bridge_port_group *p;
- unsigned long now;
- unsigned long time;
- spin_lock(&brmctx->br->multicast_lock);
- if (!br_multicast_ctx_should_use(brmctx, pmctx))
- goto out;
- mp = br_mdb_ip_get(brmctx->br, group);
- if (!mp)
- goto out;
- if (pmctx && (pmctx->port->flags & BR_MULTICAST_FAST_LEAVE)) {
- struct net_bridge_port_group __rcu **pp;
- for (pp = &mp->ports;
- (p = mlock_dereference(*pp, brmctx->br)) != NULL;
- pp = &p->next) {
- if (!br_port_group_equal(p, pmctx->port, src))
- continue;
- if (p->flags & MDB_PG_FLAGS_PERMANENT)
- break;
- p->flags |= MDB_PG_FLAGS_FAST_LEAVE;
- br_multicast_del_pg(mp, p, pp);
- }
- goto out;
- }
- if (timer_pending(&other_query->timer))
- goto out;
- if (brmctx->multicast_querier) {
- __br_multicast_send_query(brmctx, pmctx, NULL, NULL, &mp->addr,
- false, 0, NULL);
- time = jiffies + brmctx->multicast_last_member_count *
- brmctx->multicast_last_member_interval;
- mod_timer(&own_query->timer, time);
- for (p = mlock_dereference(mp->ports, brmctx->br);
- p != NULL && pmctx != NULL;
- p = mlock_dereference(p->next, brmctx->br)) {
- if (!br_port_group_equal(p, pmctx->port, src))
- continue;
- if (!hlist_unhashed(&p->mglist) &&
- (timer_pending(&p->timer) ?
- time_after(p->timer.expires, time) :
- try_to_del_timer_sync(&p->timer) >= 0)) {
- mod_timer(&p->timer, time);
- }
- break;
- }
- }
- now = jiffies;
- time = now + brmctx->multicast_last_member_count *
- brmctx->multicast_last_member_interval;
- if (!pmctx) {
- if (mp->host_joined &&
- (timer_pending(&mp->timer) ?
- time_after(mp->timer.expires, time) :
- try_to_del_timer_sync(&mp->timer) >= 0)) {
- mod_timer(&mp->timer, time);
- }
- goto out;
- }
- for (p = mlock_dereference(mp->ports, brmctx->br);
- p != NULL;
- p = mlock_dereference(p->next, brmctx->br)) {
- if (p->key.port != pmctx->port)
- continue;
- if (!hlist_unhashed(&p->mglist) &&
- (timer_pending(&p->timer) ?
- time_after(p->timer.expires, time) :
- try_to_del_timer_sync(&p->timer) >= 0)) {
- mod_timer(&p->timer, time);
- }
- break;
- }
- out:
- spin_unlock(&brmctx->br->multicast_lock);
- }
- static void br_ip4_multicast_leave_group(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- __be32 group,
- __u16 vid,
- const unsigned char *src)
- {
- struct br_ip br_group;
- struct bridge_mcast_own_query *own_query;
- if (ipv4_is_local_multicast(group))
- return;
- own_query = pmctx ? &pmctx->ip4_own_query : &brmctx->ip4_own_query;
- memset(&br_group, 0, sizeof(br_group));
- br_group.dst.ip4 = group;
- br_group.proto = htons(ETH_P_IP);
- br_group.vid = vid;
- br_multicast_leave_group(brmctx, pmctx, &br_group,
- &brmctx->ip4_other_query,
- own_query, src);
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static void br_ip6_multicast_leave_group(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- const struct in6_addr *group,
- __u16 vid,
- const unsigned char *src)
- {
- struct br_ip br_group;
- struct bridge_mcast_own_query *own_query;
- if (ipv6_addr_is_ll_all_nodes(group))
- return;
- own_query = pmctx ? &pmctx->ip6_own_query : &brmctx->ip6_own_query;
- memset(&br_group, 0, sizeof(br_group));
- br_group.dst.ip6 = *group;
- br_group.proto = htons(ETH_P_IPV6);
- br_group.vid = vid;
- br_multicast_leave_group(brmctx, pmctx, &br_group,
- &brmctx->ip6_other_query,
- own_query, src);
- }
- #endif
- static void br_multicast_err_count(const struct net_bridge *br,
- const struct net_bridge_port *p,
- __be16 proto)
- {
- struct bridge_mcast_stats __percpu *stats;
- struct bridge_mcast_stats *pstats;
- if (!br_opt_get(br, BROPT_MULTICAST_STATS_ENABLED))
- return;
- if (p)
- stats = p->mcast_stats;
- else
- stats = br->mcast_stats;
- if (WARN_ON(!stats))
- return;
- pstats = this_cpu_ptr(stats);
- u64_stats_update_begin(&pstats->syncp);
- switch (proto) {
- case htons(ETH_P_IP):
- pstats->mstats.igmp_parse_errors++;
- break;
- #if IS_ENABLED(CONFIG_IPV6)
- case htons(ETH_P_IPV6):
- pstats->mstats.mld_parse_errors++;
- break;
- #endif
- }
- u64_stats_update_end(&pstats->syncp);
- }
- static void br_multicast_pim(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- const struct sk_buff *skb)
- {
- unsigned int offset = skb_transport_offset(skb);
- struct pimhdr *pimhdr, _pimhdr;
- pimhdr = skb_header_pointer(skb, offset, sizeof(_pimhdr), &_pimhdr);
- if (!pimhdr || pim_hdr_version(pimhdr) != PIM_VERSION ||
- pim_hdr_type(pimhdr) != PIM_TYPE_HELLO)
- return;
- spin_lock(&brmctx->br->multicast_lock);
- br_ip4_multicast_mark_router(brmctx, pmctx);
- spin_unlock(&brmctx->br->multicast_lock);
- }
- static int br_ip4_multicast_mrd_rcv(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct sk_buff *skb)
- {
- if (ip_hdr(skb)->protocol != IPPROTO_IGMP ||
- igmp_hdr(skb)->type != IGMP_MRDISC_ADV)
- return -ENOMSG;
- spin_lock(&brmctx->br->multicast_lock);
- br_ip4_multicast_mark_router(brmctx, pmctx);
- spin_unlock(&brmctx->br->multicast_lock);
- return 0;
- }
- static int br_multicast_ipv4_rcv(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct sk_buff *skb,
- u16 vid)
- {
- struct net_bridge_port *p = pmctx ? pmctx->port : NULL;
- const unsigned char *src;
- struct igmphdr *ih;
- int err;
- err = ip_mc_check_igmp(skb);
- if (err == -ENOMSG) {
- if (!ipv4_is_local_multicast(ip_hdr(skb)->daddr)) {
- BR_INPUT_SKB_CB(skb)->mrouters_only = 1;
- } else if (pim_ipv4_all_pim_routers(ip_hdr(skb)->daddr)) {
- if (ip_hdr(skb)->protocol == IPPROTO_PIM)
- br_multicast_pim(brmctx, pmctx, skb);
- } else if (ipv4_is_all_snoopers(ip_hdr(skb)->daddr)) {
- br_ip4_multicast_mrd_rcv(brmctx, pmctx, skb);
- }
- return 0;
- } else if (err < 0) {
- br_multicast_err_count(brmctx->br, p, skb->protocol);
- return err;
- }
- ih = igmp_hdr(skb);
- src = eth_hdr(skb)->h_source;
- BR_INPUT_SKB_CB(skb)->igmp = ih->type;
- switch (ih->type) {
- case IGMP_HOST_MEMBERSHIP_REPORT:
- case IGMPV2_HOST_MEMBERSHIP_REPORT:
- BR_INPUT_SKB_CB(skb)->mrouters_only = 1;
- err = br_ip4_multicast_add_group(brmctx, pmctx, ih->group, vid,
- src, true);
- break;
- case IGMPV3_HOST_MEMBERSHIP_REPORT:
- err = br_ip4_multicast_igmp3_report(brmctx, pmctx, skb, vid);
- break;
- case IGMP_HOST_MEMBERSHIP_QUERY:
- br_ip4_multicast_query(brmctx, pmctx, skb, vid);
- break;
- case IGMP_HOST_LEAVE_MESSAGE:
- br_ip4_multicast_leave_group(brmctx, pmctx, ih->group, vid, src);
- break;
- }
- br_multicast_count(brmctx->br, p, skb, BR_INPUT_SKB_CB(skb)->igmp,
- BR_MCAST_DIR_RX);
- return err;
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static void br_ip6_multicast_mrd_rcv(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct sk_buff *skb)
- {
- if (icmp6_hdr(skb)->icmp6_type != ICMPV6_MRDISC_ADV)
- return;
- spin_lock(&brmctx->br->multicast_lock);
- br_ip6_multicast_mark_router(brmctx, pmctx);
- spin_unlock(&brmctx->br->multicast_lock);
- }
- static int br_multicast_ipv6_rcv(struct net_bridge_mcast *brmctx,
- struct net_bridge_mcast_port *pmctx,
- struct sk_buff *skb,
- u16 vid)
- {
- struct net_bridge_port *p = pmctx ? pmctx->port : NULL;
- const unsigned char *src;
- struct mld_msg *mld;
- int err;
- err = ipv6_mc_check_mld(skb);
- if (err == -ENOMSG || err == -ENODATA) {
- if (!ipv6_addr_is_ll_all_nodes(&ipv6_hdr(skb)->daddr))
- BR_INPUT_SKB_CB(skb)->mrouters_only = 1;
- if (err == -ENODATA &&
- ipv6_addr_is_all_snoopers(&ipv6_hdr(skb)->daddr))
- br_ip6_multicast_mrd_rcv(brmctx, pmctx, skb);
- return 0;
- } else if (err < 0) {
- br_multicast_err_count(brmctx->br, p, skb->protocol);
- return err;
- }
- mld = (struct mld_msg *)skb_transport_header(skb);
- BR_INPUT_SKB_CB(skb)->igmp = mld->mld_type;
- switch (mld->mld_type) {
- case ICMPV6_MGM_REPORT:
- src = eth_hdr(skb)->h_source;
- BR_INPUT_SKB_CB(skb)->mrouters_only = 1;
- err = br_ip6_multicast_add_group(brmctx, pmctx, &mld->mld_mca,
- vid, src, true);
- break;
- case ICMPV6_MLD2_REPORT:
- err = br_ip6_multicast_mld2_report(brmctx, pmctx, skb, vid);
- break;
- case ICMPV6_MGM_QUERY:
- err = br_ip6_multicast_query(brmctx, pmctx, skb, vid);
- break;
- case ICMPV6_MGM_REDUCTION:
- src = eth_hdr(skb)->h_source;
- br_ip6_multicast_leave_group(brmctx, pmctx, &mld->mld_mca, vid,
- src);
- break;
- }
- br_multicast_count(brmctx->br, p, skb, BR_INPUT_SKB_CB(skb)->igmp,
- BR_MCAST_DIR_RX);
- return err;
- }
- #endif
- int br_multicast_rcv(struct net_bridge_mcast **brmctx,
- struct net_bridge_mcast_port **pmctx,
- struct net_bridge_vlan *vlan,
- struct sk_buff *skb, u16 vid)
- {
- int ret = 0;
- BR_INPUT_SKB_CB(skb)->igmp = 0;
- BR_INPUT_SKB_CB(skb)->mrouters_only = 0;
- if (!br_opt_get((*brmctx)->br, BROPT_MULTICAST_ENABLED))
- return 0;
- if (br_opt_get((*brmctx)->br, BROPT_MCAST_VLAN_SNOOPING_ENABLED) && vlan) {
- const struct net_bridge_vlan *masterv;
- /* the vlan has the master flag set only when transmitting
- * through the bridge device
- */
- if (br_vlan_is_master(vlan)) {
- masterv = vlan;
- *brmctx = &vlan->br_mcast_ctx;
- *pmctx = NULL;
- } else {
- masterv = vlan->brvlan;
- *brmctx = &vlan->brvlan->br_mcast_ctx;
- *pmctx = &vlan->port_mcast_ctx;
- }
- if (!(masterv->priv_flags & BR_VLFLAG_GLOBAL_MCAST_ENABLED))
- return 0;
- }
- switch (skb->protocol) {
- case htons(ETH_P_IP):
- ret = br_multicast_ipv4_rcv(*brmctx, *pmctx, skb, vid);
- break;
- #if IS_ENABLED(CONFIG_IPV6)
- case htons(ETH_P_IPV6):
- ret = br_multicast_ipv6_rcv(*brmctx, *pmctx, skb, vid);
- break;
- #endif
- }
- return ret;
- }
- static void br_multicast_query_expired(struct net_bridge_mcast *brmctx,
- struct bridge_mcast_own_query *query,
- struct bridge_mcast_querier *querier)
- {
- spin_lock(&brmctx->br->multicast_lock);
- if (br_multicast_ctx_vlan_disabled(brmctx))
- goto out;
- if (query->startup_sent < brmctx->multicast_startup_query_count)
- query->startup_sent++;
- br_multicast_send_query(brmctx, NULL, query);
- out:
- spin_unlock(&brmctx->br->multicast_lock);
- }
- static void br_ip4_multicast_query_expired(struct timer_list *t)
- {
- struct net_bridge_mcast *brmctx = from_timer(brmctx, t,
- ip4_own_query.timer);
- br_multicast_query_expired(brmctx, &brmctx->ip4_own_query,
- &brmctx->ip4_querier);
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static void br_ip6_multicast_query_expired(struct timer_list *t)
- {
- struct net_bridge_mcast *brmctx = from_timer(brmctx, t,
- ip6_own_query.timer);
- br_multicast_query_expired(brmctx, &brmctx->ip6_own_query,
- &brmctx->ip6_querier);
- }
- #endif
- static void br_multicast_gc_work(struct work_struct *work)
- {
- struct net_bridge *br = container_of(work, struct net_bridge,
- mcast_gc_work);
- HLIST_HEAD(deleted_head);
- spin_lock_bh(&br->multicast_lock);
- hlist_move_list(&br->mcast_gc_list, &deleted_head);
- spin_unlock_bh(&br->multicast_lock);
- br_multicast_gc(&deleted_head);
- }
- void br_multicast_ctx_init(struct net_bridge *br,
- struct net_bridge_vlan *vlan,
- struct net_bridge_mcast *brmctx)
- {
- brmctx->br = br;
- brmctx->vlan = vlan;
- brmctx->multicast_router = MDB_RTR_TYPE_TEMP_QUERY;
- brmctx->multicast_last_member_count = 2;
- brmctx->multicast_startup_query_count = 2;
- brmctx->multicast_last_member_interval = HZ;
- brmctx->multicast_query_response_interval = 10 * HZ;
- brmctx->multicast_startup_query_interval = 125 * HZ / 4;
- brmctx->multicast_query_interval = 125 * HZ;
- brmctx->multicast_querier_interval = 255 * HZ;
- brmctx->multicast_membership_interval = 260 * HZ;
- brmctx->ip4_other_query.delay_time = 0;
- brmctx->ip4_querier.port_ifidx = 0;
- seqcount_spinlock_init(&brmctx->ip4_querier.seq, &br->multicast_lock);
- brmctx->multicast_igmp_version = 2;
- #if IS_ENABLED(CONFIG_IPV6)
- brmctx->multicast_mld_version = 1;
- brmctx->ip6_other_query.delay_time = 0;
- brmctx->ip6_querier.port_ifidx = 0;
- seqcount_spinlock_init(&brmctx->ip6_querier.seq, &br->multicast_lock);
- #endif
- timer_setup(&brmctx->ip4_mc_router_timer,
- br_ip4_multicast_local_router_expired, 0);
- timer_setup(&brmctx->ip4_other_query.timer,
- br_ip4_multicast_querier_expired, 0);
- timer_setup(&brmctx->ip4_own_query.timer,
- br_ip4_multicast_query_expired, 0);
- #if IS_ENABLED(CONFIG_IPV6)
- timer_setup(&brmctx->ip6_mc_router_timer,
- br_ip6_multicast_local_router_expired, 0);
- timer_setup(&brmctx->ip6_other_query.timer,
- br_ip6_multicast_querier_expired, 0);
- timer_setup(&brmctx->ip6_own_query.timer,
- br_ip6_multicast_query_expired, 0);
- #endif
- }
- void br_multicast_ctx_deinit(struct net_bridge_mcast *brmctx)
- {
- __br_multicast_stop(brmctx);
- }
- void br_multicast_init(struct net_bridge *br)
- {
- br->hash_max = BR_MULTICAST_DEFAULT_HASH_MAX;
- br_multicast_ctx_init(br, NULL, &br->multicast_ctx);
- br_opt_toggle(br, BROPT_MULTICAST_ENABLED, true);
- br_opt_toggle(br, BROPT_HAS_IPV6_ADDR, true);
- spin_lock_init(&br->multicast_lock);
- INIT_HLIST_HEAD(&br->mdb_list);
- INIT_HLIST_HEAD(&br->mcast_gc_list);
- INIT_WORK(&br->mcast_gc_work, br_multicast_gc_work);
- }
- static void br_ip4_multicast_join_snoopers(struct net_bridge *br)
- {
- struct in_device *in_dev = in_dev_get(br->dev);
- if (!in_dev)
- return;
- __ip_mc_inc_group(in_dev, htonl(INADDR_ALLSNOOPERS_GROUP), GFP_ATOMIC);
- in_dev_put(in_dev);
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static void br_ip6_multicast_join_snoopers(struct net_bridge *br)
- {
- struct in6_addr addr;
- ipv6_addr_set(&addr, htonl(0xff020000), 0, 0, htonl(0x6a));
- ipv6_dev_mc_inc(br->dev, &addr);
- }
- #else
- static inline void br_ip6_multicast_join_snoopers(struct net_bridge *br)
- {
- }
- #endif
- void br_multicast_join_snoopers(struct net_bridge *br)
- {
- br_ip4_multicast_join_snoopers(br);
- br_ip6_multicast_join_snoopers(br);
- }
- static void br_ip4_multicast_leave_snoopers(struct net_bridge *br)
- {
- struct in_device *in_dev = in_dev_get(br->dev);
- if (WARN_ON(!in_dev))
- return;
- __ip_mc_dec_group(in_dev, htonl(INADDR_ALLSNOOPERS_GROUP), GFP_ATOMIC);
- in_dev_put(in_dev);
- }
- #if IS_ENABLED(CONFIG_IPV6)
- static void br_ip6_multicast_leave_snoopers(struct net_bridge *br)
- {
- struct in6_addr addr;
- ipv6_addr_set(&addr, htonl(0xff020000), 0, 0, htonl(0x6a));
- ipv6_dev_mc_dec(br->dev, &addr);
- }
- #else
- static inline void br_ip6_multicast_leave_snoopers(struct net_bridge *br)
- {
- }
- #endif
- void br_multicast_leave_snoopers(struct net_bridge *br)
- {
- br_ip4_multicast_leave_snoopers(br);
- br_ip6_multicast_leave_snoopers(br);
- }
- static void __br_multicast_open_query(struct net_bridge *br,
- struct bridge_mcast_own_query *query)
- {
- query->startup_sent = 0;
- if (!br_opt_get(br, BROPT_MULTICAST_ENABLED))
- return;
- mod_timer(&query->timer, jiffies);
- }
- static void __br_multicast_open(struct net_bridge_mcast *brmctx)
- {
- __br_multicast_open_query(brmctx->br, &brmctx->ip4_own_query);
- #if IS_ENABLED(CONFIG_IPV6)
- __br_multicast_open_query(brmctx->br, &brmctx->ip6_own_query);
- #endif
- }
- void br_multicast_open(struct net_bridge *br)
- {
- ASSERT_RTNL();
- if (br_opt_get(br, BROPT_MCAST_VLAN_SNOOPING_ENABLED)) {
- struct net_bridge_vlan_group *vg;
- struct net_bridge_vlan *vlan;
- vg = br_vlan_group(br);
- if (vg) {
- list_for_each_entry(vlan, &vg->vlan_list, vlist) {
- struct net_bridge_mcast *brmctx;
- brmctx = &vlan->br_mcast_ctx;
- if (br_vlan_is_brentry(vlan) &&
- !br_multicast_ctx_vlan_disabled(brmctx))
- __br_multicast_open(&vlan->br_mcast_ctx);
- }
- }
- } else {
- __br_multicast_open(&br->multicast_ctx);
- }
- }
- static void __br_multicast_stop(struct net_bridge_mcast *brmctx)
- {
- del_timer_sync(&brmctx->ip4_mc_router_timer);
- del_timer_sync(&brmctx->ip4_other_query.timer);
- del_timer_sync(&brmctx->ip4_own_query.timer);
- #if IS_ENABLED(CONFIG_IPV6)
- del_timer_sync(&brmctx->ip6_mc_router_timer);
- del_timer_sync(&brmctx->ip6_other_query.timer);
- del_timer_sync(&brmctx->ip6_own_query.timer);
- #endif
- }
- void br_multicast_toggle_one_vlan(struct net_bridge_vlan *vlan, bool on)
- {
- struct net_bridge *br;
- /* it's okay to check for the flag without the multicast lock because it
- * can only change under RTNL -> multicast_lock, we need the latter to
- * sync with timers and packets
- */
- if (on == !!(vlan->priv_flags & BR_VLFLAG_MCAST_ENABLED))
- return;
- if (br_vlan_is_master(vlan)) {
- br = vlan->br;
- if (!br_vlan_is_brentry(vlan) ||
- (on &&
- br_multicast_ctx_vlan_global_disabled(&vlan->br_mcast_ctx)))
- return;
- spin_lock_bh(&br->multicast_lock);
- vlan->priv_flags ^= BR_VLFLAG_MCAST_ENABLED;
- spin_unlock_bh(&br->multicast_lock);
- if (on)
- __br_multicast_open(&vlan->br_mcast_ctx);
- else
- __br_multicast_stop(&vlan->br_mcast_ctx);
- } else {
- struct net_bridge_mcast *brmctx;
- brmctx = br_multicast_port_ctx_get_global(&vlan->port_mcast_ctx);
- if (on && br_multicast_ctx_vlan_global_disabled(brmctx))
- return;
- br = vlan->port->br;
- spin_lock_bh(&br->multicast_lock);
- vlan->priv_flags ^= BR_VLFLAG_MCAST_ENABLED;
- if (on)
- __br_multicast_enable_port_ctx(&vlan->port_mcast_ctx);
- else
- __br_multicast_disable_port_ctx(&vlan->port_mcast_ctx);
- spin_unlock_bh(&br->multicast_lock);
- }
- }
- static void br_multicast_toggle_vlan(struct net_bridge_vlan *vlan, bool on)
- {
- struct net_bridge_port *p;
- if (WARN_ON_ONCE(!br_vlan_is_master(vlan)))
- return;
- list_for_each_entry(p, &vlan->br->port_list, list) {
- struct net_bridge_vlan *vport;
- vport = br_vlan_find(nbp_vlan_group(p), vlan->vid);
- if (!vport)
- continue;
- br_multicast_toggle_one_vlan(vport, on);
- }
- if (br_vlan_is_brentry(vlan))
- br_multicast_toggle_one_vlan(vlan, on);
- }
- int br_multicast_toggle_vlan_snooping(struct net_bridge *br, bool on,
- struct netlink_ext_ack *extack)
- {
- struct net_bridge_vlan_group *vg;
- struct net_bridge_vlan *vlan;
- struct net_bridge_port *p;
- if (br_opt_get(br, BROPT_MCAST_VLAN_SNOOPING_ENABLED) == on)
- return 0;
- if (on && !br_opt_get(br, BROPT_VLAN_ENABLED)) {
- NL_SET_ERR_MSG_MOD(extack, "Cannot enable multicast vlan snooping with vlan filtering disabled");
- return -EINVAL;
- }
- vg = br_vlan_group(br);
- if (!vg)
- return 0;
- br_opt_toggle(br, BROPT_MCAST_VLAN_SNOOPING_ENABLED, on);
- /* disable/enable non-vlan mcast contexts based on vlan snooping */
- if (on)
- __br_multicast_stop(&br->multicast_ctx);
- else
- __br_multicast_open(&br->multicast_ctx);
- list_for_each_entry(p, &br->port_list, list) {
- if (on)
- br_multicast_disable_port(p);
- else
- br_multicast_enable_port(p);
- }
- list_for_each_entry(vlan, &vg->vlan_list, vlist)
- br_multicast_toggle_vlan(vlan, on);
- return 0;
- }
- bool br_multicast_toggle_global_vlan(struct net_bridge_vlan *vlan, bool on)
- {
- ASSERT_RTNL();
- /* BR_VLFLAG_GLOBAL_MCAST_ENABLED relies on eventual consistency and
- * requires only RTNL to change
- */
- if (on == !!(vlan->priv_flags & BR_VLFLAG_GLOBAL_MCAST_ENABLED))
- return false;
- vlan->priv_flags ^= BR_VLFLAG_GLOBAL_MCAST_ENABLED;
- br_multicast_toggle_vlan(vlan, on);
- return true;
- }
- void br_multicast_stop(struct net_bridge *br)
- {
- ASSERT_RTNL();
- if (br_opt_get(br, BROPT_MCAST_VLAN_SNOOPING_ENABLED)) {
- struct net_bridge_vlan_group *vg;
- struct net_bridge_vlan *vlan;
- vg = br_vlan_group(br);
- if (vg) {
- list_for_each_entry(vlan, &vg->vlan_list, vlist) {
- struct net_bridge_mcast *brmctx;
- brmctx = &vlan->br_mcast_ctx;
- if (br_vlan_is_brentry(vlan) &&
- !br_multicast_ctx_vlan_disabled(brmctx))
- __br_multicast_stop(&vlan->br_mcast_ctx);
- }
- }
- } else {
- __br_multicast_stop(&br->multicast_ctx);
- }
- }
- void br_multicast_dev_del(struct net_bridge *br)
- {
- struct net_bridge_mdb_entry *mp;
- HLIST_HEAD(deleted_head);
- struct hlist_node *tmp;
- spin_lock_bh(&br->multicast_lock);
- hlist_for_each_entry_safe(mp, tmp, &br->mdb_list, mdb_node)
- br_multicast_del_mdb_entry(mp);
- hlist_move_list(&br->mcast_gc_list, &deleted_head);
- spin_unlock_bh(&br->multicast_lock);
- br_multicast_ctx_deinit(&br->multicast_ctx);
- br_multicast_gc(&deleted_head);
- cancel_work_sync(&br->mcast_gc_work);
- rcu_barrier();
- }
- int br_multicast_set_router(struct net_bridge_mcast *brmctx, unsigned long val)
- {
- int err = -EINVAL;
- spin_lock_bh(&brmctx->br->multicast_lock);
- switch (val) {
- case MDB_RTR_TYPE_DISABLED:
- case MDB_RTR_TYPE_PERM:
- br_mc_router_state_change(brmctx->br, val == MDB_RTR_TYPE_PERM);
- del_timer(&brmctx->ip4_mc_router_timer);
- #if IS_ENABLED(CONFIG_IPV6)
- del_timer(&brmctx->ip6_mc_router_timer);
- #endif
- brmctx->multicast_router = val;
- err = 0;
- break;
- case MDB_RTR_TYPE_TEMP_QUERY:
- if (brmctx->multicast_router != MDB_RTR_TYPE_TEMP_QUERY)
- br_mc_router_state_change(brmctx->br, false);
- brmctx->multicast_router = val;
- err = 0;
- break;
- }
- spin_unlock_bh(&brmctx->br->multicast_lock);
- return err;
- }
- static void
- br_multicast_rport_del_notify(struct net_bridge_mcast_port *pmctx, bool deleted)
- {
- if (!deleted)
- return;
- /* For backwards compatibility for now, only notify if there is
- * no multicast router anymore for both IPv4 and IPv6.
- */
- if (!hlist_unhashed(&pmctx->ip4_rlist))
- return;
- #if IS_ENABLED(CONFIG_IPV6)
- if (!hlist_unhashed(&pmctx->ip6_rlist))
- return;
- #endif
- br_rtr_notify(pmctx->port->br->dev, pmctx, RTM_DELMDB);
- br_port_mc_router_state_change(pmctx->port, false);
- /* don't allow timer refresh */
- if (pmctx->multicast_router == MDB_RTR_TYPE_TEMP)
- pmctx->multicast_router = MDB_RTR_TYPE_TEMP_QUERY;
- }
- int br_multicast_set_port_router(struct net_bridge_mcast_port *pmctx,
- unsigned long val)
- {
- struct net_bridge_mcast *brmctx;
- unsigned long now = jiffies;
- int err = -EINVAL;
- bool del = false;
- brmctx = br_multicast_port_ctx_get_global(pmctx);
- spin_lock_bh(&brmctx->br->multicast_lock);
- if (pmctx->multicast_router == val) {
- /* Refresh the temp router port timer */
- if (pmctx->multicast_router == MDB_RTR_TYPE_TEMP) {
- mod_timer(&pmctx->ip4_mc_router_timer,
- now + brmctx->multicast_querier_interval);
- #if IS_ENABLED(CONFIG_IPV6)
- mod_timer(&pmctx->ip6_mc_router_timer,
- now + brmctx->multicast_querier_interval);
- #endif
- }
- err = 0;
- goto unlock;
- }
- switch (val) {
- case MDB_RTR_TYPE_DISABLED:
- pmctx->multicast_router = MDB_RTR_TYPE_DISABLED;
- del |= br_ip4_multicast_rport_del(pmctx);
- del_timer(&pmctx->ip4_mc_router_timer);
- del |= br_ip6_multicast_rport_del(pmctx);
- #if IS_ENABLED(CONFIG_IPV6)
- del_timer(&pmctx->ip6_mc_router_timer);
- #endif
- br_multicast_rport_del_notify(pmctx, del);
- break;
- case MDB_RTR_TYPE_TEMP_QUERY:
- pmctx->multicast_router = MDB_RTR_TYPE_TEMP_QUERY;
- del |= br_ip4_multicast_rport_del(pmctx);
- del |= br_ip6_multicast_rport_del(pmctx);
- br_multicast_rport_del_notify(pmctx, del);
- break;
- case MDB_RTR_TYPE_PERM:
- pmctx->multicast_router = MDB_RTR_TYPE_PERM;
- del_timer(&pmctx->ip4_mc_router_timer);
- br_ip4_multicast_add_router(brmctx, pmctx);
- #if IS_ENABLED(CONFIG_IPV6)
- del_timer(&pmctx->ip6_mc_router_timer);
- #endif
- br_ip6_multicast_add_router(brmctx, pmctx);
- break;
- case MDB_RTR_TYPE_TEMP:
- pmctx->multicast_router = MDB_RTR_TYPE_TEMP;
- br_ip4_multicast_mark_router(brmctx, pmctx);
- br_ip6_multicast_mark_router(brmctx, pmctx);
- break;
- default:
- goto unlock;
- }
- err = 0;
- unlock:
- spin_unlock_bh(&brmctx->br->multicast_lock);
- return err;
- }
- int br_multicast_set_vlan_router(struct net_bridge_vlan *v, u8 mcast_router)
- {
- int err;
- if (br_vlan_is_master(v))
- err = br_multicast_set_router(&v->br_mcast_ctx, mcast_router);
- else
- err = br_multicast_set_port_router(&v->port_mcast_ctx,
- mcast_router);
- return err;
- }
- static void br_multicast_start_querier(struct net_bridge_mcast *brmctx,
- struct bridge_mcast_own_query *query)
- {
- struct net_bridge_port *port;
- if (!br_multicast_ctx_matches_vlan_snooping(brmctx))
- return;
- __br_multicast_open_query(brmctx->br, query);
- rcu_read_lock();
- list_for_each_entry_rcu(port, &brmctx->br->port_list, list) {
- struct bridge_mcast_own_query *ip4_own_query;
- #if IS_ENABLED(CONFIG_IPV6)
- struct bridge_mcast_own_query *ip6_own_query;
- #endif
- if (br_multicast_port_ctx_state_stopped(&port->multicast_ctx))
- continue;
- if (br_multicast_ctx_is_vlan(brmctx)) {
- struct net_bridge_vlan *vlan;
- vlan = br_vlan_find(nbp_vlan_group_rcu(port),
- brmctx->vlan->vid);
- if (!vlan ||
- br_multicast_port_ctx_state_stopped(&vlan->port_mcast_ctx))
- continue;
- ip4_own_query = &vlan->port_mcast_ctx.ip4_own_query;
- #if IS_ENABLED(CONFIG_IPV6)
- ip6_own_query = &vlan->port_mcast_ctx.ip6_own_query;
- #endif
- } else {
- ip4_own_query = &port->multicast_ctx.ip4_own_query;
- #if IS_ENABLED(CONFIG_IPV6)
- ip6_own_query = &port->multicast_ctx.ip6_own_query;
- #endif
- }
- if (query == &brmctx->ip4_own_query)
- br_multicast_enable(ip4_own_query);
- #if IS_ENABLED(CONFIG_IPV6)
- else
- br_multicast_enable(ip6_own_query);
- #endif
- }
- rcu_read_unlock();
- }
- int br_multicast_toggle(struct net_bridge *br, unsigned long val,
- struct netlink_ext_ack *extack)
- {
- struct net_bridge_port *port;
- bool change_snoopers = false;
- int err = 0;
- spin_lock_bh(&br->multicast_lock);
- if (!!br_opt_get(br, BROPT_MULTICAST_ENABLED) == !!val)
- goto unlock;
- err = br_mc_disabled_update(br->dev, val, extack);
- if (err == -EOPNOTSUPP)
- err = 0;
- if (err)
- goto unlock;
- br_opt_toggle(br, BROPT_MULTICAST_ENABLED, !!val);
- if (!br_opt_get(br, BROPT_MULTICAST_ENABLED)) {
- change_snoopers = true;
- goto unlock;
- }
- if (!netif_running(br->dev))
- goto unlock;
- br_multicast_open(br);
- list_for_each_entry(port, &br->port_list, list)
- __br_multicast_enable_port_ctx(&port->multicast_ctx);
- change_snoopers = true;
- unlock:
- spin_unlock_bh(&br->multicast_lock);
- /* br_multicast_join_snoopers has the potential to cause
- * an MLD Report/Leave to be delivered to br_multicast_rcv,
- * which would in turn call br_multicast_add_group, which would
- * attempt to acquire multicast_lock. This function should be
- * called after the lock has been released to avoid deadlocks on
- * multicast_lock.
- *
- * br_multicast_leave_snoopers does not have the problem since
- * br_multicast_rcv first checks BROPT_MULTICAST_ENABLED, and
- * returns without calling br_multicast_ipv4/6_rcv if it's not
- * enabled. Moved both functions out just for symmetry.
- */
- if (change_snoopers) {
- if (br_opt_get(br, BROPT_MULTICAST_ENABLED))
- br_multicast_join_snoopers(br);
- else
- br_multicast_leave_snoopers(br);
- }
- return err;
- }
- bool br_multicast_enabled(const struct net_device *dev)
- {
- struct net_bridge *br = netdev_priv(dev);
- return !!br_opt_get(br, BROPT_MULTICAST_ENABLED);
- }
- EXPORT_SYMBOL_GPL(br_multicast_enabled);
- bool br_multicast_router(const struct net_device *dev)
- {
- struct net_bridge *br = netdev_priv(dev);
- bool is_router;
- spin_lock_bh(&br->multicast_lock);
- is_router = br_multicast_is_router(&br->multicast_ctx, NULL);
- spin_unlock_bh(&br->multicast_lock);
- return is_router;
- }
- EXPORT_SYMBOL_GPL(br_multicast_router);
- int br_multicast_set_querier(struct net_bridge_mcast *brmctx, unsigned long val)
- {
- unsigned long max_delay;
- val = !!val;
- spin_lock_bh(&brmctx->br->multicast_lock);
- if (brmctx->multicast_querier == val)
- goto unlock;
- WRITE_ONCE(brmctx->multicast_querier, val);
- if (!val)
- goto unlock;
- max_delay = brmctx->multicast_query_response_interval;
- if (!timer_pending(&brmctx->ip4_other_query.timer))
- brmctx->ip4_other_query.delay_time = jiffies + max_delay;
- br_multicast_start_querier(brmctx, &brmctx->ip4_own_query);
- #if IS_ENABLED(CONFIG_IPV6)
- if (!timer_pending(&brmctx->ip6_other_query.timer))
- brmctx->ip6_other_query.delay_time = jiffies + max_delay;
- br_multicast_start_querier(brmctx, &brmctx->ip6_own_query);
- #endif
- unlock:
- spin_unlock_bh(&brmctx->br->multicast_lock);
- return 0;
- }
- int br_multicast_set_igmp_version(struct net_bridge_mcast *brmctx,
- unsigned long val)
- {
- /* Currently we support only version 2 and 3 */
- switch (val) {
- case 2:
- case 3:
- break;
- default:
- return -EINVAL;
- }
- spin_lock_bh(&brmctx->br->multicast_lock);
- brmctx->multicast_igmp_version = val;
- spin_unlock_bh(&brmctx->br->multicast_lock);
- return 0;
- }
- #if IS_ENABLED(CONFIG_IPV6)
- int br_multicast_set_mld_version(struct net_bridge_mcast *brmctx,
- unsigned long val)
- {
- /* Currently we support version 1 and 2 */
- switch (val) {
- case 1:
- case 2:
- break;
- default:
- return -EINVAL;
- }
- spin_lock_bh(&brmctx->br->multicast_lock);
- brmctx->multicast_mld_version = val;
- spin_unlock_bh(&brmctx->br->multicast_lock);
- return 0;
- }
- #endif
- void br_multicast_set_query_intvl(struct net_bridge_mcast *brmctx,
- unsigned long val)
- {
- unsigned long intvl_jiffies = clock_t_to_jiffies(val);
- if (intvl_jiffies < BR_MULTICAST_QUERY_INTVL_MIN) {
- br_info(brmctx->br,
- "trying to set multicast query interval below minimum, setting to %lu (%ums)\n",
- jiffies_to_clock_t(BR_MULTICAST_QUERY_INTVL_MIN),
- jiffies_to_msecs(BR_MULTICAST_QUERY_INTVL_MIN));
- intvl_jiffies = BR_MULTICAST_QUERY_INTVL_MIN;
- }
- brmctx->multicast_query_interval = intvl_jiffies;
- }
- void br_multicast_set_startup_query_intvl(struct net_bridge_mcast *brmctx,
- unsigned long val)
- {
- unsigned long intvl_jiffies = clock_t_to_jiffies(val);
- if (intvl_jiffies < BR_MULTICAST_STARTUP_QUERY_INTVL_MIN) {
- br_info(brmctx->br,
- "trying to set multicast startup query interval below minimum, setting to %lu (%ums)\n",
- jiffies_to_clock_t(BR_MULTICAST_STARTUP_QUERY_INTVL_MIN),
- jiffies_to_msecs(BR_MULTICAST_STARTUP_QUERY_INTVL_MIN));
- intvl_jiffies = BR_MULTICAST_STARTUP_QUERY_INTVL_MIN;
- }
- brmctx->multicast_startup_query_interval = intvl_jiffies;
- }
- /**
- * br_multicast_list_adjacent - Returns snooped multicast addresses
- * @dev: The bridge port adjacent to which to retrieve addresses
- * @br_ip_list: The list to store found, snooped multicast IP addresses in
- *
- * Creates a list of IP addresses (struct br_ip_list) sensed by the multicast
- * snooping feature on all bridge ports of dev's bridge device, excluding
- * the addresses from dev itself.
- *
- * Returns the number of items added to br_ip_list.
- *
- * Notes:
- * - br_ip_list needs to be initialized by caller
- * - br_ip_list might contain duplicates in the end
- * (needs to be taken care of by caller)
- * - br_ip_list needs to be freed by caller
- */
- int br_multicast_list_adjacent(struct net_device *dev,
- struct list_head *br_ip_list)
- {
- struct net_bridge *br;
- struct net_bridge_port *port;
- struct net_bridge_port_group *group;
- struct br_ip_list *entry;
- int count = 0;
- rcu_read_lock();
- if (!br_ip_list || !netif_is_bridge_port(dev))
- goto unlock;
- port = br_port_get_rcu(dev);
- if (!port || !port->br)
- goto unlock;
- br = port->br;
- list_for_each_entry_rcu(port, &br->port_list, list) {
- if (!port->dev || port->dev == dev)
- continue;
- hlist_for_each_entry_rcu(group, &port->mglist, mglist) {
- entry = kmalloc(sizeof(*entry), GFP_ATOMIC);
- if (!entry)
- goto unlock;
- entry->addr = group->key.addr;
- list_add(&entry->list, br_ip_list);
- count++;
- }
- }
- unlock:
- rcu_read_unlock();
- return count;
- }
- EXPORT_SYMBOL_GPL(br_multicast_list_adjacent);
- /**
- * br_multicast_has_querier_anywhere - Checks for a querier on a bridge
- * @dev: The bridge port providing the bridge on which to check for a querier
- * @proto: The protocol family to check for: IGMP -> ETH_P_IP, MLD -> ETH_P_IPV6
- *
- * Checks whether the given interface has a bridge on top and if so returns
- * true if a valid querier exists anywhere on the bridged link layer.
- * Otherwise returns false.
- */
- bool br_multicast_has_querier_anywhere(struct net_device *dev, int proto)
- {
- struct net_bridge *br;
- struct net_bridge_port *port;
- struct ethhdr eth;
- bool ret = false;
- rcu_read_lock();
- if (!netif_is_bridge_port(dev))
- goto unlock;
- port = br_port_get_rcu(dev);
- if (!port || !port->br)
- goto unlock;
- br = port->br;
- memset(ð, 0, sizeof(eth));
- eth.h_proto = htons(proto);
- ret = br_multicast_querier_exists(&br->multicast_ctx, ð, NULL);
- unlock:
- rcu_read_unlock();
- return ret;
- }
- EXPORT_SYMBOL_GPL(br_multicast_has_querier_anywhere);
- /**
- * br_multicast_has_querier_adjacent - Checks for a querier behind a bridge port
- * @dev: The bridge port adjacent to which to check for a querier
- * @proto: The protocol family to check for: IGMP -> ETH_P_IP, MLD -> ETH_P_IPV6
- *
- * Checks whether the given interface has a bridge on top and if so returns
- * true if a selected querier is behind one of the other ports of this
- * bridge. Otherwise returns false.
- */
- bool br_multicast_has_querier_adjacent(struct net_device *dev, int proto)
- {
- struct net_bridge_mcast *brmctx;
- struct net_bridge *br;
- struct net_bridge_port *port;
- bool ret = false;
- int port_ifidx;
- rcu_read_lock();
- if (!netif_is_bridge_port(dev))
- goto unlock;
- port = br_port_get_rcu(dev);
- if (!port || !port->br)
- goto unlock;
- br = port->br;
- brmctx = &br->multicast_ctx;
- switch (proto) {
- case ETH_P_IP:
- port_ifidx = brmctx->ip4_querier.port_ifidx;
- if (!timer_pending(&brmctx->ip4_other_query.timer) ||
- port_ifidx == port->dev->ifindex)
- goto unlock;
- break;
- #if IS_ENABLED(CONFIG_IPV6)
- case ETH_P_IPV6:
- port_ifidx = brmctx->ip6_querier.port_ifidx;
- if (!timer_pending(&brmctx->ip6_other_query.timer) ||
- port_ifidx == port->dev->ifindex)
- goto unlock;
- break;
- #endif
- default:
- goto unlock;
- }
- ret = true;
- unlock:
- rcu_read_unlock();
- return ret;
- }
- EXPORT_SYMBOL_GPL(br_multicast_has_querier_adjacent);
- /**
- * br_multicast_has_router_adjacent - Checks for a router behind a bridge port
- * @dev: The bridge port adjacent to which to check for a multicast router
- * @proto: The protocol family to check for: IGMP -> ETH_P_IP, MLD -> ETH_P_IPV6
- *
- * Checks whether the given interface has a bridge on top and if so returns
- * true if a multicast router is behind one of the other ports of this
- * bridge. Otherwise returns false.
- */
- bool br_multicast_has_router_adjacent(struct net_device *dev, int proto)
- {
- struct net_bridge_mcast_port *pmctx;
- struct net_bridge_mcast *brmctx;
- struct net_bridge_port *port;
- bool ret = false;
- rcu_read_lock();
- port = br_port_get_check_rcu(dev);
- if (!port)
- goto unlock;
- brmctx = &port->br->multicast_ctx;
- switch (proto) {
- case ETH_P_IP:
- hlist_for_each_entry_rcu(pmctx, &brmctx->ip4_mc_router_list,
- ip4_rlist) {
- if (pmctx->port == port)
- continue;
- ret = true;
- goto unlock;
- }
- break;
- #if IS_ENABLED(CONFIG_IPV6)
- case ETH_P_IPV6:
- hlist_for_each_entry_rcu(pmctx, &brmctx->ip6_mc_router_list,
- ip6_rlist) {
- if (pmctx->port == port)
- continue;
- ret = true;
- goto unlock;
- }
- break;
- #endif
- default:
- /* when compiled without IPv6 support, be conservative and
- * always assume presence of an IPv6 multicast router
- */
- ret = true;
- }
- unlock:
- rcu_read_unlock();
- return ret;
- }
- EXPORT_SYMBOL_GPL(br_multicast_has_router_adjacent);
- static void br_mcast_stats_add(struct bridge_mcast_stats __percpu *stats,
- const struct sk_buff *skb, u8 type, u8 dir)
- {
- struct bridge_mcast_stats *pstats = this_cpu_ptr(stats);
- __be16 proto = skb->protocol;
- unsigned int t_len;
- u64_stats_update_begin(&pstats->syncp);
- switch (proto) {
- case htons(ETH_P_IP):
- t_len = ntohs(ip_hdr(skb)->tot_len) - ip_hdrlen(skb);
- switch (type) {
- case IGMP_HOST_MEMBERSHIP_REPORT:
- pstats->mstats.igmp_v1reports[dir]++;
- break;
- case IGMPV2_HOST_MEMBERSHIP_REPORT:
- pstats->mstats.igmp_v2reports[dir]++;
- break;
- case IGMPV3_HOST_MEMBERSHIP_REPORT:
- pstats->mstats.igmp_v3reports[dir]++;
- break;
- case IGMP_HOST_MEMBERSHIP_QUERY:
- if (t_len != sizeof(struct igmphdr)) {
- pstats->mstats.igmp_v3queries[dir]++;
- } else {
- unsigned int offset = skb_transport_offset(skb);
- struct igmphdr *ih, _ihdr;
- ih = skb_header_pointer(skb, offset,
- sizeof(_ihdr), &_ihdr);
- if (!ih)
- break;
- if (!ih->code)
- pstats->mstats.igmp_v1queries[dir]++;
- else
- pstats->mstats.igmp_v2queries[dir]++;
- }
- break;
- case IGMP_HOST_LEAVE_MESSAGE:
- pstats->mstats.igmp_leaves[dir]++;
- break;
- }
- break;
- #if IS_ENABLED(CONFIG_IPV6)
- case htons(ETH_P_IPV6):
- t_len = ntohs(ipv6_hdr(skb)->payload_len) +
- sizeof(struct ipv6hdr);
- t_len -= skb_network_header_len(skb);
- switch (type) {
- case ICMPV6_MGM_REPORT:
- pstats->mstats.mld_v1reports[dir]++;
- break;
- case ICMPV6_MLD2_REPORT:
- pstats->mstats.mld_v2reports[dir]++;
- break;
- case ICMPV6_MGM_QUERY:
- if (t_len != sizeof(struct mld_msg))
- pstats->mstats.mld_v2queries[dir]++;
- else
- pstats->mstats.mld_v1queries[dir]++;
- break;
- case ICMPV6_MGM_REDUCTION:
- pstats->mstats.mld_leaves[dir]++;
- break;
- }
- break;
- #endif /* CONFIG_IPV6 */
- }
- u64_stats_update_end(&pstats->syncp);
- }
- void br_multicast_count(struct net_bridge *br,
- const struct net_bridge_port *p,
- const struct sk_buff *skb, u8 type, u8 dir)
- {
- struct bridge_mcast_stats __percpu *stats;
- /* if multicast_disabled is true then igmp type can't be set */
- if (!type || !br_opt_get(br, BROPT_MULTICAST_STATS_ENABLED))
- return;
- if (p)
- stats = p->mcast_stats;
- else
- stats = br->mcast_stats;
- if (WARN_ON(!stats))
- return;
- br_mcast_stats_add(stats, skb, type, dir);
- }
- int br_multicast_init_stats(struct net_bridge *br)
- {
- br->mcast_stats = netdev_alloc_pcpu_stats(struct bridge_mcast_stats);
- if (!br->mcast_stats)
- return -ENOMEM;
- return 0;
- }
- void br_multicast_uninit_stats(struct net_bridge *br)
- {
- free_percpu(br->mcast_stats);
- }
- /* noinline for https://bugs.llvm.org/show_bug.cgi?id=45802#c9 */
- static noinline_for_stack void mcast_stats_add_dir(u64 *dst, u64 *src)
- {
- dst[BR_MCAST_DIR_RX] += src[BR_MCAST_DIR_RX];
- dst[BR_MCAST_DIR_TX] += src[BR_MCAST_DIR_TX];
- }
- void br_multicast_get_stats(const struct net_bridge *br,
- const struct net_bridge_port *p,
- struct br_mcast_stats *dest)
- {
- struct bridge_mcast_stats __percpu *stats;
- struct br_mcast_stats tdst;
- int i;
- memset(dest, 0, sizeof(*dest));
- if (p)
- stats = p->mcast_stats;
- else
- stats = br->mcast_stats;
- if (WARN_ON(!stats))
- return;
- memset(&tdst, 0, sizeof(tdst));
- for_each_possible_cpu(i) {
- struct bridge_mcast_stats *cpu_stats = per_cpu_ptr(stats, i);
- struct br_mcast_stats temp;
- unsigned int start;
- do {
- start = u64_stats_fetch_begin_irq(&cpu_stats->syncp);
- memcpy(&temp, &cpu_stats->mstats, sizeof(temp));
- } while (u64_stats_fetch_retry_irq(&cpu_stats->syncp, start));
- mcast_stats_add_dir(tdst.igmp_v1queries, temp.igmp_v1queries);
- mcast_stats_add_dir(tdst.igmp_v2queries, temp.igmp_v2queries);
- mcast_stats_add_dir(tdst.igmp_v3queries, temp.igmp_v3queries);
- mcast_stats_add_dir(tdst.igmp_leaves, temp.igmp_leaves);
- mcast_stats_add_dir(tdst.igmp_v1reports, temp.igmp_v1reports);
- mcast_stats_add_dir(tdst.igmp_v2reports, temp.igmp_v2reports);
- mcast_stats_add_dir(tdst.igmp_v3reports, temp.igmp_v3reports);
- tdst.igmp_parse_errors += temp.igmp_parse_errors;
- mcast_stats_add_dir(tdst.mld_v1queries, temp.mld_v1queries);
- mcast_stats_add_dir(tdst.mld_v2queries, temp.mld_v2queries);
- mcast_stats_add_dir(tdst.mld_leaves, temp.mld_leaves);
- mcast_stats_add_dir(tdst.mld_v1reports, temp.mld_v1reports);
- mcast_stats_add_dir(tdst.mld_v2reports, temp.mld_v2reports);
- tdst.mld_parse_errors += temp.mld_parse_errors;
- }
- memcpy(dest, &tdst, sizeof(*dest));
- }
- int br_mdb_hash_init(struct net_bridge *br)
- {
- int err;
- err = rhashtable_init(&br->sg_port_tbl, &br_sg_port_rht_params);
- if (err)
- return err;
- err = rhashtable_init(&br->mdb_hash_tbl, &br_mdb_rht_params);
- if (err) {
- rhashtable_destroy(&br->sg_port_tbl);
- return err;
- }
- return 0;
- }
- void br_mdb_hash_fini(struct net_bridge *br)
- {
- rhashtable_destroy(&br->sg_port_tbl);
- rhashtable_destroy(&br->mdb_hash_tbl);
- }
|