summaryrefslogtreecommitdiffstats
path: root/src/vnet/flow/ipfix_packet.h
blob: a50d86ea379e291af79ce3a0002295e70b0542fd (plain)
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
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
/*
 * Copyright (c) 2015 Cisco and/or its affiliates.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at:
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
#ifndef __included_ipfix_packet_h__
#define __included_ipfix_packet_h__

#include <vnet/flow/ipfix_info_elements.h>

/* From RFC-7011:
 * https://tools.ietf.org/html/rfc7011
 */

typedef struct
{
  u32 version_length;
  u32 export_time;
  u32 sequence_number;
  u32 domain_id;
} ipfix_message_header_t;

static inline u32
version_length (u16 length)
{
  return clib_host_to_net_u32 (0x000a0000 | length);
}


/*
 *   The Field Specifier format is shown in Figure G.
 *
 *     0                   1                   2                   3
 *     0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
 *     +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 *     |E|  Information Element ident. |        Field Length           |
 *     +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 *     |                      Enterprise Number                        |
 *     +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 *
 *                     Figure G: Field Specifier Format
 *
 *   Where:
 *
 *   E
 *
 *      Enterprise bit.  This is the first bit of the Field Specifier.  If
 *      this bit is zero, the Information Element identifier identifies an
 *      Information Element in [IANA-IPFIX], and the four-octet Enterprise
 *      Number field MUST NOT be present.  If this bit is one, the
 *      Information Element identifier identifies an enterprise-specific
 *      Information Element, and the Enterprise Number field MUST be
 *      present.
 */

typedef struct
{
  u32 e_id_length;
  u32 enterprise;
} ipfix_enterprise_field_specifier_t;

typedef struct
{
  u32 e_id_length;
} ipfix_field_specifier_t;

static inline u32
ipfix_e_id_length (int e, u16 id, u16 length)
{
  u32 value;
  value = (e << 31) | ((id & 0x7FFF) << 16) | length;
  return clib_host_to_net_u32 (value);
}

/*
 *   Every Set contains a common header.  This header is defined in
 *   Figure I.
 *
 *      0                   1                   2                   3
 *      0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
 *     +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 *     |          Set ID               |          Length               |
 *     +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 *
 *                        Figure I: Set Header Format
 *
 *   Each Set Header field is exported in network format.  The fields are
 *   defined as follows:
 *
 *   Set ID
 *
 *      Identifies the Set.  A value of 2 is reserved for Template Sets.
 *      A value of 3 is reserved for Options Template Sets.  Values from 4
 *      to 255 are reserved for future use.  Values 256 and above are used
 *      for Data Sets.  The Set ID values of 0 and 1 are not used, for
 *      historical reasons [RFC3954].
 *
 *   Length
 *
 *      Total length of the Set, in octets, including the Set Header, all
 *      records, and the optional padding.  Because an individual Set MAY
 *      contain multiple records, the Length value MUST be used to
 *      determine the position of the next Set.
 */

typedef struct
{
  u32 set_id_length;
} ipfix_set_header_t;

static inline u32
ipfix_set_id_length (u16 set_id, u16 length)
{
  return clib_host_to_net_u32 ((set_id << 16) | length);
}

