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
16 along with this program; see the file COPYING; if not, write to the
17 Free Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston,
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 const char *const PIM_ALL_SYSTEMS
= MCAST_ALL_SYSTEMS
;
45 const char *const PIM_ALL_ROUTERS
= MCAST_ALL_ROUTERS
;
46 const char *const PIM_ALL_PIM_ROUTERS
= MCAST_ALL_PIM_ROUTERS
;
47 const char *const PIM_ALL_IGMP_ROUTERS
= MCAST_ALL_IGMP_ROUTERS
;
49 struct thread_master
*master
= NULL
;
50 uint32_t qpim_debugs
= 0;
51 int qpim_mroute_socket_fd
= -1;
52 int64_t qpim_mroute_socket_creation
= 0; /* timestamp of creation */
53 struct thread
*qpim_mroute_socket_reader
= NULL
;
54 int qpim_mroute_oif_highest_vif_index
= -1;
55 struct list
*qpim_channel_oil_list
= NULL
;
56 int qpim_t_periodic
= PIM_DEFAULT_T_PERIODIC
; /* Period between Join/Prune Messages */
57 struct list
*qpim_upstream_list
= NULL
;
58 struct zclient
*qpim_zclient_update
= NULL
;
59 struct pim_assert_metric qpim_infinite_assert_metric
;
60 long qpim_rpf_cache_refresh_delay_msec
= 2000;
61 struct thread
*qpim_rpf_cache_refresher
= NULL
;
62 int64_t qpim_rpf_cache_refresh_requests
= 0;
63 int64_t qpim_rpf_cache_refresh_events
= 0;
64 int64_t qpim_rpf_cache_refresh_last
= 0;
65 struct in_addr qpim_inaddr_any
;
66 struct list
*qpim_ssmpingd_list
= NULL
;
67 struct in_addr qpim_ssmpingd_group_addr
;
68 int64_t qpim_scan_oil_events
= 0;
69 int64_t qpim_scan_oil_last
= 0;
70 int64_t qpim_mroute_add_events
= 0;
71 int64_t qpim_mroute_add_last
= 0;
72 int64_t qpim_mroute_del_events
= 0;
73 int64_t qpim_mroute_del_last
= 0;
74 struct list
*qpim_static_route_list
= NULL
;
75 unsigned int qpim_keep_alive_time
= PIM_KEEPALIVE_PERIOD
;
76 signed int qpim_rp_keep_alive_time
= 0;
77 int64_t qpim_nexthop_lookups
= 0;
79 int32_t qpim_register_suppress_time
= PIM_REGISTER_SUPPRESSION_TIME_DEFAULT
;
80 int32_t qpim_register_probe_time
= PIM_REGISTER_PROBE_TIME_DEFAULT
;
82 static void pim_free()
84 pim_ssmpingd_destroy();
86 if (qpim_channel_oil_list
)
87 list_free(qpim_channel_oil_list
);
89 if (qpim_upstream_list
)
90 list_free(qpim_upstream_list
);
92 if (qpim_static_route_list
)
93 list_free(qpim_static_route_list
);
95 pim_route_map_terminate();
98 pim_route_map_terminate();
105 qpim_rp_keep_alive_time
= PIM_RP_KEEPALIVE_PERIOD
;
109 if (!inet_aton(PIM_ALL_PIM_ROUTERS
, &qpim_all_pim_routers_addr
)) {
110 zlog_err("%s %s: could not solve %s to group address: errno=%d: %s",
111 __FILE__
, __PRETTY_FUNCTION__
,
112 PIM_ALL_PIM_ROUTERS
, errno
, safe_strerror(errno
));
117 qpim_channel_oil_list
= list_new();
118 if (!qpim_channel_oil_list
) {
119 zlog_err("%s %s: failure: channel_oil_list=list_new()",
120 __FILE__
, __PRETTY_FUNCTION__
);
123 qpim_channel_oil_list
->del
= (void (*)(void *)) pim_channel_oil_free
;
125 qpim_upstream_list
= list_new();
126 if (!qpim_upstream_list
) {
127 zlog_err("%s %s: failure: upstream_list=list_new()",
128 __FILE__
, __PRETTY_FUNCTION__
);
132 qpim_upstream_list
->del
= (void (*)(void *)) pim_upstream_free
;
134 qpim_static_route_list
= list_new();
135 if (!qpim_static_route_list
) {
136 zlog_err("%s %s: failure: static_route_list=list_new()",
137 __FILE__
, __PRETTY_FUNCTION__
);
140 qpim_static_route_list
->del
= (void (*)(void *)) pim_static_route_free
;
142 qpim_mroute_socket_fd
= -1; /* mark mroute as disabled */
143 qpim_mroute_oif_highest_vif_index
= -1;
145 qpim_inaddr_any
.s_addr
= PIM_NET_INADDR_ANY
;
148 RFC 4601: 4.6.3. Assert Metrics
151 infinite_assert_metric() {
152 return {1,infinity,infinity,0}
155 qpim_infinite_assert_metric
.rpt_bit_flag
= 1;
156 qpim_infinite_assert_metric
.metric_preference
= PIM_ASSERT_METRIC_PREFERENCE_MAX
;
157 qpim_infinite_assert_metric
.route_metric
= PIM_ASSERT_ROUTE_METRIC_MAX
;
158 qpim_infinite_assert_metric
.ip_address
= qpim_inaddr_any
;