1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
|
/*
* src/nl-monitor.c Monitor events
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation version 2.1
* of the License.
*
* Copyright (c) 2003-2009 Thomas Graf <tgraf@suug.ch>
*/
#include <netlink/cli/utils.h>
#include <netlink/cli/link.h>
#include <linux/rtnetlink.h>
static const struct {
enum rtnetlink_groups gr_id;
const char* gr_name;
} known_groups[] = {
{ RTNLGRP_LINK, "link" },
{ RTNLGRP_NOTIFY, "notify" },
{ RTNLGRP_NEIGH, "neigh" },
{ RTNLGRP_TC, "tc" },
{ RTNLGRP_IPV4_IFADDR, "ipv4-ifaddr" },
{ RTNLGRP_IPV4_MROUTE, "ipv4-mroute" },
{ RTNLGRP_IPV4_ROUTE, "ipv4-route" },
{ RTNLGRP_IPV6_IFADDR, "ipv6-ifaddr" },
{ RTNLGRP_IPV6_MROUTE, "ipv6-mroute" },
{ RTNLGRP_IPV6_ROUTE, "ipv6-route" },
{ RTNLGRP_IPV6_IFINFO, "ipv6-ifinfo" },
{ RTNLGRP_DECnet_IFADDR, "decnet-ifaddr" },
{ RTNLGRP_DECnet_ROUTE, "decnet-route" },
{ RTNLGRP_IPV6_PREFIX, "ipv6-prefix" },
{ RTNLGRP_IPV4_NETCONF, "ipv4-netconf" },
{ RTNLGRP_IPV6_NETCONF, "ipv6-netconf" },
{ RTNLGRP_MPLS_NETCONF, "mpls-netconf" },
{ RTNLGRP_NONE, NULL }
};
static void obj_input(struct nl_object *obj, void *arg)
{
nl_object_dump(obj, arg);
}
static int event_input(struct nl_msg *msg, void *arg)
{
if (nl_msg_parse(msg, &obj_input, arg) < 0)
fprintf(stderr, "<<EVENT>> Unknown message type\n");
/* Exit nl_recvmsgs_def() and return to the main select() */
return NL_STOP;
}
static void print_usage(void)
{
int i;
printf(
"Usage: nl-monitor [OPTION] [<groups>]\n"
"\n"
"Options\n"
" -f, --format=TYPE Output format { brief | details | stats }\n"
" -h, --help Show this help.\n"
"\n"
);
printf("Known groups:");
for (i = 0; known_groups[i].gr_id != RTNLGRP_NONE; i++)
printf(" %s", known_groups[i].gr_name);
printf("\n");
exit(0);
}
int main(int argc, char *argv[])
{
struct nl_dump_params dp = {
.dp_type = NL_DUMP_STATS,
.dp_fd = stdout,
.dp_dump_msgtype = 1,
};
struct nl_sock *sock;
int err = 1;
int i, idx;
sock = nl_cli_alloc_socket();
nl_socket_disable_seq_check(sock);
nl_socket_modify_cb(sock, NL_CB_VALID, NL_CB_CUSTOM, event_input, &dp);
for (;;) {
int c, optidx = 0;
static struct option long_opts[] = {
{ "format", 1, 0, 'f' },
{ 0, 0, 0, 0 }
};
c = getopt_long(argc, argv, "f:h", long_opts, &optidx);
if (c == -1)
break;
switch (c) {
case 'f':
dp.dp_type = nl_cli_parse_dumptype(optarg);
break;
default:
print_usage();
break;
}
}
nl_cli_connect(sock, NETLINK_ROUTE);
for (idx = optind; argc > idx; idx++) {
for (i = 0; known_groups[i].gr_id != RTNLGRP_NONE; i++) {
if (!strcmp(argv[idx], known_groups[i].gr_name)) {
if ((err = nl_socket_add_membership(sock, known_groups[i].gr_id)) < 0) {
nl_cli_fatal(err, "%s: %s\n", argv[idx],
nl_geterror(err));
}
break;
}
}
if (known_groups[i].gr_id == RTNLGRP_NONE)
fprintf(stderr, "Warning: Unknown group: %s\n", argv[idx]);
}
nl_cli_link_alloc_cache(sock);
while (1) {
fd_set rfds;
int fd, retval;
fd = nl_socket_get_fd(sock);
FD_ZERO(&rfds);
FD_SET(fd, &rfds);
/* wait for an incoming message on the netlink socket */
retval = select(fd+1, &rfds, NULL, NULL, NULL);
if (retval) {
/* FD_ISSET(fd, &rfds) will be true */
nl_recvmsgs_default(sock);
}
}
return 0;
}
|
