IGMP-PROXY/src/igmpv3.c

225              k_proxy_chg_mfc(router,router->igmprt_socket,sources[i].s_addr,gp->igmpg_addr.s_addr,ifp->igmpi_index,forward_upstream);
227 			 k_proxy_chg_mfc(router,router->igmprt_socket,sources[i].s_addr,gp->igmpg_addr.s_addr,ifp->igmpi_index,1);
243       member = (membership_db*)update_multi(router,gp->igmpg_addr,gp->igmpg_fmode,num,set_src);
290           member = (membership_db*)update_multi(router,gp->igmpg_addr,gp->igmpg_fmode,num,set_src);
327       member = (membership_db*)update_multi(router,gp->igmpg_addr,gp->igmpg_fmode,num,set_src);
384           k_proxy_del_mfc (router->igmprt_socket, src->igmps_source.s_addr, gp->igmpg_addr.s_addr);
401         k_proxy_del_mfc (router->igmprt_socket, src->igmps_source.s_addr, gp->igmpg_addr.s_addr);
425       member = (membership_db*)update_multi(router,gp->igmpg_addr,gp->igmpg_fmode,num,set_src);
433         k_proxy_chg_mfc(router,router->igmprt_socket,mulsrc.igmps_addr.s_addr,gp->igmpg_addr.s_addr,wan_index,1);
460 	if(!igmp_interface_group_lookup(ifp,gp->igmpg_addr))
494 			k_proxy_del_mfc(router->igmprt_socket,mulsrc.igmps_addr.s_addr,gp->igmpg_addr.s_addr);
515            k_proxy_chg_mfc(router,router->igmprt_socket,sources[i].s_addr,gp->igmpg_addr.s_addr,ifp->igmpi_index,forward_upstream);
520            k_proxy_chg_mfc(router,router->igmprt_socket,sources[i].s_addr,gp->igmpg_addr.s_addr,ifp->igmpi_index,1);
553     member = (membership_db*)update_multi(router,gp->igmpg_addr,gp->igmpg_fmode,num,set_src);
588       member = (membership_db*)update_multi(router,gp->igmpg_addr,gp->igmpg_fmode,num,set_src);
624 			//printf("%d, 0x%x,0x%x,0x%x,\n",router->igmprt_socket,mulsrc.igmps_addr.s_addr,gp->igmpg_addr.s_addr,wan_index);
625 			k_proxy_chg_mfc(router,router->igmprt_socket,mulsrc.igmps_addr.s_addr,gp->igmpg_addr.s_addr,wan_index,1);
649         k_proxy_del_mfc (router->igmprt_socket, src->igmps_source.s_addr, gp->igmpg_addr.s_addr);
665         k_proxy_del_mfc (router->igmprt_socket, src->igmps_source.s_addr, gp->igmpg_addr.s_addr);
673       member = (membership_db*)update_multi(router,gp->igmpg_addr,gp->igmpg_fmode,numsrc,sources);
709                 k_proxy_chg_mfc(router,router->igmprt_socket,sources[i].s_addr,gp->igmpg_addr.s_addr,ifp->igmpi_index,forward_upstream);
711                 k_proxy_chg_mfc(router,router->igmprt_socket,sources[i].s_addr,gp->igmpg_addr.s_addr,ifp->igmpi_index,1);
726         member = (membership_db*)update_multi(router,gp->igmpg_addr,gp->igmpg_fmode,num,set_src);
735         member = (membership_db*)update_multi(router,gp->igmpg_addr,gp->igmpg_fmode,num,set_src);
788 		  if(!rt_group_find(ntohl(gp->igmpg_addr.s_addr)))
790 		  if(!emf_cfg_mfdb_group_find(gp->igmpg_addr))
792 			k_proxy_del_mfc(router->igmprt_socket,mulsrc.igmps_addr.s_addr,gp->igmpg_addr.s_addr);
802         k_proxy_del_mfc (router->igmprt_socket, src->igmps_source.s_addr, gp->igmpg_addr.s_addr);
817         if ((igmp_interface_group_lookup(ifp1,gp->igmpg_addr) != NULL) && (ifp1->igmpi_addr.s_addr != upstream))
823         mreq.imr_multiaddr.s_addr=gp->igmpg_addr.s_addr;
883         k_proxy_chg_mfc(router,router->igmprt_socket,src->igmps_source.s_addr,gp->igmpg_addr.s_addr,ifp->igmpi_index,1);
892           k_proxy_chg_mfc(router,router->igmprt_socket,src->igmps_source.s_addr,gp->igmpg_addr.s_addr,ifp->igmpi_index,0);
895         k_proxy_del_mfc (router->igmprt_socket, src->igmps_source.s_addr, gp->igmpg_addr.s_addr);
904         if ((igmp_interface_group_lookup(ifp1,gp->igmpg_addr) != NULL) && (ifp1->igmpi_addr.s_addr != upstream))
907         mreq.imr_multiaddr.s_addr=gp->igmpg_addr.s_addr;
933         k_proxy_chg_mfc(router,router->igmprt_socket,src->igmps_source.s_addr,gp->igmpg_addr.s_addr,ifp->igmpi_index,1);
942           k_proxy_chg_mfc(router,router->igmprt_socket,src->igmps_source.s_addr,gp->igmpg_addr.s_addr,ifp->igmpi_index,0);
1110     igmprt_membership_query(router,ifp,&gp->igmpg_addr,NULL,0,SRSP);
1112     sch_group_specq_add(ifp,gp->igmpg_addr,NULL,0);
1138     sch_group_specq_add(ifp,gp->igmpg_addr,sources,numsrc);
1320 					 if (gp_1->igmpg_addr.s_addr == 0){
1324 					 if ((gp_1->igmpg_addr.s_addr == inet_addr(IGMP_ALL_ROUTERS_V3)) ||
1325 						 (gp_1->igmpg_addr.s_addr == inet_addr(IGMP_ALL_ROUTERS)))
1332 					memcpy(&(v2_report->igmpr_group),&(gp_1->igmpg_addr),4);
1340 					memcpy(&sin.sin_addr,&(gp_1->igmpg_addr),4);
1476 				//if ((gp1->igmpg_addr.s_addr != 0) && (recordnum < 64) && (gp1->igmpg_members != NULL))
1478 					//records[recordnum].igmpg_addr.s_addr = gp->igmpg_addr.s_addr;
1517 						if(gp1->igmpg_addr.s_addr == inet_addr(IGMP_ALL_ROUTERS) || gp1->igmpg_addr.s_addr == inet_addr(IGMP_ALL_ROUTERS_V3))
1525 						arecord.igmpg_group.s_addr = gp1->igmpg_addr.s_addr;
1577 								arecord.igmpg_group.s_addr = gp1->igmpg_addr.s_addr;
1737 				if ((gp2->igmpg_addr.s_addr != 0) && (recordnum2 < 64) && (gp2->igmpg_members != NULL)){
1779 					if (gp2->igmpg_addr.s_addr == 0){
1783 					if (gp2->igmpg_addr.s_addr == inet_addr(IGMP_ALL_ROUTERS_V3) ||
1784 						gp2->igmpg_addr.s_addr == inet_addr(IGMP_ALL_ROUTERS))
1793 						memcpy(&(v12_report->igmpr_group),&(gp2->igmpg_addr),4);
1794 						memcpy(&sin.sin_addr,&(gp2->igmpg_addr),4);
1802 							memcpy(&(v12_report->igmpr_group),&(gp2->igmpg_addr),4);