IGMP-PROXY/src/proxy.c

192         membership_db* member;
194         if (member = (membership_db*) malloc(sizeof(*member))) {
195                 member->membership.group = group;
196                 member->membership.fmode = fmode;
197                 member->membership.numsources = numsources;
199                   member->membership.sources[i].s_addr = sources[i].s_addr;
200                 member->next = NULL;
201                 return member;
229        membership_db *member;
232         member = find_membership(igmprt->igmprt_membership_db,group);
234         assert(member != NULL);
239           memb->next = member->next;
240           free(member);
247         LOG((LOG_DEBUG, "membership database, group_cleanup: %s\n", inet_ntoa(member->membership.group.s_addr)));
275        membership_db* member;
279        if (member = find_membership(igmprt->igmprt_membership_db,group)) {
281            member->membership.fmode = (int)member->membership.fmode && (int)fmode;
282            if (member->membership.fmode == IGMP_FMODE_INCLUDE) {
285                        if (find_source(sources[i],member->membership.numsources,member->membership.sources) == FALSE){
286                          member->membership.numsources = member->membership.numsources + 1;
287                          member->membership.sources[member->membership.numsources].s_addr = sources[i].s_addr;
293                          if (find_source(sources[i],member->membership.numsources,member->membership.sources) == FALSE){
297                      member->membership.numsources = k;
299                          member->membership.sources[i].s_addr = sr[i].s_addr;
305                      for(i=0;i<member->membership.numsources;i++)
306                          if (find_source(member->membership.sources[i],nsources,sources) == FALSE){
307                              sr[k].s_addr = member->membership.sources[i].s_addr;
310                      member->membership.numsources = k;
312                        member->membership.sources[i].s_addr = sr[i].s_addr;
316                      for(i=0;i<member->membership.numsources;i++)
317                          if (find_source(member->membership.sources[i],nsources,sources) == TRUE){
318                              sr[k].s_addr = member->membership.sources[i].s_addr;
321                      member->membership.numsources = k;
323                        member->membership.sources[i].s_addr = sr[i].s_addr;
326            //printf("update membership database group: %s, source: %s\n",inet_ntoa(group.s_addr),inet_ntoa(member->membership.sources[0]
330             member = create_membership(group,fmode,nsources,sources);
331             member->next = igmprt->igmprt_membership_db;
332             igmprt->igmprt_membership_db = member;
334        return member;