upgrade to the new version of wprobe - includes reconfigurable layer 2 statistics...
[openwrt/svn-archive/archive.git] / package / wprobe / src / kernel / linux / wprobe.h
1 /*
2 * wprobe.h: API for the wireless probe interface
3 * Copyright (C) 2008-2009 Felix Fietkau <nbd@openwrt.org>
4 *
5 * This program is free software; you can redistribute it and/or
6 * modify it under the terms of the GNU General Public License
7 * as published by the Free Software Foundation; either version 2
8 * of the License, or (at your option) any later version.
9 *
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
14 */
15
16 #ifndef __WPROBE_H
17 #define __WPROBE_H
18
19 #ifdef __KERNEL__
20 #include <linux/types.h>
21 #include <linux/if_ether.h>
22 #include <linux/spinlock.h>
23 #include <linux/module.h>
24 #include <linux/list.h>
25 #include <linux/timer.h>
26 #include <linux/filter.h>
27 #include <net/genetlink.h>
28 #endif
29
30 /**
31 * enum wprobe_attr: netlink attribute list
32 *
33 * @WPROBE_ATTR_UNSPEC: unused
34 *
35 * @WPROBE_ATTR_INTERFACE: interface name to process query on (NLA_STRING)
36 * @WPROBE_ATTR_MAC: mac address (used for wireless links) (NLA_STRING)
37 * @WPROBE_ATTR_FLAGS: interface/link/attribute flags (see enum wprobe_flags) (NLA_U32)a
38 * @WPROBE_ATTR_DURATION: sampling duration (in milliseconds) (NLA_MSECS)
39 *
40 * @WPROBE_ATTR_ID: attribute id (NLA_U32)
41 * @WPROBE_ATTR_NAME: attribute name (NLA_STRING)
42 * @WPROBE_ATTR_TYPE: attribute type (NLA_U8)
43 *
44 * attribute values:
45 *
46 * @WPROBE_VAL_STRING: string value (NLA_STRING)
47 * @WPROBE_VAL_S8: signed 8-bit integer (NLA_U8)
48 * @WPROBE_VAL_S16: signed 16-bit integer (NLA_U16)
49 * @WPROBE_VAL_S32: signed 32-bit integer (NLA_U32)
50 * @WPROBE_VAL_S64: signed 64-bit integer (NLA_U64)
51 * @WPROBE_VAL_U8: unsigned 8-bit integer (NLA_U8)
52 * @WPROBE_VAL_U16: unsigned 16-bit integer (NLA_U16)
53 * @WPROBE_VAL_U32: unsigned 32-bit integer (NLA_U32)
54 * @WPROBE_VAL_U64: unsigned 64-bit integer (NLA_U64)
55 *
56 * statistics:
57 * @WPROBE_VAL_SUM: sum of all samples
58 * @WPROBE_VAL_SUM_SQ: sum of all samples^2
59 * @WPROBE_VAL_SAMPLES: number of samples
60 * @WPROBE_VAL_SCALE_TIME: last time the samples were scaled down
61 *
62 * configuration:
63 * @WPROBE_ATTR_INTERVAL: (measurement interval in milliseconds) (NLA_MSECS)
64 * @WPROBE_ATTR_SAMPLES_MIN: minimum samples to keep during inactivity (NLA_U32)
65 * @WPROBE_ATTR_SAMPLES_MAX: maximum samples to keep before scaling down (NLA_U32)
66 * @WPROBE_ATTR_SAMPLES_SCALE_M: multiplier for scaling down samples (NLA_U32)
67 * @WPROBE_ATTR_SAMPLES_SCALE_D: divisor for scaling down samples (NLA_U32)
68 *
69 * @WPROBE_ATTR_LAST: unused
70 */
71 enum wprobe_attr {
72 /* query attributes */
73 WPROBE_ATTR_UNSPEC,
74 WPROBE_ATTR_INTERFACE,
75 WPROBE_ATTR_MAC,
76 WPROBE_ATTR_FLAGS,
77
78 /* response data */
79 WPROBE_ATTR_ID,
80 WPROBE_ATTR_NAME,
81 WPROBE_ATTR_TYPE,
82 WPROBE_ATTR_DURATION,
83
84 /* value type attributes */
85 WPROBE_VAL_STRING,
86 WPROBE_VAL_S8,
87 WPROBE_VAL_S16,
88 WPROBE_VAL_S32,
89 WPROBE_VAL_S64,
90 WPROBE_VAL_U8,
91 WPROBE_VAL_U16,
92 WPROBE_VAL_U32,
93 WPROBE_VAL_U64,
94
95 /* aggregates for statistics */
96 WPROBE_VAL_SUM,
97 WPROBE_VAL_SUM_SQ,
98 WPROBE_VAL_SAMPLES,
99 WPROBE_VAL_SCALE_TIME,
100
101 /* config attributes */
102 WPROBE_ATTR_INTERVAL,
103 WPROBE_ATTR_SAMPLES_MIN,
104 WPROBE_ATTR_SAMPLES_MAX,
105 WPROBE_ATTR_SAMPLES_SCALE_M,
106 WPROBE_ATTR_SAMPLES_SCALE_D,
107 WPROBE_ATTR_FILTER,
108
109 WPROBE_ATTR_FILTER_GROUP,
110 WPROBE_ATTR_RXCOUNT,
111 WPROBE_ATTR_TXCOUNT,
112
113 WPROBE_ATTR_LAST
114 };
115
116
117 /**
118 * enum wprobe_cmd: netlink commands for interacting with wprobe
119 *
120 * @WPROBE_CMD_UNSPEC: unused
121 *
122 * @WPROBE_CMD_GET_LIST: get global/link property list
123 * @WPROBE_CMD_GET_INFO: get global/link properties
124 * @WPROBE_CMD_SET_FLAGS: set global/link flags
125 * @WPROBE_CMD_MEASURE: take a snapshot of the current data
126 * @WPROBE_CMD_GET_LINKS: get a list of links
127 * @WPROBE_CMD_CONFIG: set config options
128 * @WPROBE_CMD_GET_FILTER: get counters for active filters
129 *
130 * @WPROBE_CMD_LAST: unused
131 *
132 * options for GET_INFO and SET_FLAGS:
133 * - mac address set: per-link
134 * - mac address unset: globalsa
135 */
136 enum wprobe_cmd {
137 WPROBE_CMD_UNSPEC,
138 WPROBE_CMD_GET_LIST,
139 WPROBE_CMD_GET_INFO,
140 WPROBE_CMD_SET_FLAGS,
141 WPROBE_CMD_MEASURE,
142 WPROBE_CMD_GET_LINKS,
143 WPROBE_CMD_CONFIG,
144 WPROBE_CMD_GET_FILTER,
145 WPROBE_CMD_LAST
146 };
147
148 /**
149 * enum wprobe_flags: flags for wprobe links and items
150 * @WPROBE_F_KEEPSTAT: keep statistics for this link/device
151 * @WPROBE_F_RESET: reset statistics now
152 * @WPROBE_F_NEWDATA: used to indicate that a value has been updated
153 */
154 enum wprobe_flags {
155 WPROBE_F_KEEPSTAT = (1 << 0),
156 WPROBE_F_RESET = (1 << 1),
157 WPROBE_F_NEWDATA = (1 << 2),
158 };
159
160 #ifdef __KERNEL__
161
162 struct wprobe_link;
163 struct wprobe_item;
164 struct wprobe_source;
165 struct wprobe_value;
166
167 /**
168 * struct wprobe_link - data structure describing a wireless link
169 * @iface: pointer to the wprobe_iface that this link belongs to
170 * @addr: BSSID of the remote link partner
171 * @flags: link flags (see wprobe_flags)
172 * @priv: user pointer
173 *
174 * @list: for internal use
175 * @val: for internal use
176 */
177 struct wprobe_link {
178 struct list_head list;
179 struct wprobe_iface *iface;
180 char addr[ETH_ALEN];
181 u32 flags;
182 void *priv;
183 struct wprobe_value *val;
184 };
185
186 /**
187 * struct wprobe_item - data structure describing the format of wprobe_link::data or wprobe_iface::data
188 * @name: name of the field
189 * @type: data type of this field
190 * @flags: measurement item flags (see wprobe_flags)
191 */
192 struct wprobe_item {
193 const char *name;
194 enum wprobe_attr type;
195 u32 flags;
196 };
197
198 struct wprobe_value {
199 bool pending;
200 union {
201 /*
202 * the following are kept uppercase to allow
203 * for automated checking against WPROBE_VAL_*
204 * via BUG_ON()
205 */
206 const char *STRING;
207 u8 U8;
208 u16 U16;
209 u32 U32;
210 u64 U64;
211 s8 S8;
212 s16 S16;
213 s32 S32;
214 s64 S64;
215 };
216 s64 s, ss;
217 unsigned int n;
218
219 /* timestamps */
220 u64 first, last;
221 u64 scale_timestamp;
222 };
223
224 struct wprobe_filter_item_hdr {
225 char name[32];
226 __be32 n_items;
227 } __attribute__((packed));
228
229 struct wprobe_filter_item {
230 struct wprobe_filter_item_hdr hdr;
231 struct sock_filter filter[];
232 } __attribute__((packed));
233
234 struct wprobe_filter_counter {
235 u64 tx;
236 u64 rx;
237 };
238
239 struct wprobe_filter_group {
240 const char *name;
241 int n_items;
242 struct wprobe_filter_item **items;
243 struct wprobe_filter_counter *counters;
244 };
245
246 struct wprobe_filter_hdr {
247 __u8 magic[4];
248 __u8 version;
249 __u8 hdrlen;
250 __u16 n_groups;
251 } __attribute__((packed));
252
253 struct wprobe_filter {
254 spinlock_t lock;
255 struct sk_buff *skb;
256 void *data;
257 int n_groups;
258 int hdrlen;
259 struct wprobe_filter_item **items;
260 struct wprobe_filter_counter *counters;
261 struct wprobe_filter_group groups[];
262 };
263
264 enum {
265 WPROBE_PKT_RX = 0x00,
266 WPROBE_PKT_TX = 0x10,
267 };
268
269 struct wprobe_wlan_hdr {
270 u16 len;
271 u8 snr;
272 u8 type;
273 } __attribute__((packed));
274
275
276 /**
277 * struct wprobe_source - data structure describing a wireless interface
278 *
279 * @name: name of the interface
280 * @addr: local mac address of the interface
281 * @links: list of wireless links to poll
282 * @link_items: description of the per-link data structure
283 * @n_link_items: number of link description items
284 * @global_items: description of the per-interface data structure
285 * @n_global_items: number of per-interface description items
286 * @sync_data: callback allowing the driver to prepare data for the wprobe poll
287 *
288 * @list: head for the list of interfaces
289 * @priv: user pointer
290 * @lock: spinlock protecting value data access
291 * @val: internal use
292 * @query_val: internal use
293 *
294 * if sync_data is NULL, wprobe assumes that it can access the data structure
295 * at any time (in atomic context). if sync_data returns a negative error code,
296 * the poll request will not be handled for the given link
297 */
298 struct wprobe_iface {
299 /* to be filled in by wprobe source drivers */
300 const char *name;
301 const char *addr;
302 const struct wprobe_item *link_items;
303 int n_link_items;
304 const struct wprobe_item *global_items;
305 int n_global_items;
306
307 int (*sync_data)(struct wprobe_iface *dev, struct wprobe_link *l,
308 struct wprobe_value *val, bool measure);
309 void *priv;
310
311 /* handled by the wprobe core */
312 struct list_head list;
313 struct list_head links;
314 spinlock_t lock;
315 struct wprobe_value *val;
316 struct wprobe_value *query_val;
317 struct wprobe_filter *active_filter;
318
319 u32 measure_interval;
320 struct timer_list measure_timer;
321
322 u32 scale_min;
323 u32 scale_max;
324 u32 scale_m;
325 u32 scale_d;
326 };
327
328
329 #define WPROBE_FILL_BEGIN(_ptr, _list) do { \
330 struct wprobe_value *__val = (_ptr); \
331 const struct wprobe_item *__item = _list; \
332 u64 __msecs = jiffies_to_msecs(jiffies)
333
334 #define WPROBE_SET(_idx, _type, _value) \
335 if (__item[_idx].type != WPROBE_VAL_##_type) { \
336 printk("ERROR: invalid data type at %s:%d\n", __FILE__, __LINE__); \
337 break; \
338 } \
339 __val[_idx].pending = true; \
340 __val[_idx]._type = _value; \
341 if (!__val[_idx].first) \
342 __val[_idx].first = __msecs; \
343 __val[_idx].first = __msecs
344
345 #define WPROBE_FILL_END() \
346 } while(0)
347
348 /**
349 * wprobe_add_iface: register an interface with the wireless probe subsystem
350 * @dev: wprobe_iface structure describing the interface
351 */
352 extern int __weak wprobe_add_iface(struct wprobe_iface *dev);
353
354 /**
355 * wprobe_remove_iface: deregister an interface from the wireless probe subsystem
356 * @dev: wprobe_iface structure describing the interface
357 */
358 extern void __weak wprobe_remove_iface(struct wprobe_iface *dev);
359
360 /**
361 * wprobe_add_link: register a new wireless link
362 * @dev: wprobe_iface structure describing the interface
363 * @l: storage space for the wprobe_link structure
364 * @addr: mac address of the new link
365 *
366 * the entire wprobe_link structure is overwritten by this function call
367 */
368 extern int __weak wprobe_add_link(struct wprobe_iface *dev, struct wprobe_link *l, const char *addr);
369
370 /**
371 * wprobe_remove_link: deregister a previously registered wireless link
372 * @dev: wprobe_iface structure describing the interface
373 * @l: wprobe_link data structure
374 */
375 extern void __weak wprobe_remove_link(struct wprobe_iface *dev, struct wprobe_link *l);
376
377 /**
378 * wprobe_update_stats: update statistics after sampling values
379 * @dev: wprobe_iface structure describing the interface
380 * @l: wprobe_link data structure
381 *
382 * if l == NULL, then the stats for globals are updated
383 */
384 extern void __weak wprobe_update_stats(struct wprobe_iface *dev, struct wprobe_link *l);
385
386 /**
387 * wprobe_add_frame: add frame for layer 2 analysis
388 * @dev: wprobe_iface structure describing the interface
389 * @hdr: metadata for the frame
390 * @data: 802.11 header pointer
391 * @len: length of the 802.11 header
392 */
393 extern int __weak wprobe_add_frame(struct wprobe_iface *dev, const struct wprobe_wlan_hdr *hdr, void *data, int len);
394
395 #endif /* __KERNEL__ */
396
397 #endif