/*
 *   The format of the Template Record is shown in Figure J.  It consists
 *   of a Template Record Header and one or more Field Specifiers.  Field
 *   Specifiers are defined in Figure G above.
 *
 *           +--------------------------------------------------+
 *           | Template Record Header                           |
 *           +--------------------------------------------------+
 *           | Field Specifier                                  |
 *           +--------------------------------------------------+
 *           | Field Specifier                                  |
 *           +--------------------------------------------------+
 *            ...
 *           +--------------------------------------------------+
 *           | Field Specifier                                  |
 *           +--------------------------------------------------+
 *
 *                     Figure J: Template Record Format
 *
 *   The format of the Template Record Header is shown in Figure K.
 *
 *     0                   1                   2                   3
 *     0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1 2 3 4 5 6 7 8 9 0 1
 *    +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 *    |      Template ID (> 255)      |         Field Count           |
 *    +-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+-+
 *
 *                  Figure K: Template Record Header Format
 *
 *   The Template Record Header Field definitions are as follows:
 *
 *   Template ID
 *
 *      Each Template Record is given a unique Template ID in the range
 *      256 to 65535.  This uniqueness is local to the Transport Session
 *      and Observation Domain that generated the Template ID.  Since
 *      Template IDs are used as Set IDs in the Sets they describe (see
 *      Section 3.4.3), values 0-255 are reserved for special Set types
 *      (e.g., Template Sets themselves), and Templates and Options
 *      Templates (see Section 3.4.2) cannot share Template IDs within a
 *      Transport Session and Observation Domain.  There are no
 *      constraints regarding the order of the Template ID allocation.  As
 *      Exporting Processes are free to allocate Template IDs as they see
 *      fit, Collecting Processes MUST NOT assume incremental Template
 *      IDs, or anything about the contents of a Template based on its
 *      Template ID alone.
 *
 *   Field Count
 *
 *      Number of fields in this Template Record.
 */

typedef struct
{
  u32 id_count;
} ipfix_template_header_t;

static inline u32
ipfix_id_count (u16 id, u16 count)
{
  return clib_host_to_net_u32 ((id << 16) | count);
}

/* Template packet */
typedef struct
{
  ipfix_message_header_t h;
  ipfix_set_header_t s;
  ipfix_template_header_t t;
  ipfix_field_specifier_t fields[0];
} ipfix_template_packet_t;

#endif /* __included_ipfix_packet_h__ */

/*
 * fd.io coding-style-patch-verification: ON
 *
 * Local Variables:
 * eval: (c-set-style "gnu")
 * End:
 */
