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
|
/*
* flowprobe.h - ipfix probe plug-in header file
*
* Copyright (c) 2016 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_flowprobe_h__
#define __included_flowprobe_h__
#include <vnet/vnet.h>
#include <vnet/ip/ip.h>
#include <vnet/ethernet/ethernet.h>
#include <vppinfra/hash.h>
#include <vppinfra/error.h>
#include <vnet/ipfix-export/flow_report.h>
#include <vnet/ipfix-export/flow_report_classify.h>
#include <vppinfra/tw_timer_2t_1w_2048sl.h>
/* Default timers in seconds */
#define FLOWPROBE_TIMER_ACTIVE (15)
#define FLOWPROBE_TIMER_PASSIVE 120 // XXXX: FOR TESTING (30*60)
#define FLOWPROBE_LOG2_HASHSIZE (18)
typedef enum
{
FLOW_RECORD_L2 = 1 << 0,
FLOW_RECORD_L3 = 1 << 1,
FLOW_RECORD_L4 = 1 << 2,
FLOW_RECORD_L2_IP4 = 1 << 3,
FLOW_RECORD_L2_IP6 = 1 << 4,
FLOW_N_RECORDS = 1 << 5,
} flowprobe_record_t;
/* *INDENT-OFF* */
typedef enum __attribute__ ((__packed__))
{
FLOW_VARIANT_IP4 = 0,
FLOW_VARIANT_IP6,
FLOW_VARIANT_L2,
FLOW_VARIANT_L2_IP4,
FLOW_VARIANT_L2_IP6,
FLOW_N_VARIANTS,
} flowprobe_variant_t;
typedef enum __attribute__ ((__packed__))
{
FLOW_DIRECTION_RX = 0,
FLOW_DIRECTION_TX,
FLOW_DIRECTION_BOTH,
} flowprobe_direction_t;
/* *INDENT-ON* */
STATIC_ASSERT (sizeof (flowprobe_variant_t) == 1,
"flowprobe_variant_t is expected to be 1 byte, "
"revisit padding in flowprobe_key_t");
#define FLOW_MAXIMUM_EXPORT_ENTRIES (1024)
typedef struct
{
/* what to collect per variant */
flowprobe_record_t flags;
/** ipfix buffers under construction, per-worker thread */
vlib_buffer_t **buffers_per_worker;
/** frames containing ipfix buffers, per-worker thread */
vlib_frame_t **frames_per_worker;
/** next record offset, per worker thread */
u16 *next_record_offset_per_worker;
} flowprobe_protocol_context_t;
/* *INDENT-OFF* */
typedef struct __attribute__ ((aligned (8))) {
u32 rx_sw_if_index;
u32 tx_sw_if_index;
u8 src_mac[6];
u8 dst_mac[6];
u16 ethertype;
ip46_address_t src_address;
ip46_address_t dst_address;
u8 protocol;
u16 src_port;
u16 dst_port;
flowprobe_variant_t which;
flowprobe_direction_t direction;
} flowprobe_key_t;
/* *INDENT-ON* */
typedef struct
{
u32 sec;
u32 nsec;
} timestamp_nsec_t;
typedef struct
{
flowprobe_key_t key;
u64 packetcount;
u64 octetcount;
timestamp_nsec_t flow_start;
timestamp_nsec_t flow_end;
f64 last_updated;
f64 last_exported;
u32 passive_timer_handle;
union
{
struct
{
u16 flags;
} tcp;
} prot;
} flowprobe_entry_t;
/**
* @file
* @brief flow-per-packet plugin header file
*/
typedef struct
{
/** API message ID base */
u16 msg_id_base;
flowprobe_protocol_context_t context[FLOW_N_VARIANTS];
u16 template_reports[FLOW_N_RECORDS];
u16 template_size[FLOW_N_RECORDS];
/** Time reference pair */
u64 nanosecond_time_0;
f64 vlib_time_0;
/** Per CPU flow-state */
u8 ht_log2len; /* Hash table size is 2^log2len */
u32 **hash_per_worker;
flowprobe_entry_t **pool_per_worker;
/* *INDENT-OFF* */
TWT (tw_timer_wheel) ** timers_per_worker;
/* *INDENT-ON* */
u32 **expired_passive_per_worker;
flowprobe_record_t record;
u32 active_timer;
u32 passive_timer;
flowprobe_entry_t *stateless_entry;
bool initialized;
bool disabled;
u16 template_per_flow[FLOW_N_VARIANTS];
u8 *flow_per_interface;
u8 *direction_per_interface;
/** convenience vlib_main_t pointer */
vlib_main_t *vlib_main;
/** convenience vnet_main_t pointer */
vnet_main_t *vnet_main;
} flowprobe_main_t;
extern flowprobe_main_t flowprobe_main;
extern vlib_node_registration_t flowprobe_walker_node;
void flowprobe_delete_by_index (u32 my_cpu_number, u32 poolindex);
void flowprobe_flush_callback_ip4 (void);
void flowprobe_flush_callback_ip6 (void);
void flowprobe_flush_callback_l2 (void);
u8 *format_flowprobe_entry (u8 * s, va_list * args);
#endif
/*
* fd.io coding-style-patch-verification: ON
*
* Local Variables:
* eval: (c-set-style "gnu")
* End:
*/
|
