diff options
| author | Stephen Worley <sworley@nvidia.com> | 2021-12-15 17:40:53 -0500 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-12-15 17:40:53 -0500 |
| commit | ad1229a077f09d7d7bcfe7bf453730666e6324f5 (patch) | |
| tree | 3e5b4ba6f452fa4a2edacd1748cd27a5791bf71c /pimd/pim_igmp.c | |
| parent | 24f91867d2e6e687a3130d2b665e85795192d7cf (diff) | |
| parent | 29e582259046e8a48c1a8e81a8eaef9804bb4c5d (diff) | |
Merge pull request #10215 from FRRouting/revert-10164-name_change
Revert "pimd: Modifying members of pim_interface to accommodate IPv6 changes"
Diffstat (limited to 'pimd/pim_igmp.c')
| -rw-r--r-- | pimd/pim_igmp.c | 71 |
1 files changed, 36 insertions, 35 deletions
diff --git a/pimd/pim_igmp.c b/pimd/pim_igmp.c index 5b201c8586..49ec804df5 100644 --- a/pimd/pim_igmp.c +++ b/pimd/pim_igmp.c @@ -226,7 +226,7 @@ void pim_igmp_other_querier_timer_on(struct gm_sock *igmp) */ other_querier_present_interval_msec = PIM_IGMP_OQPI_MSEC( igmp->querier_robustness_variable, igmp->querier_query_interval, - pim_ifp->query_max_response_time_dsec); + pim_ifp->igmp_query_max_response_time_dsec); if (PIM_DEBUG_IGMP_TRACE) { char ifaddr_str[INET_ADDRSTRLEN]; @@ -351,10 +351,11 @@ static int igmp_recv_query(struct gm_sock *igmp, int query_version, * For now we will simplify things and inform the user that they need to * configure all PIM routers to use the same version of IGMP. */ - if (query_version != pim_ifp->version) { + if (query_version != pim_ifp->igmp_version) { zlog_warn( "Recv IGMP query v%d from %s on %s but we are using v%d, please configure all PIM routers on this subnet to use the same IGMP version", - query_version, from_str, ifp->name, pim_ifp->version); + query_version, from_str, ifp->name, + pim_ifp->igmp_version); return 0; } @@ -635,14 +636,14 @@ void pim_igmp_general_query_on(struct gm_sock *igmp) * newly configured igmp interface send it out in 1 second * just to give the entire world a tiny bit of time to settle * else the query interval is: - * query_interval = pim_ifp->default_query_interval >> 2; + * query_interval = pim_ifp->igmp_default_query_interval >> 2; */ if (igmp->startup_query_count == igmp->querier_robustness_variable) query_interval = 1; else - query_interval = - PIM_IGMP_SQI(pim_ifp->default_query_interval); + query_interval = PIM_IGMP_SQI( + pim_ifp->igmp_default_query_interval); --igmp->startup_query_count; } else { @@ -695,7 +696,7 @@ static int pim_igmp_general_query(struct thread *t) pim_ifp = igmp->interface->info; - if (pim_ifp->version == 3) { + if (pim_ifp->igmp_version == 3) { query_buf_size = PIM_IGMP_BUFSIZE_WRITE; } else { query_buf_size = IGMP_V12_MSG_SIZE; @@ -725,10 +726,10 @@ static int pim_igmp_general_query(struct thread *t) querier_str, dst_str, igmp->interface->name); } - igmp_send_query(pim_ifp->version, 0 /* igmp_group */, igmp->fd, + igmp_send_query(pim_ifp->igmp_version, 0 /* igmp_group */, igmp->fd, igmp->interface->name, query_buf, sizeof(query_buf), 0 /* num_sources */, dst_addr, group_addr, - pim_ifp->query_max_response_time_dsec, + pim_ifp->igmp_query_max_response_time_dsec, 1 /* s_flag: always set for general queries */, igmp->querier_robustness_variable, igmp->querier_query_interval); @@ -786,7 +787,7 @@ void igmp_startup_mode_on(struct gm_sock *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 gm_group *group) @@ -843,8 +844,8 @@ void igmp_group_delete(struct gm_group *group) group_timer_off(group); igmp_group_count_decr(pim_ifp); - listnode_delete(pim_ifp->group_list, group); - hash_release(pim_ifp->group_hash, group); + listnode_delete(pim_ifp->igmp_group_list, group); + hash_release(pim_ifp->igmp_group_hash, group); igmp_group_free(group); } @@ -874,11 +875,11 @@ void igmp_sock_delete(struct gm_sock *igmp) pim_ifp = igmp->interface->info; - listnode_delete(pim_ifp->socket_list, igmp); + listnode_delete(pim_ifp->igmp_socket_list, igmp); igmp_sock_free(igmp); - if (!listcount(pim_ifp->socket_list)) + if (!listcount(pim_ifp->igmp_socket_list)) pim_igmp_if_reset(pim_ifp); } @@ -890,8 +891,8 @@ void igmp_sock_delete_all(struct interface *ifp) pim_ifp = ifp->info; - for (ALL_LIST_ELEMENTS(pim_ifp->socket_list, igmp_node, igmp_nextnode, - igmp)) { + for (ALL_LIST_ELEMENTS(pim_ifp->igmp_socket_list, igmp_node, + igmp_nextnode, igmp)) { igmp_sock_delete(igmp); } } @@ -918,15 +919,15 @@ void pim_igmp_if_init(struct pim_interface *pim_ifp, struct interface *ifp) { char hash_name[64]; - pim_ifp->socket_list = list_new(); - pim_ifp->socket_list->del = (void (*)(void *))igmp_sock_free; + pim_ifp->igmp_socket_list = list_new(); + pim_ifp->igmp_socket_list->del = (void (*)(void *))igmp_sock_free; - pim_ifp->group_list = list_new(); - pim_ifp->group_list->del = (void (*)(void *))igmp_group_free; + pim_ifp->igmp_group_list = list_new(); + pim_ifp->igmp_group_list->del = (void (*)(void *))igmp_group_free; snprintf(hash_name, sizeof(hash_name), "IGMP %s hash", ifp->name); - pim_ifp->group_hash = hash_create(igmp_group_hash_key, - igmp_group_hash_equal, hash_name); + pim_ifp->igmp_group_hash = hash_create( + igmp_group_hash_key, igmp_group_hash_equal, hash_name); } void pim_igmp_if_reset(struct pim_interface *pim_ifp) @@ -934,7 +935,7 @@ void pim_igmp_if_reset(struct pim_interface *pim_ifp) struct listnode *grp_node, *grp_nextnode; 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); } @@ -944,13 +945,13 @@ void pim_igmp_if_fini(struct pim_interface *pim_ifp) { 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 gm_sock *igmp_sock_new(int fd, struct in_addr ifaddr, @@ -977,7 +978,7 @@ static struct gm_sock *igmp_sock_new(int fd, struct in_addr ifaddr, igmp->t_igmp_query_timer = NULL; igmp->t_other_querier_timer = NULL; /* no other querier present */ igmp->querier_robustness_variable = - pim_ifp->default_robustness_variable; + pim_ifp->igmp_default_robustness_variable; igmp->sock_creation = pim_time_monotonic_sec(); igmp_stats_init(&igmp->rx_stats); @@ -992,7 +993,7 @@ static struct gm_sock *igmp_sock_new(int fd, struct in_addr ifaddr, /* igmp_startup_mode_on() will reset QQI: - igmp->querier_query_interval = pim_ifp->default_query_interval; + igmp->querier_query_interval = pim_ifp->igmp_default_query_interval; */ igmp_startup_mode_on(igmp); pim_igmp_general_query_on(igmp); @@ -1187,7 +1188,7 @@ struct gm_group *find_group_by_addr(struct gm_sock *igmp, 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 gm_group *igmp_add_group_by_addr(struct gm_sock *igmp, @@ -1245,8 +1246,8 @@ struct gm_group *igmp_add_group_by_addr(struct gm_sock *igmp, /* initialize new group as INCLUDE {empty} */ group->group_filtermode_isexcl = 0; /* 0=INCLUDE, 1=EXCLUDE */ - listnode_add(pim_ifp->group_list, group); - group = hash_get(pim_ifp->group_hash, group, hash_alloc_intern); + listnode_add(pim_ifp->igmp_group_list, group); + group = hash_get(pim_ifp->igmp_group_hash, group, hash_alloc_intern); if (PIM_DEBUG_IGMP_TRACE) { char group_str[INET_ADDRSTRLEN]; @@ -1319,7 +1320,7 @@ void igmp_send_query_on_intf(struct interface *ifp, int igmp_ver) zlog_debug("Issuing general query on request on %s", ifp->name); - 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)) { char query_buf[query_buf_size]; @@ -1327,7 +1328,7 @@ void igmp_send_query_on_intf(struct interface *ifp, int igmp_ver) igmp->interface->name, query_buf, sizeof(query_buf), 0 /* num_sources */, dst_addr, group_addr, - pim_ifp->query_max_response_time_dsec, + pim_ifp->igmp_query_max_response_time_dsec, 1 /* s_flag: always set for general queries */, igmp->querier_robustness_variable, igmp->querier_query_interval); |
