IGMP-PROXY/src/proxy.c

202         membership_db* member;
204         if ((member = (membership_db*) malloc(sizeof(*member)))) {
205                 member->membership.group = group;
206                 member->membership.fmode = fmode;
207                 member->membership.numsources = numsources;
209                   member->membership.sources[i].s_addr = sources[i].s_addr;
210                 member->next = NULL;
211                 return member;
240        membership_db *member;
243         member = find_membership(igmprt->igmprt_membership_db,group);
245         assert(member != NULL);
250           memb->next = member->next;
251           free(member);
258         LOG((LOG_DEBUG, "membership database, group_cleanup: %s\n", inet_ntoa(member->membership.group.s_addr)));
286        membership_db* member;
290        if ((member = find_membership(igmprt->igmprt_membership_db,group))) {
292            member->membership.fmode = (int)member->membership.fmode && (int)fmode;
293            if (member->membership.fmode == IGMP_FMODE_INCLUDE) {
296                        if (find_source(sources[i],member->membership.numsources,member->membership.sources) == FALSE){
297                          member->membership.numsources = member->membership.numsources + 1;
298                          member->membership.sources[member->membership.numsources].s_addr = sources[i].s_addr;
304                          if (find_source(sources[i],member->membership.numsources,member->membership.sources) == FALSE){
308                      member->membership.numsources = k;
310                          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) == FALSE){
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;
327                      for(i=0;i<member->membership.numsources;i++)
328                          if (find_source(member->membership.sources[i],nsources,sources) == TRUE){
329                              sr[k].s_addr = member->membership.sources[i].s_addr;
332                      member->membership.numsources = k;
334                        member->membership.sources[i].s_addr = sr[i].s_addr;
337            //printf("update membership database group: %s, source: %s\n",inet_ntoa(group.s_addr),inet_ntoa(member->membership.sources[0]
341             member = create_membership(group,fmode,nsources,sources);
342             member->next = igmprt->igmprt_membership_db;
343             igmprt->igmprt_membership_db = member;
345        return member;