continue;
/* scan igmp groups */
- for (ALL_LIST_ELEMENTS_RO(pim_ifp->group_list, grpnode, grp)) {
+ for (ALL_LIST_ELEMENTS_RO(pim_ifp->igmp_group_list, grpnode,
+ grp)) {
char group_str[INET_ADDRSTRLEN];
struct listnode *srcnode;
- struct igmp_source *src;
+ struct gm_source *src;
pim_inet4_dump("<group?>", grp->group_addr, group_str,
sizeof(group_str));
continue;
/* scan igmp groups */
- for (ALL_LIST_ELEMENTS_RO(pim_ifp->group_list, grpnode, grp)) {
+ for (ALL_LIST_ELEMENTS_RO(pim_ifp->igmp_group_list, grpnode,
+ grp)) {
char group_str[INET_ADDRSTRLEN];
struct listnode *srcnode;
- struct igmp_source *src;
+ struct gm_source *src;
pim_inet4_dump("<group?>", grp->group_addr, group_str,
sizeof(group_str));
// return;
if (PIM_IF_TEST_IGMP(pim_ifp->options)) {
- struct igmp_sock *igmp;
+ struct gm_sock *igmp;
/* lookup IGMP socket */
- igmp = pim_igmp_sock_lookup_ifaddr(pim_ifp->socket_list,
+ igmp = pim_igmp_sock_lookup_ifaddr(pim_ifp->igmp_socket_list,
ifaddr);
if (!igmp) {
/* if addr new, add IGMP socket */
}
/* Replay Static IGMP groups */
- if (pim_ifp->join_list) {
+ if (pim_ifp->igmp_join_list) {
struct listnode *node;
struct listnode *nextnode;
- struct igmp_join *ij;
+ struct gm_join *ij;
int join_fd;
- for (ALL_LIST_ELEMENTS(pim_ifp->join_list, node,
+ for (ALL_LIST_ELEMENTS(pim_ifp->igmp_join_list, node,
nextnode, ij)) {
/* Close socket and reopen with Source and Group
*/
}
} /* igmp */
else {
- struct igmp_sock *igmp;
+ struct gm_sock *igmp;
/* lookup IGMP socket */
- igmp = pim_igmp_sock_lookup_ifaddr(pim_ifp->socket_list,
+ igmp = pim_igmp_sock_lookup_ifaddr(pim_ifp->igmp_socket_list,
ifaddr);
if (ifc->address->family == AF_INET) {
if (igmp)
/*
Since we're (re)starting, reset QQI to default Query Interval
*/
- igmp->querier_query_interval = pim_ifp->default_query_interval;
+ igmp->querier_query_interval = pim_ifp->igmp_default_query_interval;
}
-static void igmp_group_free(struct igmp_group *group)
+static void igmp_group_free(struct gm_group *group)
{
list_delete(&group->group_source_list);
void pim_igmp_if_reset(struct pim_interface *pim_ifp)
{
struct listnode *grp_node, *grp_nextnode;
- struct igmp_group *grp;
+ struct gm_group *grp;
- for (ALL_LIST_ELEMENTS(pim_ifp->group_list, grp_node, grp_nextnode,
+ for (ALL_LIST_ELEMENTS(pim_ifp->igmp_group_list, grp_node, grp_nextnode,
grp)) {
igmp_group_delete(grp);
}
{
pim_igmp_if_reset(pim_ifp);
- assert(pim_ifp->group_list);
- assert(!listcount(pim_ifp->group_list));
+ assert(pim_ifp->igmp_group_list);
+ assert(!listcount(pim_ifp->igmp_group_list));
- list_delete(&pim_ifp->group_list);
- hash_free(pim_ifp->group_hash);
+ list_delete(&pim_ifp->igmp_group_list);
+ hash_free(pim_ifp->igmp_group_hash);
- list_delete(&pim_ifp->socket_list);
+ list_delete(&pim_ifp->igmp_socket_list);
}
-static struct igmp_sock *igmp_sock_new(int fd, struct in_addr ifaddr,
- struct interface *ifp, int mtrace_only)
+static struct gm_sock *igmp_sock_new(int fd, struct in_addr ifaddr,
+ struct interface *ifp, int mtrace_only)
{
struct pim_interface *pim_ifp;
- struct igmp_sock *igmp;
+ struct gm_sock *igmp;
pim_ifp = ifp->info;
lookup.group_addr.s_addr = group_addr.s_addr;
- return hash_lookup(pim_ifp->group_hash, &lookup);
+ return hash_lookup(pim_ifp->igmp_group_hash, &lookup);
}
-struct igmp_group *igmp_add_group_by_addr(struct igmp_sock *igmp,
- struct in_addr group_addr)
+struct gm_group *igmp_add_group_by_addr(struct gm_sock *igmp,
+ struct in_addr group_addr)
{
- struct igmp_group *group;
+ struct gm_group *group;
struct pim_interface *pim_ifp = igmp->interface->info;
group = find_group_by_addr(igmp, group_addr);
qqi = MAX(qqi, igmp->querier_query_interval);
}
return PIM_IGMP_GMI_MSEC(qrv, qqi,
- pim_ifp->query_max_response_time_dsec);
+ pim_ifp->igmp_query_max_response_time_dsec);
}
-void igmp_group_reset_gmi(struct igmp_group *group)
+void igmp_group_reset_gmi(struct gm_group *group)
{
long group_membership_interval_msec;
struct interface *ifp;
{
struct interface *ifp = group->interface;
struct pim_interface *pim_ifp = ifp->info;
- struct igmp_sock *igmp;
+ struct gm_sock *igmp;
struct listnode *sock_node;
- for (ALL_LIST_ELEMENTS_RO(pim_ifp->socket_list, sock_node, igmp)) {
- igmp_send_query(pim_ifp->version, group, igmp->fd, ifp->name,
- query_buf, query_buf_size, num_sources,
- group->group_addr, group->group_addr,
- pim_ifp->specific_query_max_response_time_dsec,
- s_flag, igmp->querier_robustness_variable,
- igmp->querier_query_interval);
+ for (ALL_LIST_ELEMENTS_RO(pim_ifp->igmp_socket_list, sock_node, igmp)) {
+ igmp_send_query(
+ pim_ifp->igmp_version, group, igmp->fd, ifp->name,
+ query_buf, query_buf_size, num_sources,
+ group->group_addr, group->group_addr,
+ pim_ifp->igmp_specific_query_max_response_time_dsec,
+ s_flag, igmp->querier_robustness_variable,
+ igmp->querier_query_interval);
}
}
*/
/* scan igmp groups */
- for (ALL_LIST_ELEMENTS_RO(pim_ifp->group_list, grpnode, grp)) {
+ for (ALL_LIST_ELEMENTS_RO(pim_ifp->igmp_group_list, grpnode, grp)) {
struct listnode *srcnode;
- struct igmp_source *src;
+ struct gm_source *src;
/* scan group sources */
for (ALL_LIST_ELEMENTS_RO(grp->group_source_list, srcnode,
int query_interval)
{
struct listnode *sock_node;
- struct igmp_sock *igmp;
+ struct gm_sock *igmp;
- pim_ifp->default_query_interval = query_interval;
+ pim_ifp->igmp_default_query_interval = query_interval;
- for (ALL_LIST_ELEMENTS_RO(pim_ifp->socket_list, sock_node, igmp)) {
+ for (ALL_LIST_ELEMENTS_RO(pim_ifp->igmp_socket_list, sock_node, igmp)) {
igmp_sock_query_interval_reconfig(igmp);
igmp_sock_query_reschedule(igmp);
}
int query_max_response_time_dsec)
{
struct listnode *sock_node;
- struct igmp_sock *igmp;
+ struct gm_sock *igmp;
struct listnode *grp_node;
- struct igmp_group *grp;
+ struct gm_group *grp;
- if (pim_ifp->query_max_response_time_dsec
+ if (pim_ifp->igmp_query_max_response_time_dsec
== query_max_response_time_dsec)
return;
}
/* scan socket groups */
- for (ALL_LIST_ELEMENTS_RO(pim_ifp->group_list, grp_node, grp)) {
+ for (ALL_LIST_ELEMENTS_RO(pim_ifp->igmp_group_list, grp_node, grp)) {
struct listnode *src_node;
- struct igmp_source *src;
+ struct gm_source *src;
/* reset group timers for groups in EXCLUDE mode */
if (grp->group_filtermode_isexcl)
}
/* IF ip igmp join */
- if (pim_ifp->join_list) {
+ if (pim_ifp->igmp_join_list) {
struct listnode *node;
- struct igmp_join *ij;
+ struct gm_join *ij;
for (ALL_LIST_ELEMENTS_RO(
- pim_ifp->join_list, node,
- ij)) {
+ pim_ifp->igmp_join_list,
+ node, ij)) {
char group_str[INET_ADDRSTRLEN];
char source_str
[INET_ADDRSTRLEN];
continue;
/* scan igmp groups */
- for (ALL_LIST_ELEMENTS_RO(pim_ifp->group_list, grpnode, grp)) {
+ for (ALL_LIST_ELEMENTS_RO(pim_ifp->igmp_group_list, grpnode,
+ grp)) {
struct listnode *srcnode;
- struct igmp_source *src;
+ struct gm_source *src;
/* scan group sources */
for (ALL_LIST_ELEMENTS_RO(grp->group_source_list,