IGMP-PROXY/src/igmpv3.c

100  *      struct in_addr *sources,
105         struct in_addr *sources, int numsrc)
109         if (src.s_addr == sources[i].s_addr)
213             struct in_addr *sources)
223       src=igmp_group_src_add(gp,sources[i]);
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);
234       if (check_src(src->igmps_source,sources,numsrc) == TRUE){
244       set_source_filter(router,gp,upstream,member->membership.fmode,member->membership.numsources,member->membership.sources);
258             struct in_addr *sources)
272             if ((check_src_set(sr->igmps_source,old_src_set) == TRUE)&& (check_src(sr->igmps_source,sources,numsrc) == TRUE)){
291           set_source_filter(router,gp,upstream,member->membership.fmode,member->membership.numsources,member->membership.sources);
298             sr=igmp_group_src_add(gp,sources[i]);
300             if ((check_src_set(sr->igmps_source,old_src_set) == FALSE) && (check_src(sr->igmps_source,sources,numsrc) == TRUE)){
309         if ((check_src(sr->igmps_source,sources,numsrc) == TRUE) && (sr->igmps_timer == 0)){
328       set_source_filter(router,gp,upstream,member->membership.fmode,member->membership.numsources,member->membership.sources);
343                 struct in_addr *sources)
376         src=igmp_group_src_add(gp,sources[i]);
377         if ((check_src_set(src->igmps_source,old_src_set) == FALSE) && check_src(src->igmps_source,sources,numsrc) == TRUE) {
381         if ((check_src_set(src->igmps_source,old_src_set) == TRUE) && check_src(src->igmps_source,sources,numsrc) == FALSE){
390         src=igmp_group_src_add(gp,sources[i]);
392         if ((check_src_set(src->igmps_source,old_src_set) == FALSE) && (check_src(src->igmps_source,sources,numsrc) == TRUE)){
398         if ((check_src(src->igmps_source,sources,numsrc) == FALSE) && (check_src_set(src->igmps_source,old_src_set) == TRUE)){
426       set_source_filter(router,gp,upstream,member->membership.fmode,member->membership.numsources,member->membership.sources);
450                 struct in_addr *sources)
506       src=igmp_group_src_add(gp,sources[i]);
508       if ((check_src(src->igmps_source,sources,numsrc) == TRUE) && (check_src_set(src->igmps_source,old_src_set) == FALSE)){
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);
531         if ((check_src(sr->igmps_source,sources,numsrc) == FALSE) && (check_src_set(sr->igmps_source,old_src_set) == TRUE )){
555     set_source_filter(router,gp,upstream,member->membership.fmode,member->membership.numsources,member->membership.sources);
565       if ((check_src(sr->igmps_source,sources,numsrc) == FALSE) && (check_src_set(sr->igmps_source,old_src_set) == TRUE ) && (sr->igmps_timer > 0)){
590       //set_source_filter(router,gp,upstream,member->membership.fmode,member->membership.numsources,member->membership.sources);
610     struct in_addr *sources)
638         src=igmp_group_src_add(gp,sources[i]);
640         if ((check_src_set(src->igmps_source,old_src_set) == FALSE) && (check_src(src->igmps_source,sources,numsrc) == TRUE)){
646           if ((check_src(src->igmps_source,sources,numsrc) == FALSE) && (check_src_set(src->igmps_source,old_src_set) == TRUE)){
657         src=igmp_group_src_add(gp,sources[i]);
658         if ((check_src_set(src->igmps_source,old_src_set) == FALSE) && (check_src(src->igmps_source,sources,numsrc) == TRUE)){
662           if ((check_src(src->igmps_source,sources,numsrc) == FALSE) && (check_src_set(src->igmps_source,old_src_set) == TRUE)){
673       member = (membership_db*)update_multi(router,gp->igmpg_addr,gp->igmpg_fmode,numsrc,sources);
674       set_source_filter(router,gp,upstream,member->membership.fmode,member->membership.numsources,member->membership.sources);
692     struct in_addr *sources)
704       src=igmp_group_src_add(gp,sources[i]);
705       if (check_src(src->igmps_source,sources,numsrc) == TRUE){
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);
727         set_source_filter(router,gp,upstream,member->membership.fmode,member->membership.numsources,member->membership.sources);
736         set_source_filter(router,gp,upstream,member->membership.fmode,member->membership.numsources,member->membership.sources);
841       /*switch to INCLUDE filter-mode with source list = sources with timer running*/
946         printf("forward traffic from all sources\n");
972  * void sch_group_specq_add(router,ifp,gp,sources,numsrc)
978         struct in_addr *sources,
990         sch->sources[i].s_addr = sources[i].s_addr;
1002  * Include sources if they are specified and the router version of the
1007     struct in_addr *group, struct in_addr *sources, int numsrc, int SRSP)
1069                 query->igmpq_sources[i].s_addr = sources[i].s_addr;
1123             struct in_addr *sources,
1131         src=igmp_group_src_lookup(gp,sources[i]);
1138     sch_group_specq_add(ifp,gp->igmpg_addr,sources,numsrc);
1164  * construct two sets of sources with source timer lower than LMQI
1190         if ((src=igmp_group_src_lookup(gp,sch->sources[i]))==NULL){
1927                   struct in_addr *sources,
1952                     src=igmp_group_src_lookup(gr,sources[i]);