>, sizeof (src.ip6)); clib_memcpy (&server.ip6, mp->dhcp_server, sizeof (server.ip6)); rv = dhcp6_proxy_set_server (&server, &src, (u32) ntohl (mp->rx_vrf_id), (u32) ntohl (mp->server_vrf_id), (int) (mp->is_add == 0)); } else { ip46_address_reset (&src); ip46_address_reset (&server); clib_memcpy (&src.ip4, mp->dhcp_src_address, sizeof (src.ip4)); clib_memcpy (&server.ip4, mp->dhcp_server, sizeof (server.ip4)); rv = dhcp4_proxy_set_server (&server, &src, (u32) ntohl (mp->rx_vrf_id), (u32) ntohl (mp->server_vrf_id), (int) (mp->is_add == 0)); } REPLY_MACRO (VL_API_DHCP_PROXY_CONFIG_REPLY); } static void vl_api_dhcp_proxy_dump_t_handler (vl_api_dhcp_proxy_dump_t * mp) { vl_api_registration_t *reg; reg = vl_api_client_index_to_registration (mp->client_index); if (!reg) return;; dhcp_proxy_dump ((mp->is_ip6 == 1 ? FIB_PROTOCOL_IP6 : FIB_PROTOCOL_IP4), reg, mp->context); } void dhcp_send_details (fib_protocol_t proto, void *opaque, u32 context, dhcp_proxy_t * proxy) { vl_api_dhcp_proxy_details_t *mp; vl_api_registration_t *reg = opaque; vl_api_dhcp_server_t *v_server; dhcp_server_t *server; fib_table_t *s_fib; dhcp_vss_t *vss; u32 count; size_t n; count = vec_len (proxy->dhcp_servers); n = sizeof (*mp) + (count * sizeof (vl_api_dhcp_server_t)); mp = vl_msg_api_alloc (n); if (!mp) return; memset (mp, 0, n); mp->_vl_msg_id = ntohs (VL_API_DHCP_PROXY_DETAILS); mp->context = context; mp->count = count; mp->is_ipv6 = (proto == FIB_PROTOCOL_IP6); mp->rx_vrf_id = htonl (dhcp_proxy_rx_table_get_table_id (proto, proxy->rx_fib_index)); vss = dhcp_get_vss_info (&dhcp_proxy_main, proxy->rx_fib_index, proto); if (vss) { mp->vss_type = vss->vss_type; if (vss->vss_type == VSS_TYPE_ASCII) { u32 id_len = vec_len (vss->vpn_ascii_id); clib_memcpy (mp->vss_vpn_ascii_id, vss->vpn_ascii_id, id_len); } else if (vss->vss_type == VSS_TYPE_VPN_ID) { u32 oui = ((u32) vss->vpn_id[0] << 16) + ((u32) vss->vpn_id[1] << 8) + ((u32) vss->vpn_id[2]); u32 fib_id = ((u32) vss->vpn_id[3] << 24) + ((u32) vss->vpn_id[4] << 16) + ((u32) vss->vpn_id[5] << 8) + ((u32) vss->vpn_id[6]); mp->vss_oui = htonl (oui); mp->vss_fib_id = htonl (fib_id); } } else mp->vss_type = VSS_TYPE_INVALID; vec_foreach_index (count, proxy->dhcp_servers) { server = &proxy->dhcp_servers[count]; v_server = &mp->servers[count]; s_fib = fib_table_get (server->server_fib_index, proto); v_server->server_vrf_id = htonl (s_fib->ft_table_id); if (mp->is_ipv6) { memcpy (v_server->dhcp_server, &server->dhcp_server.ip6, 16); } else { /* put the address in the first bytes */ memcpy (v_server->dhcp_server, &server->dhcp_server.ip4, 4); } } if (mp->is_ipv6) { memcpy (mp->dhcp_src_address, &proxy->dhcp_src_address.ip6, 16); } else { /* put the address in the first bytes */ memcpy (mp->dhcp_src_address, &proxy->dhcp_src_address.ip4, 4); } vl_api_send_msg (reg, (u8 *) mp); } static void dhcp_client_lease_encode (vl_api_dhcp_lease_t * lease, const dhcp_client_t * client) { size_t len; lease->is_ipv6 = 0; // only support IPv6 clients lease->sw_if_index = ntohl (client->sw_if_index); lease->state = client->state; len = clib_min (sizeof (lease->hostname) - 1, vec_len (client->hostname)); clib_memcpy (&lease->hostname, client->hostname, len); lease->hostname[len] = 0; lease->mask_width = client->subnet_mask_width; clib_memcpy (&lease->host_address[0], (u8 *) & client->leased_address, 4); clib_memcpy (&lease->router_address[0], (u8 *) & client->router_address, 4); if (NULL != client->l2_rewrite) clib_memcpy (&lease->host_mac[0], client->l2_rewrite + 6, 6); } static void dhcp_client_data_encode (vl_api_dhcp_client_t * vclient, const dhcp_client_t * client) { size_t len; vclient->sw_if_index = ntohl (client->sw_if_index); len = clib_min (sizeof (vclient->hostname) - 1, vec_len (client->hostname)); clib_memcpy (&vclient->hostname, client->hostname, len); vclient->hostname[len] = 0; len = clib_min (sizeof (vclient->id) - 1, vec_len (client->client_identifier)); clib_memcpy (&vclient->id, client->client_identifier, len); vclient->id[len] = 0; if (NULL != client->event_callback) vclient->want_dhcp_event = 1; else vclient->want_dhcp_event = 0; vclient->set_broadcast_flag = client->set_broadcast_flag; vclient->pid = client->pid; } static void dhcp_compl_event_callback (u32 client_index, const dhcp_client_t * client) { vl_api_registration_t *reg; vl_api_dhcp_compl_event_t *mp; reg = vl_api_client_index_to_registration (client_index); if (!reg) return; mp = vl_msg_api_alloc (sizeof (*mp)); mp->client_index = client_index; mp->pid = client->pid; dhcp_client_lease_encode (&mp->lease, client); mp->_vl_msg_id = ntohs (VL_API_DHCP_COMPL_EVENT); vl_api_send_msg (reg, (u8 *) mp); } static void vl_api_dhcp_client_config_t_handler (vl_api_dhcp_client_config_t * mp) { vlib_main_t *vm = vlib_get_main (); vl_api_dhcp_client_config_reply_t *rmp; u32 sw_if_index; int rv = 0; sw_if_index = ntohl (mp->client.sw_if_index); if (!vnet_sw_if_index_is_api_valid (sw_if_index)) { rv = VNET_API_ERROR_INVALID_SW_IF_INDEX; goto bad_sw_if_index; } rv = dhcp_client_config (mp->is_add, mp->client_index, vm, sw_if_index, mp->client.hostname, mp->client.id, (mp->client.want_dhcp_event ? dhcp_compl_event_callback : NULL), mp->client.set_broadcast_flag, mp->client.pid); BAD_SW_IF_INDEX_LABEL; REPLY_MACRO (VL_API_DHCP_CLIENT_CONFIG_REPLY); } typedef struct dhcp_client_send_walk_ctx_t_ { vl_api_registration_t *reg; u32 context; } dhcp_client_send_walk_ctx_t; static int send_dhcp_client_entry (const dhcp_client_t * client, void *arg) { dhcp_client_send_walk_ctx_t *ctx; vl_api_dhcp_client_details_t *mp; ctx = arg; mp = vl_msg_api_alloc (sizeof (*mp)); memset (mp, 0, sizeof (*mp)); mp->_vl_msg_id = ntohs (VL_API_DHCP_CLIENT_DETAILS); mp->context = ctx->context; dhcp_client_data_encode (&mp->client, client); dhcp_client_lease_encode (&mp->lease, client); vl_api_send_msg (ctx->reg, (u8 *) mp); return (1); } static void vl_api_dhcp_client_dump_t_handler (vl_api_dhcp_client_dump_t * mp) { vl_api_registration_t *reg; reg = vl_api_client_index_to_registration (mp->client_index); if (!reg) return; dhcp_client_send_walk_ctx_t ctx = { .reg = reg, .context = mp->context, }; dhcp_client_walk (send_dhcp_client_entry, &ctx); } /* * dhcp_api_hookup * Add vpe's API message handlers to the table. * vlib has alread mapped shared memory and * added the client registration handlers. * See .../vlib-api/vlibmemory/memclnt_vlib.c:memclnt_process() */ #define vl_msg_name_crc_list #include <vnet/vnet_all_api_h.h> #undef vl_msg_name_crc_list static void setup_message_id_table (api_main_t * am) { #define _(id,n,crc) vl_msg_api_add_msg_name_crc (am, #n "_" #crc, id); foreach_vl_msg_name_crc_dhcp; #undef _ } static clib_error_t * dhcp_api_hookup (vlib_main_t * vm) { api_main_t *am = &api_main; #define _(N,n) \ vl_msg_api_set_handlers(VL_API_##N, #n, \ vl_api_##n##_t_handler, \ vl_noop_handler, \ vl_api_##n##_t_endian, \ vl_api_##n##_t_print, \ sizeof(vl_api_##n##_t), 1); foreach_vpe_api_msg; #undef _ /* * Set up the (msg_name, crc, message-id) table */ setup_message_id_table (am); dhcp6_pd_set_publisher_node (dhcp6_pd_reply_process_node.index, DHCP6_PD_DP_REPLY_REPORT); dhcp6_set_publisher_node (dhcp6_reply_process_node.index, DHCP6_DP_REPLY_REPORT); return 0; } VLIB_API_INIT_FUNCTION (dhcp_api_hookup); /* * fd.io coding-style-patch-verification: ON * * Local Variables: * eval: (c-set-style "gnu") * End: */