]>
git.ipfire.org Git - thirdparty/lldpd.git/blob - src/daemon/lldpd.h
aacb39e4d38da49725b52a4526211d476aedb62c
1 /* -*- mode: c; c-file-style: "openbsd" -*- */
3 * Copyright (c) 2008 Vincent Bernat <bernat@luffy.cx>
5 * Permission to use, copy, modify, and/or distribute this software for any
6 * purpose with or without fee is hereby granted, provided that the above
7 * copyright notice and this permission notice appear in all copies.
9 * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
10 * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
11 * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
12 * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
13 * WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
14 * ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
15 * OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
25 #ifdef HAVE_VALGRIND_VALGRIND_H
26 # include <valgrind/valgrind.h>
28 # define RUNNING_ON_VALGRIND 0
34 #include <sys/queue.h>
35 #include <sys/types.h>
36 #include <netinet/if_ether.h>
37 #include <netinet/in.h>
48 #if defined (ENABLE_CDP) || defined (ENABLE_FDP)
49 # include "protocols/cdp.h"
52 # include "protocols/sonmp.h"
55 # include "protocols/edp.h"
58 #include "../compat/compat.h"
59 #include "../marshal.h"
62 #include "../lldpd-structs.h"
64 /* We don't want to import event2/event.h. We only need those as
69 #define SYSFS_CLASS_NET "/sys/class/net/"
70 #define SYSFS_CLASS_DMI "/sys/class/dmi/id/"
71 #define LLDPD_TX_INTERVAL 30
72 #define LLDPD_TX_HOLD 4
73 #define LLDPD_TTL LLDPD_TX_INTERVAL * LLDPD_TX_HOLD
74 #define LLDPD_TX_MSGDELAY 1
75 #define LLDPD_MAX_NEIGHBORS 4
76 #define LLDPD_FAST_TX_INTERVAL 1
77 #define LLDPD_FAST_INIT 4
79 #define USING_AGENTX_SUBAGENT_MODULE 1
81 #define PROTO_SEND_SIG struct lldpd *, struct lldpd_hardware *
82 #define PROTO_DECODE_SIG struct lldpd *, char *, int, struct lldpd_hardware *, struct lldpd_chassis **, struct lldpd_port **
83 #define PROTO_GUESS_SIG char *, int
85 #define ALIGNED_CAST(TYPE, ATTR) ((TYPE) (void *) (ATTR))
88 int mode
; /* > 0 mode identifier (unique per protocol) */
89 int enabled
; /* Is this protocol enabled? */
90 char *name
; /* Name of protocol */
91 char arg
; /* Argument to enable this protocol */
92 int(*send
)(PROTO_SEND_SIG
); /* How to send a frame */
93 int(*decode
)(PROTO_DECODE_SIG
); /* How to decode a frame */
94 int(*guess
)(PROTO_GUESS_SIG
); /* Can be NULL, use MAC address in this case */
95 u_int8_t mac
[ETHER_ADDR_LEN
]; /* Destination MAC address used by this protocol */
98 #define SMART_HIDDEN(port) (port->p_hidden_in)
103 struct lldpd_hardware
*lldpd_get_hardware(struct lldpd
*,
104 char *, int, struct lldpd_ops
*);
105 struct lldpd_hardware
*lldpd_alloc_hardware(struct lldpd
*, char *, int);
106 void lldpd_hardware_cleanup(struct lldpd
*, struct lldpd_hardware
*);
107 struct lldpd_mgmt
*lldpd_alloc_mgmt(int family
, void *addr
, size_t addrsize
, u_int32_t iface
);
108 void lldpd_recv(struct lldpd
*, struct lldpd_hardware
*, int);
109 void lldpd_send(struct lldpd_hardware
*);
110 void lldpd_loop(struct lldpd
*);
111 int lldpd_main(int, char **, char **);
112 void lldpd_update_localports(struct lldpd
*);
113 void lldpd_cleanup(struct lldpd
*);
116 u_int16_t
frame_checksum(const u_int8_t
*, int, int);
119 void levent_loop(struct lldpd
*);
120 void levent_hardware_init(struct lldpd_hardware
*);
121 void levent_hardware_add_fd(struct lldpd_hardware
*, int);
122 void levent_hardware_release(struct lldpd_hardware
*);
123 void levent_ctl_notify(char *, int, struct lldpd_port
*);
124 void levent_send_now(struct lldpd
*);
125 void levent_update_now(struct lldpd
*);
126 int levent_iface_subscribe(struct lldpd
*, int);
127 void levent_schedule_pdu(struct lldpd_hardware
*);
128 void levent_schedule_cleanup(struct lldpd
*);
129 int levent_make_socket_nonblocking(int);
130 int levent_make_socket_blocking(int);
133 int lldp_send_shutdown(PROTO_SEND_SIG
);
134 int lldp_send(PROTO_SEND_SIG
);
135 int lldp_decode(PROTO_DECODE_SIG
);
139 int cdpv1_send(PROTO_SEND_SIG
);
140 int cdpv2_send(PROTO_SEND_SIG
);
141 int cdpv1_guess(PROTO_GUESS_SIG
);
142 int cdpv2_guess(PROTO_GUESS_SIG
);
144 #if defined (ENABLE_CDP) || defined (ENABLE_FDP)
145 int cdp_decode(PROTO_DECODE_SIG
);
148 int fdp_send(PROTO_SEND_SIG
);
153 int sonmp_send(PROTO_SEND_SIG
);
154 int sonmp_decode(PROTO_DECODE_SIG
);
159 int edp_send(PROTO_SEND_SIG
);
160 int edp_decode(PROTO_DECODE_SIG
);
164 #ifdef ENABLE_LLDPMED
168 char *dmi_manuf(void);
169 char *dmi_model(void);
170 char *dmi_asset(void);
175 void agent_shutdown(void);
176 void agent_init(struct lldpd
*, const char *);
177 void agent_notify(struct lldpd_hardware
*, int, struct lldpd_port
*);
180 #ifdef ENABLE_PRIVSEP
182 void agent_priv_register_domain(void);
187 client_handle_client(struct lldpd
*cfg
,
188 ssize_t(*send
)(void *, int, void *, size_t),
190 enum hmsg_type type
, void *buffer
, size_t n
,
194 void priv_init(const char*, int, uid_t
, gid_t
);
195 void priv_wait(void);
196 void priv_ctl_cleanup(const char *ctlname
);
197 char *priv_gethostname(void);
199 int priv_open(char*);
200 void asroot_open(void);
201 int priv_ethtool(char*, void*, size_t);
202 void asroot_ethtool(void);
203 int priv_iface_mac(char*, void*, size_t);
204 void asroot_iface_mac(void);
206 int priv_iface_init(int, char *);
207 int asroot_iface_init_os(int, char *, int *);
208 int priv_iface_multicast(const char *, u_int8_t
*, int);
209 int priv_iface_description(const char *, const char *);
210 int asroot_iface_description_os(const char *, const char *);
211 int priv_iface_promisc(const char*);
212 int asroot_iface_promisc_os(const char *);
213 int priv_snmp_socket(struct sockaddr_un
*);
217 PRIV_DELETE_CTL_SOCKET
,
222 PRIV_IFACE_MULTICAST
,
223 PRIV_IFACE_DESCRIPTION
,
230 #if defined USE_SECCOMP && defined ENABLE_PRIVSEP
231 int priv_seccomp_init(int, int);
239 int may_read(enum priv_context
, void *, size_t);
240 void must_read(enum priv_context
, void *, size_t);
241 void must_write(enum priv_context
, const void *, size_t);
242 void priv_privileged_fd(int);
243 void priv_unprivileged_fd(int);
244 int priv_fd(enum priv_context
);
245 int receive_fd(enum priv_context
);
246 void send_fd(enum priv_context
, int);
250 /* BPF filter to get revelant information from interfaces */
251 /* LLDP: "ether proto 0x88cc and ether dst 01:80:c2:00:00:0e" */
252 /* FDP: "ether dst 01:e0:52:cc:cc:cc" */
253 /* CDP: "ether dst 01:00:0c:cc:cc:cc" */
254 /* SONMP: "ether dst 01:00:81:00:01:00" */
255 /* EDP: "ether dst 00:e0:2b:00:00:00" */
256 /* For optimization purpose, we first check if the first bit of the
257 first byte is 1. if not, this can only be an EDP packet:
259 tcpdump -dd "(ether[0] & 1 = 1 and
260 ((ether proto 0x88cc and ether dst 01:80:c2:00:00:0e) or
261 (ether dst 01:e0:52:cc:cc:cc) or
262 (ether dst 01:00:0c:cc:cc:cc) or
263 (ether dst 01:00:81:00:01:00))) or
264 (ether dst 00:e0:2b:00:00:00)"
267 #define LLDPD_FILTER_F \
268 { 0x30, 0, 0, 0x00000000 }, \
269 { 0x54, 0, 0, 0x00000001 }, \
270 { 0x15, 0, 14, 0x00000001 }, \
271 { 0x28, 0, 0, 0x0000000c }, \
272 { 0x15, 0, 4, 0x000088cc }, \
273 { 0x20, 0, 0, 0x00000002 }, \
274 { 0x15, 0, 2, 0xc200000e }, \
275 { 0x28, 0, 0, 0x00000000 }, \
276 { 0x15, 12, 13, 0x00000180 }, \
277 { 0x20, 0, 0, 0x00000002 }, \
278 { 0x15, 0, 2, 0x52cccccc }, \
279 { 0x28, 0, 0, 0x00000000 }, \
280 { 0x15, 8, 9, 0x000001e0 }, \
281 { 0x15, 1, 0, 0x0ccccccc }, \
282 { 0x15, 0, 2, 0x81000100 }, \
283 { 0x28, 0, 0, 0x00000000 }, \
284 { 0x15, 4, 5, 0x00000100 }, \
285 { 0x20, 0, 0, 0x00000002 }, \
286 { 0x15, 0, 3, 0x2b000000 }, \
287 { 0x28, 0, 0, 0x00000000 }, \
288 { 0x15, 0, 1, 0x000000e0 }, \
289 { 0x6, 0, 0, 0x0000ffff }, \
290 { 0x6, 0, 0, 0x00000000 },
292 /* This function is responsible to refresh information about interfaces. It is
293 * OS specific but should be present for each OS. It can use the functions in
294 * `interfaces.c` as helper by providing a list of OS-independent interface
296 void interfaces_update(struct lldpd
*);
299 /* An interface cannot be both physical and (bridge or bond or vlan) */
300 #define IFACE_PHYSICAL_T (1 << 0) /* Physical interface */
301 #define IFACE_BRIDGE_T (1 << 1) /* Bridge interface */
302 #define IFACE_BOND_T (1 << 2) /* Bond interface */
303 #define IFACE_VLAN_T (1 << 3) /* VLAN interface */
304 #define IFACE_WIRELESS_T (1 << 4) /* Wireless interface */
305 struct interfaces_device
{
306 TAILQ_ENTRY(interfaces_device
) next
;
307 int ignore
; /* Ignore this interface */
308 int index
; /* Index */
309 char *name
; /* Name */
310 char *alias
; /* Alias */
311 char *address
; /* MAC address */
312 char *driver
; /* Driver (for whitelisting purpose) */
313 int flags
; /* Flags (IFF_*) */
315 int type
; /* Type (see IFACE_*_T) */
316 int vlanid
; /* If a VLAN, what is the VLAN ID? */
317 struct interfaces_device
*lower
; /* Lower interface (for a VLAN for example) */
318 struct interfaces_device
*upper
; /* Upper interface (for a bridge or a bond) */
320 /* The following are OS specific. Should be static (no free function) */
322 int lower_idx
; /* Index to lower interface */
323 int upper_idx
; /* Index to upper interface */
326 struct interfaces_address
{
327 TAILQ_ENTRY(interfaces_address
) next
;
328 int index
; /* Index */
329 int flags
; /* Flags */
330 struct sockaddr_storage address
; /* Address */
332 /* The following are OS specific. */
335 TAILQ_HEAD(interfaces_device_list
, interfaces_device
);
336 TAILQ_HEAD(interfaces_address_list
, interfaces_address
);
337 void interfaces_free_device(struct interfaces_device
*);
338 void interfaces_free_address(struct interfaces_address
*);
339 void interfaces_free_devices(struct interfaces_device_list
*);
340 void interfaces_free_addresses(struct interfaces_address_list
*);
341 struct interfaces_device
* interfaces_indextointerface(
342 struct interfaces_device_list
*,
344 struct interfaces_device
* interfaces_nametointerface(
345 struct interfaces_device_list
*,
348 void interfaces_helper_promisc(struct lldpd
*,
349 struct lldpd_hardware
*);
350 void interfaces_helper_whitelist(struct lldpd
*,
351 struct interfaces_device_list
*);
352 void interfaces_helper_chassis(struct lldpd
*,
353 struct interfaces_device_list
*);
354 void interfaces_helper_add_hardware(struct lldpd
*,
355 struct lldpd_hardware
*);
356 void interfaces_helper_physical(struct lldpd
*,
357 struct interfaces_device_list
*,
359 int(*init
)(struct lldpd
*, struct lldpd_hardware
*));
360 void interfaces_helper_port_name_desc(struct lldpd
*,
361 struct lldpd_hardware
*,
362 struct interfaces_device
*);
363 void interfaces_helper_mgmt(struct lldpd
*,
364 struct interfaces_address_list
*);
366 void interfaces_helper_vlan(struct lldpd
*,
367 struct interfaces_device_list
*);
369 int interfaces_send_helper(struct lldpd
*,
370 struct lldpd_hardware
*, char *, size_t);
372 void interfaces_setup_multicast(struct lldpd
*, const char *, int);
373 int interfaces_routing_enabled(struct lldpd
*);
374 void interfaces_cleanup(struct lldpd
*);
378 struct interfaces_device_list
*netlink_get_interfaces(struct lldpd
*);
379 struct interfaces_address_list
*netlink_get_addresses(struct lldpd
*);
380 void netlink_cleanup(struct lldpd
*);
381 struct lldpd_netlink
;
384 #ifndef HOST_OS_LINUX
385 int ifbpf_phys_init(struct lldpd
*, struct lldpd_hardware
*);
389 int pattern_match(char *, char *, int);
393 struct event_base
*g_base
;
397 struct lldpd_config g_config
;
399 struct protocol
*g_protocols
;
401 struct event
*g_main_loop
;
402 struct event
*g_cleanup_timer
;
405 struct event
*g_snmp_timeout
;
407 const char *g_snmp_agentx
;
408 #endif /* USE_SNMP */
410 /* Unix socket handling */
411 const char *g_ctlname
;
413 struct event
*g_iface_event
; /* Triggered when there is an interface change */
414 struct event
*g_iface_timer_event
; /* Triggered one second after last interface change */
415 void(*g_iface_cb
)(struct lldpd
*); /* Called when there is an interface change */
420 struct lldpd_netlink
*g_netlink
;
423 struct lldpd_port
*g_default_local_port
;
424 #define LOCAL_CHASSIS(cfg) ((struct lldpd_chassis *)(TAILQ_FIRST(&cfg->g_chassis)))
425 TAILQ_HEAD(, lldpd_chassis
) g_chassis
;
426 TAILQ_HEAD(, lldpd_hardware
) g_hardware
;
429 #endif /* _LLDPD_H */