diff options
| author | Sai Gomathi <nsaigomathi@vmware.com> | 2021-12-03 09:41:52 -0800 |
|---|---|---|
| committer | Sai Gomathi <nsaigomathi@vmware.com> | 2021-12-03 10:11:13 -0800 |
| commit | a16db099e44dd05f7c43e3770b22cff0c8d0d0f6 (patch) | |
| tree | 86a480cf0056ba5251a681094693302ff1690b1c /pimd/pim_igmpv3.c | |
| parent | 517001077fe2f038adfef09bdc9b09b7e9a654d0 (diff) | |
pimd: Modifying name of struct igmp_group to struct gm_group for IPv6.
Modifying name of struct igmp_group to struct gm_group, which is to be used
by both IPv4 and IPv6(for both MLD and IGMP).
Co-authored-by: Mobashshera Rasool <mrasool@vmware.com>
Co-authored-by: Sarita Patra <saritap@vmware.com>
Signed-off-by: Sai Gomathi <nsaigomathi@vmware.com>
Diffstat (limited to 'pimd/pim_igmpv3.c')
| -rw-r--r-- | pimd/pim_igmpv3.c | 89 |
1 files changed, 44 insertions, 45 deletions
diff --git a/pimd/pim_igmpv3.c b/pimd/pim_igmpv3.c index 83cf5be242..e91b48c937 100644 --- a/pimd/pim_igmpv3.c +++ b/pimd/pim_igmpv3.c @@ -33,11 +33,11 @@ #include "pim_zebra.h" #include "pim_oil.h" -static void group_retransmit_timer_on(struct igmp_group *group); -static long igmp_group_timer_remain_msec(struct igmp_group *group); +static void group_retransmit_timer_on(struct gm_group *group); +static long igmp_group_timer_remain_msec(struct gm_group *group); static long igmp_source_timer_remain_msec(struct gm_source *source); -static void group_query_send(struct igmp_group *group); -static void source_query_send_by_flag(struct igmp_group *group, +static void group_query_send(struct gm_group *group); +static void source_query_send_by_flag(struct gm_group *group, int num_sources_tosend); static void on_trace(const char *label, struct interface *ifp, @@ -57,7 +57,7 @@ static void on_trace(const char *label, struct interface *ifp, } } -static inline long igmp_gmi_msec(struct igmp_group *group) +static inline long igmp_gmi_msec(struct gm_group *group) { struct pim_interface *pim_ifp = group->interface->info; struct igmp_sock *igmp; @@ -73,7 +73,7 @@ static inline long igmp_gmi_msec(struct igmp_group *group) pim_ifp->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; @@ -121,7 +121,7 @@ void igmp_group_reset_gmi(struct igmp_group *group) static int igmp_source_timer(struct thread *t) { struct gm_source *source; - struct igmp_group *group; + struct gm_group *group; source = THREAD_ARG(t); @@ -183,8 +183,7 @@ static int igmp_source_timer(struct thread *t) return 0; } -static void source_timer_off(struct igmp_group *group, - struct gm_source *source) +static void source_timer_off(struct gm_group *group, struct gm_source *source) { if (!source->t_source_timer) return; @@ -204,7 +203,7 @@ static void source_timer_off(struct igmp_group *group, THREAD_OFF(source->t_source_timer); } -static void igmp_source_timer_on(struct igmp_group *group, +static void igmp_source_timer_on(struct gm_group *group, struct gm_source *source, long interval_msec) { source_timer_off(group, source); @@ -234,7 +233,7 @@ static void igmp_source_timer_on(struct igmp_group *group, igmp_source_forward_start(pim_ifp->pim, source); } -void igmp_source_reset_gmi(struct igmp_group *group, struct gm_source *source) +void igmp_source_reset_gmi(struct gm_group *group, struct gm_source *source) { long group_membership_interval_msec; struct interface *ifp; @@ -262,7 +261,7 @@ void igmp_source_reset_gmi(struct igmp_group *group, struct gm_source *source) igmp_source_timer_on(group, source, group_membership_interval_msec); } -static void source_mark_delete_flag(struct igmp_group *group) +static void source_mark_delete_flag(struct gm_group *group) { struct listnode *src_node; struct gm_source *src; @@ -272,7 +271,7 @@ static void source_mark_delete_flag(struct igmp_group *group) } } -static void source_mark_send_flag(struct igmp_group *group) +static void source_mark_send_flag(struct gm_group *group) { struct listnode *src_node; struct gm_source *src; @@ -282,7 +281,7 @@ static void source_mark_send_flag(struct igmp_group *group) } } -static int source_mark_send_flag_by_timer(struct igmp_group *group) +static int source_mark_send_flag_by_timer(struct gm_group *group) { struct listnode *src_node; struct gm_source *src; @@ -314,7 +313,7 @@ static void source_clear_send_flag(struct list *source_list) /* Any source (*,G) is forwarded only if mode is EXCLUDE {empty} */ -static void group_exclude_fwd_anysrc_ifempty(struct igmp_group *group) +static void group_exclude_fwd_anysrc_ifempty(struct gm_group *group) { struct pim_interface *pim_ifp = group->interface->info; @@ -347,7 +346,7 @@ static void source_channel_oil_detach(struct gm_source *source) */ void igmp_source_delete(struct gm_source *source) { - struct igmp_group *group; + struct gm_group *group; struct in_addr src; group = source->source_group; @@ -428,8 +427,8 @@ void igmp_source_delete_expired(struct list *source_list) igmp_source_delete(src); } -struct gm_source *igmp_find_source_by_addr(struct igmp_group *group, - struct in_addr src_addr) +struct gm_source *igmp_find_source_by_addr(struct gm_group *group, + struct in_addr src_addr) { struct listnode *src_node; struct gm_source *src; @@ -441,8 +440,8 @@ struct gm_source *igmp_find_source_by_addr(struct igmp_group *group, return 0; } -struct gm_source *igmp_get_source_by_addr(struct igmp_group *group, - struct in_addr src_addr, bool *new) +struct gm_source *igmp_get_source_by_addr(struct gm_group *group, + struct in_addr src_addr, bool *new) { struct gm_source *src; @@ -487,7 +486,7 @@ static void allow(struct igmp_sock *igmp, struct in_addr from, struct in_addr *sources) { struct gm_source *source; - struct igmp_group *group; + struct gm_group *group; int i; if (num_sources == 0) { @@ -559,7 +558,7 @@ void igmpv3_report_isin(struct igmp_sock *igmp, struct in_addr from, allow(igmp, from, group_addr, num_sources, sources); } -static void isex_excl(struct igmp_group *group, int num_sources, +static void isex_excl(struct gm_group *group, int num_sources, struct in_addr *sources) { struct gm_source *source; @@ -614,7 +613,7 @@ static void isex_excl(struct igmp_group *group, int num_sources, source_delete_by_flag(group->group_source_list); } -static void isex_incl(struct igmp_group *group, int num_sources, +static void isex_incl(struct gm_group *group, int num_sources, struct in_addr *sources) { int i; @@ -664,7 +663,7 @@ void igmpv3_report_isex(struct igmp_sock *igmp, struct in_addr from, struct in_addr *sources, int from_igmp_v2_report) { struct interface *ifp = igmp->interface; - struct igmp_group *group; + struct gm_group *group; on_trace(__func__, ifp, from, group_addr, num_sources, sources); @@ -696,7 +695,7 @@ void igmpv3_report_isex(struct igmp_sock *igmp, struct in_addr from, igmp_group_reset_gmi(group); } -static void toin_incl(struct igmp_group *group, int num_sources, +static void toin_incl(struct gm_group *group, int num_sources, struct in_addr *sources) { int num_sources_tosend = listcount(group->group_source_list); @@ -734,7 +733,7 @@ static void toin_incl(struct igmp_group *group, int num_sources, } } -static void toin_excl(struct igmp_group *group, int num_sources, +static void toin_excl(struct gm_group *group, int num_sources, struct in_addr *sources) { int num_sources_tosend; @@ -781,7 +780,7 @@ void igmpv3_report_toin(struct igmp_sock *igmp, struct in_addr from, struct in_addr *sources) { struct interface *ifp = igmp->interface; - struct igmp_group *group; + struct gm_group *group; on_trace(__func__, ifp, from, group_addr, num_sources, sources); @@ -812,7 +811,7 @@ void igmpv3_report_toin(struct igmp_sock *igmp, struct in_addr from, } } -static void toex_incl(struct igmp_group *group, int num_sources, +static void toex_incl(struct gm_group *group, int num_sources, struct in_addr *sources) { int num_sources_tosend = 0; @@ -861,7 +860,7 @@ static void toex_incl(struct igmp_group *group, int num_sources, group_exclude_fwd_anysrc_ifempty(group); } -static void toex_excl(struct igmp_group *group, int num_sources, +static void toex_excl(struct gm_group *group, int num_sources, struct in_addr *sources) { int num_sources_tosend = 0; @@ -942,7 +941,7 @@ void igmpv3_report_toex(struct igmp_sock *igmp, struct in_addr from, struct in_addr *sources) { struct interface *ifp = igmp->interface; - struct igmp_group *group; + struct gm_group *group; on_trace(__func__, ifp, from, group_addr, num_sources, sources); @@ -976,7 +975,7 @@ void igmpv3_report_allow(struct igmp_sock *igmp, struct in_addr from, allow(igmp, from, group_addr, num_sources, sources); } -static void igmp_send_query_group(struct igmp_group *group, char *query_buf, +static void igmp_send_query_group(struct gm_group *group, char *query_buf, size_t query_buf_size, int num_sources, int s_flag) { @@ -1002,7 +1001,7 @@ static void igmp_send_query_group(struct igmp_group *group, char *query_buf, larger than LMQT, the "Suppress Router-Side Processing" bit is set in the query message. */ -static void group_retransmit_group(struct igmp_group *group) +static void group_retransmit_group(struct gm_group *group) { struct pim_interface *pim_ifp; long lmqc; /* Last Member Query Count */ @@ -1067,7 +1066,7 @@ static void group_retransmit_group(struct igmp_group *group) or equal to LMQT. If either of the two calculated messages does not contain any sources, then its transmission is suppressed. */ -static int group_retransmit_sources(struct igmp_group *group, +static int group_retransmit_sources(struct gm_group *group, int send_with_sflag_set) { struct pim_interface *pim_ifp; @@ -1214,7 +1213,7 @@ static int group_retransmit_sources(struct igmp_group *group, static int igmp_group_retransmit(struct thread *t) { - struct igmp_group *group; + struct gm_group *group; int num_retransmit_sources_left; int send_with_sflag_set; /* boolean */ @@ -1271,7 +1270,7 @@ static int igmp_group_retransmit(struct thread *t) if group retransmit timer isn't running, starts it; otherwise, do nothing */ -static void group_retransmit_timer_on(struct igmp_group *group) +static void group_retransmit_timer_on(struct gm_group *group) { struct pim_interface *pim_ifp; long lmqi_msec; /* Last Member Query Interval */ @@ -1300,7 +1299,7 @@ static void group_retransmit_timer_on(struct igmp_group *group) &group->t_group_query_retransmit_timer); } -static long igmp_group_timer_remain_msec(struct igmp_group *group) +static long igmp_group_timer_remain_msec(struct gm_group *group) { return pim_time_timer_remain_msec(group->t_group_timer); } @@ -1313,7 +1312,7 @@ static long igmp_source_timer_remain_msec(struct gm_source *source) /* RFC3376: 6.6.3.1. Building and Sending Group Specific Queries */ -static void group_query_send(struct igmp_group *group) +static void group_query_send(struct gm_group *group) { struct pim_interface *pim_ifp; long lmqc; /* Last Member Query Count */ @@ -1338,7 +1337,7 @@ static void group_query_send(struct igmp_group *group) /* RFC3376: 6.6.3.2. Building and Sending Group and Source Specific Queries */ -static void source_query_send_by_flag(struct igmp_group *group, +static void source_query_send_by_flag(struct gm_group *group, int num_sources_tosend) { struct pim_interface *pim_ifp; @@ -1384,7 +1383,7 @@ static void source_query_send_by_flag(struct igmp_group *group, group_retransmit_timer_on(group); } -static void block_excl(struct igmp_group *group, int num_sources, +static void block_excl(struct gm_group *group, int num_sources, struct in_addr *sources) { int num_sources_tosend = 0; @@ -1430,7 +1429,7 @@ static void block_excl(struct igmp_group *group, int num_sources, } } -static void block_incl(struct igmp_group *group, int num_sources, +static void block_incl(struct gm_group *group, int num_sources, struct in_addr *sources) { int num_sources_tosend = 0; @@ -1466,7 +1465,7 @@ void igmpv3_report_block(struct igmp_sock *igmp, struct in_addr from, struct in_addr *sources) { struct interface *ifp = igmp->interface; - struct igmp_group *group; + struct gm_group *group; on_trace(__func__, ifp, from, group_addr, num_sources, sources); @@ -1485,7 +1484,7 @@ void igmpv3_report_block(struct igmp_sock *igmp, struct in_addr from, } } -void igmp_group_timer_lower_to_lmqt(struct igmp_group *group) +void igmp_group_timer_lower_to_lmqt(struct gm_group *group) { struct interface *ifp; struct pim_interface *pim_ifp; @@ -1531,7 +1530,7 @@ void igmp_group_timer_lower_to_lmqt(struct igmp_group *group) void igmp_source_timer_lower_to_lmqt(struct gm_source *source) { - struct igmp_group *group; + struct gm_group *group; struct interface *ifp; struct pim_interface *pim_ifp; char *ifname; @@ -1565,7 +1564,7 @@ void igmp_source_timer_lower_to_lmqt(struct gm_source *source) igmp_source_timer_on(group, source, lmqt_msec); } -void igmp_v3_send_query(struct igmp_group *group, int fd, const char *ifname, +void igmp_v3_send_query(struct gm_group *group, int fd, const char *ifname, char *query_buf, int query_buf_size, int num_sources, struct in_addr dst_addr, struct in_addr group_addr, int query_max_response_time_dsec, uint8_t s_flag, @@ -1769,7 +1768,7 @@ void igmp_v3_recv_query(struct igmp_sock *igmp, const char *from_str, "General IGMP query v3 from %s on %s: Suppress Router-Side Processing flag is clear", from_str, ifp->name); } else { - struct igmp_group *group; + struct gm_group *group; /* this is a non-general query: perform timer updates */ |
