IGMP-PROXY/src/proxy.c

196  * create entry in the membership database
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;
218  * lookup for a group entry in the membership database
222 find_membership(membership_db *membership,struct in_addr group)
226         for(memb=membership;memb;memb=memb->next)
227           if (memb->membership.group.s_addr == group.s_addr)
233  * deleate group entry from membership database
246         if (igmprt->igmprt_membership_db->membership.group.s_addr != group.s_addr){
248           while(memb->next->membership.group.s_addr != group.s_addr)
258         LOG((LOG_DEBUG, "membership database, group_cleanup: %s\n", inet_ntoa(member->membership.group.s_addr)));
277  * add multicast group to the membership database
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]
340             /*create new entry in the membership database*/