3 * Copyright (C) 2008 Everton da Silva Marques
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License as published by
7 * the Free Software Foundation; either version 2 of the License, or
8 * (at your option) any later version.
10 * This program is distributed in the hope that it will be useful, but
11 * WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
13 * General Public License for more details.
15 * You should have received a copy of the GNU General Public License along
16 * with this program; see the file COPYING; if not, write to the Free Software
17 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
33 #include "pim_iface.h"
34 #include "pim_zebra.h"
38 #include "pim_upstream.h"
40 #include "pim_ssmpingd.h"
41 #include "pim_static.h"
44 #include "pim_zlookup.h"
47 const char *const PIM_ALL_SYSTEMS
= MCAST_ALL_SYSTEMS
;
48 const char *const PIM_ALL_ROUTERS
= MCAST_ALL_ROUTERS
;
49 const char *const PIM_ALL_PIM_ROUTERS
= MCAST_ALL_PIM_ROUTERS
;
50 const char *const PIM_ALL_IGMP_ROUTERS
= MCAST_ALL_IGMP_ROUTERS
;
52 struct thread_master
*master
= NULL
;
53 uint32_t qpim_debugs
= 0;
54 int qpim_mroute_socket_fd
= -1;
55 int64_t qpim_mroute_socket_creation
= 0; /* timestamp of creation */
56 int qpim_t_periodic
= PIM_DEFAULT_T_PERIODIC
; /* Period between Join/Prune Messages */
57 struct pim_assert_metric qpim_infinite_assert_metric
;
58 long qpim_rpf_cache_refresh_delay_msec
= 50;
59 struct thread
*qpim_rpf_cache_refresher
= NULL
;
60 int64_t qpim_rpf_cache_refresh_requests
= 0;
61 int64_t qpim_rpf_cache_refresh_events
= 0;
62 int64_t qpim_rpf_cache_refresh_last
= 0;
63 struct in_addr qpim_inaddr_any
;
64 struct list
*qpim_ssmpingd_list
= NULL
;
65 struct in_addr qpim_ssmpingd_group_addr
;
66 int64_t qpim_scan_oil_events
= 0;
67 int64_t qpim_scan_oil_last
= 0;
68 int64_t qpim_mroute_add_events
= 0;
69 int64_t qpim_mroute_add_last
= 0;
70 int64_t qpim_mroute_del_events
= 0;
71 int64_t qpim_mroute_del_last
= 0;
72 struct list
*qpim_static_route_list
= NULL
;
73 unsigned int qpim_keep_alive_time
= PIM_KEEPALIVE_PERIOD
;
74 signed int qpim_rp_keep_alive_time
= 0;
75 int64_t qpim_nexthop_lookups
= 0;
76 int qpim_packet_process
= PIM_DEFAULT_PACKET_PROCESS
;
77 uint8_t qpim_ecmp_enable
= 0;
78 uint8_t qpim_ecmp_rebalance_enable
= 0;
79 struct pim_instance
*pimg
= NULL
;
81 int32_t qpim_register_suppress_time
= PIM_REGISTER_SUPPRESSION_TIME_DEFAULT
;
82 int32_t qpim_register_probe_time
= PIM_REGISTER_PROBE_TIME_DEFAULT
;
84 static struct pim_instance
*pim_instance_init (vrf_id_t vrf_id
, afi_t afi
);
85 static void pim_instance_terminate (void);
88 pim_vrf_new (struct vrf
*vrf
)
90 zlog_debug ("VRF Created: %s(%d)", vrf
->name
, vrf
->vrf_id
);
95 pim_vrf_delete (struct vrf
*vrf
)
97 zlog_debug ("VRF Deletion: %s(%d)", vrf
->name
, vrf
->vrf_id
);
102 pim_vrf_enable (struct vrf
*vrf
)
105 if (!vrf
) // unexpected
108 if (vrf
->vrf_id
== VRF_DEFAULT
)
110 pimg
= pim_instance_init (VRF_DEFAULT
, AFI_IP
);
113 zlog_err ("%s %s: pim class init failure ", __FILE__
,
114 __PRETTY_FUNCTION__
);
116 * We will crash and burn otherwise
121 pimg
->send_v6_secondary
= 1;
128 pim_vrf_disable (struct vrf
*vrf
)
130 if (vrf
->vrf_id
== VRF_DEFAULT
)
133 if (vrf
->vrf_id
== VRF_DEFAULT
)
134 pim_instance_terminate ();
136 /* Note: This is a callback, the VRF will be deleted by the caller. */
143 vrf_add_hook (VRF_NEW_HOOK
, pim_vrf_new
);
144 vrf_add_hook (VRF_ENABLE_HOOK
, pim_vrf_enable
);
145 vrf_add_hook (VRF_DISABLE_HOOK
, pim_vrf_disable
);
146 vrf_add_hook (VRF_DELETE_HOOK
, pim_vrf_delete
);
152 pim_vrf_terminate (void)
154 vrf_add_hook (VRF_NEW_HOOK
, NULL
);
155 vrf_add_hook (VRF_ENABLE_HOOK
, NULL
);
156 vrf_add_hook (VRF_DISABLE_HOOK
, NULL
);
157 vrf_add_hook (VRF_DELETE_HOOK
, NULL
);
162 /* Key generate for pim->rpf_hash */
164 pim_rpf_hash_key (void *arg
)
166 struct pim_nexthop_cache
*r
= (struct pim_nexthop_cache
*) arg
;
168 return jhash_1word (r
->rpf
.rpf_addr
.u
.prefix4
.s_addr
, 0);
171 /* Compare pim->rpf_hash node data */
173 pim_rpf_equal (const void *arg1
, const void *arg2
)
175 const struct pim_nexthop_cache
*r1
=
176 (const struct pim_nexthop_cache
*) arg1
;
177 const struct pim_nexthop_cache
*r2
=
178 (const struct pim_nexthop_cache
*) arg2
;
180 return prefix_same (&r1
->rpf
.rpf_addr
, &r2
->rpf
.rpf_addr
);
183 /* Cleanup pim->rpf_hash each node data */
185 pim_rp_list_hash_clean (void *data
)
187 struct pim_nexthop_cache
*pnc
;
189 pnc
= (struct pim_nexthop_cache
*) data
;
190 if (pnc
->rp_list
->count
)
191 list_delete_all_node (pnc
->rp_list
);
192 if (pnc
->upstream_list
->count
)
193 list_delete_all_node (pnc
->upstream_list
);
197 pim_prefix_list_update (struct prefix_list
*plist
)
199 pim_rp_prefix_list_update (plist
);
200 pim_ssm_prefix_list_update (plist
);
201 pim_upstream_spt_prefix_list_update (plist
);
205 pim_instance_terminate (void)
207 /* Traverse and cleanup rpf_hash */
210 hash_clean (pimg
->rpf_hash
, (void *) pim_rp_list_hash_clean
);
211 hash_free (pimg
->rpf_hash
);
212 pimg
->rpf_hash
= NULL
;
217 pim_ssm_terminate (pimg
->ssm_info
);
218 pimg
->ssm_info
= NULL
;
221 XFREE (MTYPE_PIM_PIM_INSTANCE
, pimg
);
224 static void pim_free()
226 pim_ssmpingd_destroy();
228 pim_oil_terminate ();
230 pim_upstream_terminate ();
232 if (qpim_static_route_list
)
233 list_free(qpim_static_route_list
);
238 pim_route_map_terminate();
240 zclient_lookup_free ();
242 zprivs_terminate(&pimd_privs
);
245 static struct pim_instance
*
246 pim_instance_init (vrf_id_t vrf_id
, afi_t afi
)
248 struct pim_instance
*pim
;
250 pim
= XCALLOC (MTYPE_PIM_PIM_INSTANCE
, sizeof (struct pim_instance
));
254 pim
->vrf_id
= vrf_id
;
257 pim
->spt
.switchover
= PIM_SPT_IMMEDIATE
;
258 pim
->spt
.plist
= NULL
;
260 pim
->rpf_hash
= hash_create_size (256, pim_rpf_hash_key
, pim_rpf_equal
);
263 zlog_debug ("%s: NHT rpf hash init ", __PRETTY_FUNCTION__
);
265 pim
->ssm_info
= pim_ssm_init (vrf_id
);
266 if (!pim
->ssm_info
) {
267 pim_instance_terminate ();
276 qpim_rp_keep_alive_time
= PIM_RP_KEEPALIVE_PERIOD
;
280 if (!inet_aton(PIM_ALL_PIM_ROUTERS
, &qpim_all_pim_routers_addr
)) {
281 zlog_err("%s %s: could not solve %s to group address: errno=%d: %s",
282 __FILE__
, __PRETTY_FUNCTION__
,
283 PIM_ALL_PIM_ROUTERS
, errno
, safe_strerror(errno
));
290 pim_upstream_init ();
292 qpim_static_route_list
= list_new();
293 if (!qpim_static_route_list
) {
294 zlog_err("%s %s: failure: static_route_list=list_new()",
295 __FILE__
, __PRETTY_FUNCTION__
);
298 qpim_static_route_list
->del
= (void (*)(void *)) pim_static_route_free
;
300 pim_mroute_socket_enable();
302 qpim_inaddr_any
.s_addr
= PIM_NET_INADDR_ANY
;
305 RFC 4601: 4.6.3. Assert Metrics
308 infinite_assert_metric() {
309 return {1,infinity,infinity,0}
312 qpim_infinite_assert_metric
.rpt_bit_flag
= 1;
313 qpim_infinite_assert_metric
.metric_preference
= PIM_ASSERT_METRIC_PREFERENCE_MAX
;
314 qpim_infinite_assert_metric
.route_metric
= PIM_ASSERT_ROUTE_METRIC_MAX
;
315 qpim_infinite_assert_metric
.ip_address
= qpim_inaddr_any
;
326 /* reverse prefix_list_init */
327 prefix_list_add_hook (NULL
);
328 prefix_list_delete_hook (NULL
);
329 prefix_list_reset ();
331 pim_vrf_terminate ();