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
|
// -*- c-basic-offset: 4; tab-width: 8; indent-tabs-mode: t -*-
// Copyright (c) 2001-2009 XORP, Inc.
//
// This program is free software; you can redistribute it and/or modify
// it under the terms of the GNU General Public License, Version 2, June
// 1991 as published by the Free Software Foundation. Redistribution
// and/or modification of this program under the terms of any other
// version of the GNU General Public License is not permitted.
//
// This program is distributed in the hope that it will be useful, but
// WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. For more details,
// see the GNU General Public License, Version 2, a copy of which can be
// found in the XORP LICENSE.gpl file.
//
// XORP Inc, 2953 Bunker Hill Lane, Suite 204, Santa Clara, CA 95054, USA;
// http://xorp.net
#ident "$XORP: xorp/fea/data_plane/fibconfig/fibconfig_entry_parse_netlink_socket.cc,v 1.16 2009/01/05 18:30:51 jtc Exp $"
#include "fea/fea_module.h"
#include "libxorp/xorp.h"
#include "libxorp/xlog.h"
#include "libxorp/debug.h"
#ifdef HAVE_LINUX_TYPES_H
#include <linux/types.h>
#endif
#ifdef HAVE_LINUX_RTNETLINK_H
#include <linux/rtnetlink.h>
#endif
#include "fea/fibconfig.hh"
#include "fea/data_plane/control_socket/netlink_socket_utilities.hh"
#include "fibconfig_entry_get_netlink_socket.hh"
//
// Parse information about forwarding entry information received from
// the underlying system.
//
// The information to parse is in NETLINK format
// (e.g., obtained by netlink(7) sockets mechanism).
//
// Reading netlink(3) manual page is a good start for understanding this
//
#ifdef HAVE_NETLINK_SOCKETS
int
FibConfigEntryGetNetlinkSocket::parse_buffer_netlink_socket(
const IfTree& iftree,
FteX& fte,
const vector<uint8_t>& buffer,
bool is_nlm_get_only)
{
size_t buffer_bytes = buffer.size();
AlignData<struct nlmsghdr> align_data(buffer);
const struct nlmsghdr* nlh;
for (nlh = align_data.payload();
NLMSG_OK(nlh, buffer_bytes);
nlh = NLMSG_NEXT(const_cast<struct nlmsghdr*>(nlh), buffer_bytes)) {
void* nlmsg_data = NLMSG_DATA(const_cast<struct nlmsghdr*>(nlh));
switch (nlh->nlmsg_type) {
case NLMSG_ERROR:
{
const struct nlmsgerr* err;
err = reinterpret_cast<const struct nlmsgerr*>(nlmsg_data);
if (nlh->nlmsg_len < NLMSG_LENGTH(sizeof(*err))) {
XLOG_ERROR("AF_NETLINK nlmsgerr length error");
break;
}
errno = -err->error;
XLOG_ERROR("AF_NETLINK NLMSG_ERROR message: %s", strerror(errno));
}
break;
case NLMSG_DONE:
{
return (XORP_ERROR); // XXX: entry not found
}
break;
case NLMSG_NOOP:
break;
case RTM_NEWROUTE:
case RTM_DELROUTE:
case RTM_GETROUTE:
{
if (is_nlm_get_only) {
//
// Consider only the "get" entries returned by RTM_GETROUTE.
// XXX: RTM_NEWROUTE below instead of RTM_GETROUTE is not
// a mistake, but an artifact of Linux logistics.
//
if (nlh->nlmsg_type != RTM_NEWROUTE)
break;
}
const struct rtmsg* rtmsg;
int rta_len = RTM_PAYLOAD(nlh);
if (rta_len < 0) {
XLOG_ERROR("AF_NETLINK rtmsg length error");
break;
}
rtmsg = reinterpret_cast<const struct rtmsg*>(nlmsg_data);
if (rtmsg->rtm_type == RTN_MULTICAST)
break; // XXX: ignore multicast entries
if (rtmsg->rtm_type == RTN_BROADCAST)
break; // XXX: ignore broadcast entries
return (NlmUtils::nlm_get_to_fte_cfg(iftree, fte, nlh, rtmsg,
rta_len));
}
break;
default:
debug_msg("Unhandled type %s(%d) (%d bytes)\n",
NlmUtils::nlm_msg_type(nlh->nlmsg_type).c_str(),
nlh->nlmsg_type, nlh->nlmsg_len);
}
}
return (XORP_ERROR);
}
#endif // HAVE_NETLINK_SOCKETS
|
