2 * wprobe-core.c: Wireless probe interface core
3 * Copyright (C) 2008-2009 Felix Fietkau <nbd@openwrt.org>
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.
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.
16 #include <linux/kernel.h>
17 #include <linux/version.h>
18 #include <linux/module.h>
19 #include <linux/types.h>
20 #include <linux/spinlock.h>
21 #include <linux/rcupdate.h>
22 #if LINUX_VERSION_CODE >= KERNEL_VERSION(2,6,26)
23 #include <linux/rculist.h>
25 #include <linux/list.h>
27 #if LINUX_VERSION_CODE >= KERNEL_VERSION(3,2,0)
28 #include <linux/prefetch.h>
30 #include <linux/skbuff.h>
31 #include <linux/wprobe.h>
32 #include <linux/math64.h>
36 #if LINUX_VERSION_CODE >= KERNEL_VERSION(2,6,28)
37 #define list_for_each_rcu(pos, head) \
38 for (pos = rcu_dereference((head)->next); \
39 prefetch(pos->next), pos != (head); \
40 pos = rcu_dereference(pos->next))
43 #define WPROBE_MIN_INTERVAL 100 /* minimum measurement interval in msecs */
44 #define WPROBE_MAX_FILTER_SIZE 1024
45 #define WPROBE_MAX_FRAME_SIZE 1900
47 static struct list_head wprobe_if
;
48 static spinlock_t wprobe_lock
;
50 static struct genl_family wprobe_fam
= {
51 .id
= GENL_ID_GENERATE
,
55 /* only the first set of attributes is used for queries */
56 .maxattr
= WPROBE_ATTR_LAST
,
59 /* fake radiotap header */
60 struct wprobe_rtap_hdr
{
67 static void wprobe_update_stats(struct wprobe_iface
*dev
, struct wprobe_link
*l
);
68 static int wprobe_sync_data(struct wprobe_iface
*dev
, struct wprobe_link
*l
, bool query
);
69 static void wprobe_free_filter(struct wprobe_filter
*f
);
72 wprobe_add_link(struct wprobe_iface
*s
, struct wprobe_link
*l
, const char *addr
)
76 INIT_LIST_HEAD(&l
->list
);
77 l
->val
= kzalloc(sizeof(struct wprobe_value
) * s
->n_link_items
, GFP_ATOMIC
);
82 memcpy(&l
->addr
, addr
, ETH_ALEN
);
83 spin_lock_irqsave(&wprobe_lock
, flags
);
84 list_add_tail_rcu(&l
->list
, &s
->links
);
85 spin_unlock_irqrestore(&wprobe_lock
, flags
);
89 EXPORT_SYMBOL(wprobe_add_link
);
92 wprobe_remove_link(struct wprobe_iface
*s
, struct wprobe_link
*l
)
96 spin_lock_irqsave(&wprobe_lock
, flags
);
97 list_del_rcu(&l
->list
);
98 spin_unlock_irqrestore(&wprobe_lock
, flags
);
102 EXPORT_SYMBOL(wprobe_remove_link
);
105 wprobe_measure_timer(unsigned long data
)
107 struct wprobe_iface
*dev
= (struct wprobe_iface
*) data
;
109 /* set next measurement interval */
110 mod_timer(&dev
->measure_timer
, jiffies
+
111 msecs_to_jiffies(dev
->measure_interval
));
113 /* perform measurement */
114 wprobe_sync_data(dev
, NULL
, false);
118 wprobe_add_iface(struct wprobe_iface
*s
)
123 /* reset only wprobe private area */
124 memset(&s
->list
, 0, sizeof(struct wprobe_iface
) - offsetof(struct wprobe_iface
, list
));
127 INIT_LIST_HEAD(&s
->list
);
128 INIT_LIST_HEAD(&s
->links
);
129 setup_timer(&s
->measure_timer
, wprobe_measure_timer
, (unsigned long) s
);
131 s
->val
= kzalloc(sizeof(struct wprobe_value
) * s
->n_global_items
, GFP_ATOMIC
);
135 vsize
= max(s
->n_link_items
, s
->n_global_items
);
136 s
->query_val
= kzalloc(sizeof(struct wprobe_value
) * vsize
, GFP_ATOMIC
);
140 /* initialize defaults to be able to handle overflow,
141 * user space will need to handle this if it keeps an
142 * internal histogram */
144 s
->scale_max
= (1 << 31);
149 spin_lock_irqsave(&wprobe_lock
, flags
);
150 list_add_rcu(&s
->list
, &wprobe_if
);
151 spin_unlock_irqrestore(&wprobe_lock
, flags
);
160 EXPORT_SYMBOL(wprobe_add_iface
);
163 wprobe_remove_iface(struct wprobe_iface
*s
)
167 BUG_ON(!list_empty(&s
->links
));
169 del_timer_sync(&s
->measure_timer
);
170 spin_lock_irqsave(&wprobe_lock
, flags
);
171 list_del_rcu(&s
->list
);
172 spin_unlock_irqrestore(&wprobe_lock
, flags
);
174 /* wait for all queries to finish before freeing the
175 * temporary value storage buffer */
180 if (s
->active_filter
)
181 wprobe_free_filter(s
->active_filter
);
183 EXPORT_SYMBOL(wprobe_remove_iface
);
185 static struct wprobe_iface
*
186 wprobe_get_dev(struct nlattr
*attr
)
188 struct wprobe_iface
*dev
= NULL
;
189 struct wprobe_iface
*p
;
196 name
= nla_data(attr
);
197 list_for_each_entry_rcu(p
, &wprobe_if
, list
) {
199 if (strcmp(name
, p
->name
) != 0)
210 wprobe_add_frame(struct wprobe_iface
*dev
, const struct wprobe_wlan_hdr
*hdr
, void *data
, int len
)
212 struct wprobe_wlan_hdr
*new_hdr
;
213 struct wprobe_filter
*f
;
219 f
= rcu_dereference(dev
->active_filter
);
223 spin_lock_irqsave(&f
->lock
, flags
);
226 skb
->len
= sizeof(struct wprobe_rtap_hdr
);
227 skb
->tail
= skb
->data
+ skb
->len
;
228 if (len
+ skb
->len
> WPROBE_MAX_FRAME_SIZE
)
229 len
= WPROBE_MAX_FRAME_SIZE
- skb
->len
;
231 new_hdr
= (struct wprobe_wlan_hdr
*) skb_put(skb
, f
->hdrlen
);
232 memcpy(new_hdr
, hdr
, sizeof(struct wprobe_wlan_hdr
));
233 new_hdr
->len
= cpu_to_be16(new_hdr
->len
);
235 memcpy(skb_put(skb
, len
), data
, len
);
237 for(i
= 0; i
< f
->n_groups
; i
++) {
238 struct wprobe_filter_group
*fg
= &f
->groups
[i
];
242 for (j
= 0; j
< fg
->n_items
; j
++) {
243 struct wprobe_filter_item
*fi
= fg
->items
[j
];
245 if (!fi
->hdr
.n_items
) {
249 #if LINUX_VERSION_CODE >= KERNEL_VERSION(2,6,38)
250 if (sk_run_filter(skb
, fi
->filter
) == 0)
253 if (sk_run_filter(skb
, fi
->filter
, fi
->hdr
.n_items
) == 0)
260 if (!found
&& def
>= 0) {
265 struct wprobe_filter_counter
*c
= &fg
->counters
[j
];
267 if (hdr
->type
>= WPROBE_PKT_TX
)
274 spin_unlock_irqrestore(&f
->lock
, flags
);
279 EXPORT_SYMBOL(wprobe_add_frame
);
282 wprobe_sync_data(struct wprobe_iface
*dev
, struct wprobe_link
*l
, bool query
)
284 struct wprobe_value
*val
;
289 n
= dev
->n_link_items
;
292 n
= dev
->n_global_items
;
296 spin_lock_irqsave(&dev
->lock
, flags
);
297 err
= dev
->sync_data(dev
, l
, val
, !query
);
302 memcpy(dev
->query_val
, val
, sizeof(struct wprobe_value
) * n
);
304 wprobe_update_stats(dev
, l
);
306 spin_unlock_irqrestore(&dev
->lock
, flags
);
309 EXPORT_SYMBOL(wprobe_sync_data
);
312 wprobe_scale_stats(struct wprobe_iface
*dev
, const struct wprobe_item
*item
,
313 struct wprobe_value
*val
, int n
)
315 u64 scale_ts
= jiffies_64
;
318 for (i
= 0; i
< n
; i
++) {
319 if (!(item
[i
].flags
& WPROBE_F_KEEPSTAT
))
322 if (val
[i
].n
<= dev
->scale_min
)
325 /* FIXME: div_s64 seems to be very imprecise here, even when
326 * the values are scaled up */
327 val
[i
].s
*= dev
->scale_m
;
328 val
[i
].s
= div_s64(val
[i
].s
, dev
->scale_d
);
330 val
[i
].ss
*= dev
->scale_m
;
331 val
[i
].ss
= div_s64(val
[i
].ss
, dev
->scale_d
);
333 val
[i
].n
= (val
[i
].n
* dev
->scale_m
) / dev
->scale_d
;
334 val
[i
].scale_timestamp
= scale_ts
;
340 wprobe_update_stats(struct wprobe_iface
*dev
, struct wprobe_link
*l
)
342 const struct wprobe_item
*item
;
343 struct wprobe_value
*val
;
344 bool scale_stats
= false;
348 n
= dev
->n_link_items
;
349 item
= dev
->link_items
;
352 n
= dev
->n_global_items
;
353 item
= dev
->global_items
;
357 /* process statistics */
358 for (i
= 0; i
< n
; i
++) {
365 if ((item
[i
].flags
& WPROBE_F_KEEPSTAT
) &&
366 (dev
->scale_max
> 0) && (val
[i
].n
> dev
->scale_max
)) {
370 switch(item
[i
].type
) {
401 val
[i
].pending
= false;
404 wprobe_scale_stats(dev
, item
, val
, n
);
406 EXPORT_SYMBOL(wprobe_update_stats
);
408 static const struct nla_policy wprobe_policy
[WPROBE_ATTR_LAST
+1] = {
409 [WPROBE_ATTR_INTERFACE
] = { .type
= NLA_NUL_STRING
},
410 [WPROBE_ATTR_MAC
] = { .type
= NLA_STRING
},
411 [WPROBE_ATTR_FLAGS
] = { .type
= NLA_U32
},
414 [WPROBE_ATTR_INTERVAL
] = { .type
= NLA_MSECS
},
415 [WPROBE_ATTR_SAMPLES_MIN
] = { .type
= NLA_U32
},
416 [WPROBE_ATTR_SAMPLES_MAX
] = { .type
= NLA_U32
},
417 [WPROBE_ATTR_SAMPLES_SCALE_M
] = { .type
= NLA_U32
},
418 [WPROBE_ATTR_SAMPLES_SCALE_D
] = { .type
= NLA_U32
},
419 [WPROBE_ATTR_FILTER
] = { .type
= NLA_BINARY
, .len
= 32768 },
423 wprobe_check_ptr(struct list_head
*list
, struct list_head
*ptr
)
427 list_for_each_rcu(p
, list
) {
435 wprobe_send_item_value(struct sk_buff
*msg
, struct netlink_callback
*cb
,
436 struct wprobe_iface
*dev
, struct wprobe_link
*l
,
437 const struct wprobe_item
*item
,
440 struct genlmsghdr
*hdr
;
441 struct wprobe_value
*val
= dev
->query_val
;
442 u64 time
= val
[i
].last
- val
[i
].first
;
444 hdr
= genlmsg_put(msg
, NETLINK_CB(cb
->skb
).pid
, cb
->nlh
->nlmsg_seq
,
445 &wprobe_fam
, NLM_F_MULTI
, WPROBE_CMD_GET_INFO
);
447 if (nla_put_u32(msg
, WPROBE_ATTR_ID
, i
))
448 goto nla_put_failure
;
449 if (nla_put_u32(msg
, WPROBE_ATTR_FLAGS
, flags
))
450 goto nla_put_failure
;
451 if (nla_put_u8(msg
, WPROBE_ATTR_TYPE
, item
[i
].type
))
452 goto nla_put_failure
;
453 if (nla_put_u64(msg
, WPROBE_ATTR_DURATION
, time
))
454 goto nla_put_failure
;
456 switch(item
[i
].type
) {
459 if (nla_put_u8(msg
, item
[i
].type
, val
[i
].U8
))
460 goto nla_put_failure
;
464 if (nla_put_u16(msg
, item
[i
].type
, val
[i
].U16
))
465 goto nla_put_failure
;
469 if (nla_put_u32(msg
, item
[i
].type
, val
[i
].U32
))
470 goto nla_put_failure
;
474 if (nla_put_u64(msg
, item
[i
].type
, val
[i
].U64
))
475 goto nla_put_failure
;
477 case WPROBE_VAL_STRING
:
479 if (nla_put_string(msg
, item
[i
].type
, val
[i
].STRING
))
480 goto nla_put_failure
;
482 if (nla_put_string(msg
, item
[i
].type
, ""))
483 goto nla_put_failure
;
485 /* bypass avg/stdev */
488 /* skip unknown values */
491 if (item
[i
].flags
& WPROBE_F_KEEPSTAT
) {
492 if (nla_put_u64(msg
, WPROBE_VAL_SUM
, val
[i
].s
))
493 goto nla_put_failure
;
494 if (nla_put_u64(msg
, WPROBE_VAL_SUM_SQ
, val
[i
].ss
))
495 goto nla_put_failure
;
496 if (nla_put_u32(msg
, WPROBE_VAL_SAMPLES
, (u32
) val
[i
].n
))
497 goto nla_put_failure
;
498 if (nla_put_msecs(msg
, WPROBE_VAL_SCALE_TIME
, val
[i
].scale_timestamp
))
499 goto nla_put_failure
;
502 genlmsg_end(msg
, hdr
);
506 genlmsg_cancel(msg
, hdr
);
511 wprobe_send_item_info(struct sk_buff
*msg
, struct netlink_callback
*cb
,
512 struct wprobe_iface
*dev
,
513 const struct wprobe_item
*item
, int i
)
515 struct genlmsghdr
*hdr
;
517 hdr
= genlmsg_put(msg
, NETLINK_CB(cb
->skb
).pid
, cb
->nlh
->nlmsg_seq
,
518 &wprobe_fam
, NLM_F_MULTI
, WPROBE_CMD_GET_LIST
);
520 if ((i
== 0) && (dev
->addr
!= NULL
)) {
521 if (nla_put(msg
, WPROBE_ATTR_MAC
, 6, dev
->addr
))
522 goto nla_put_failure
;
524 if (nla_put_u32(msg
, WPROBE_ATTR_ID
, (u32
) i
))
525 goto nla_put_failure
;
526 if (nla_put_string(msg
, WPROBE_ATTR_NAME
, item
[i
].name
))
527 goto nla_put_failure
;
528 if (nla_put_u8(msg
, WPROBE_ATTR_TYPE
, item
[i
].type
))
529 goto nla_put_failure
;
530 if (nla_put_u32(msg
, WPROBE_ATTR_FLAGS
, item
[i
].flags
))
531 goto nla_put_failure
;
532 genlmsg_end(msg
, hdr
);
536 genlmsg_cancel(msg
, hdr
);
541 static struct wprobe_link
*
542 wprobe_find_link(struct wprobe_iface
*dev
, const char *mac
)
544 struct wprobe_link
*l
;
546 list_for_each_entry_rcu(l
, &dev
->links
, list
) {
547 if (!memcmp(l
->addr
, mac
, 6))
554 wprobe_dump_filter_group(struct sk_buff
*msg
, struct wprobe_filter_group
*fg
, struct netlink_callback
*cb
)
556 struct genlmsghdr
*hdr
;
557 struct nlattr
*group
, *item
;
560 hdr
= genlmsg_put(msg
, NETLINK_CB(cb
->skb
).pid
, cb
->nlh
->nlmsg_seq
,
561 &wprobe_fam
, NLM_F_MULTI
, WPROBE_CMD_GET_FILTER
);
565 if (nla_put_string(msg
, WPROBE_ATTR_NAME
, fg
->name
))
566 goto nla_put_failure
;
567 group
= nla_nest_start(msg
, WPROBE_ATTR_FILTER_GROUP
);
568 for (i
= 0; i
< fg
->n_items
; i
++) {
569 struct wprobe_filter_item
*fi
= fg
->items
[i
];
570 struct wprobe_filter_counter
*fc
= &fg
->counters
[i
];
572 item
= nla_nest_start(msg
, WPROBE_ATTR_FILTER_GROUP
);
573 if (nla_put_string(msg
, WPROBE_ATTR_NAME
, fi
->hdr
.name
))
574 goto nla_put_failure
;
575 if (nla_put_u64(msg
, WPROBE_ATTR_RXCOUNT
, fc
->rx
))
576 goto nla_put_failure
;
577 if (nla_put_u64(msg
, WPROBE_ATTR_TXCOUNT
, fc
->tx
))
578 goto nla_put_failure
;
579 nla_nest_end(msg
, item
);
582 nla_nest_end(msg
, group
);
583 genlmsg_end(msg
, hdr
);
587 genlmsg_cancel(msg
, hdr
);
592 wprobe_dump_filters(struct sk_buff
*skb
, struct netlink_callback
*cb
)
594 struct wprobe_iface
*dev
= (struct wprobe_iface
*)cb
->args
[0];
595 struct wprobe_filter
*f
;
600 err
= nlmsg_parse(cb
->nlh
, GENL_HDRLEN
+ wprobe_fam
.hdrsize
,
601 wprobe_fam
.attrbuf
, wprobe_fam
.maxattr
, wprobe_policy
);
605 dev
= wprobe_get_dev(wprobe_fam
.attrbuf
[WPROBE_ATTR_INTERFACE
]);
611 cb
->args
[0] = (long) dev
;
614 if (!wprobe_check_ptr(&wprobe_if
, &dev
->list
)) {
621 f
= rcu_dereference(dev
->active_filter
);
625 for (i
= cb
->args
[1]; i
< f
->n_groups
; i
++) {
626 if (unlikely(!wprobe_dump_filter_group(skb
, &f
->groups
[i
], cb
)))
638 wprobe_dump_link(struct sk_buff
*msg
, struct wprobe_link
*l
, struct netlink_callback
*cb
)
640 struct genlmsghdr
*hdr
;
642 hdr
= genlmsg_put(msg
, NETLINK_CB(cb
->skb
).pid
, cb
->nlh
->nlmsg_seq
,
643 &wprobe_fam
, NLM_F_MULTI
, WPROBE_CMD_GET_LINKS
);
647 if (nla_put(msg
, WPROBE_ATTR_MAC
, 6, l
->addr
))
648 goto nla_put_failure
;
649 genlmsg_end(msg
, hdr
);
653 genlmsg_cancel(msg
, hdr
);
658 wprobe_dump_links(struct sk_buff
*skb
, struct netlink_callback
*cb
)
660 struct wprobe_iface
*dev
= (struct wprobe_iface
*)cb
->args
[0];
661 struct wprobe_link
*l
;
666 err
= nlmsg_parse(cb
->nlh
, GENL_HDRLEN
+ wprobe_fam
.hdrsize
,
667 wprobe_fam
.attrbuf
, wprobe_fam
.maxattr
, wprobe_policy
);
671 dev
= wprobe_get_dev(wprobe_fam
.attrbuf
[WPROBE_ATTR_INTERFACE
]);
677 cb
->args
[0] = (long) dev
;
679 if (!wprobe_check_ptr(&wprobe_if
, &dev
->list
)) {
686 list_for_each_entry_rcu(l
, &dev
->links
, list
) {
690 if (unlikely(!wprobe_dump_link(skb
, l
, cb
)))
702 #define WPROBE_F_LINK (1 << 31) /* for internal use */
704 wprobe_dump_info(struct sk_buff
*skb
, struct netlink_callback
*cb
)
706 struct wprobe_iface
*dev
= (struct wprobe_iface
*)cb
->args
[0];
707 struct wprobe_link
*l
= (struct wprobe_link
*)cb
->args
[1];
708 struct wprobe_value
*val
;
709 const struct wprobe_item
*item
;
710 struct genlmsghdr
*hdr
;
712 int cmd
, n
, i
= cb
->args
[3];
713 u32 vflags
= cb
->args
[2];
716 hdr
= (struct genlmsghdr
*)nlmsg_data(cb
->nlh
);
719 /* since the attribute value list might be too big for a single netlink
720 * message, the device, link and offset get stored in the netlink callback.
721 * if this is the first request, we need to do the full lookup for the device.
723 * access to the device and link structure is synchronized through rcu.
727 err
= nlmsg_parse(cb
->nlh
, GENL_HDRLEN
+ wprobe_fam
.hdrsize
,
728 wprobe_fam
.attrbuf
, wprobe_fam
.maxattr
, wprobe_policy
);
733 dev
= wprobe_get_dev(wprobe_fam
.attrbuf
[WPROBE_ATTR_INTERFACE
]);
737 if (cmd
== WPROBE_CMD_GET_INFO
) {
738 if (wprobe_fam
.attrbuf
[WPROBE_ATTR_MAC
]) {
739 l
= wprobe_find_link(dev
, nla_data(wprobe_fam
.attrbuf
[WPROBE_ATTR_MAC
]));
747 item
= dev
->link_items
;
748 n
= dev
->n_link_items
;
751 item
= dev
->global_items
;
752 n
= dev
->n_global_items
;
756 /* sync data and move to temp storage for the query */
757 spin_lock_irqsave(&dev
->lock
, flags
);
758 err
= wprobe_sync_data(dev
, l
, true);
760 memcpy(dev
->query_val
, val
, n
* sizeof(struct wprobe_value
));
761 spin_unlock_irqrestore(&dev
->lock
, flags
);
767 if (wprobe_fam
.attrbuf
[WPROBE_ATTR_FLAGS
])
768 vflags
|= nla_get_u32(wprobe_fam
.attrbuf
[WPROBE_ATTR_FLAGS
]);
770 if (wprobe_fam
.attrbuf
[WPROBE_ATTR_MAC
])
771 vflags
|= WPROBE_F_LINK
;
773 cb
->args
[0] = (long) dev
;
774 cb
->args
[1] = (long) l
;
775 cb
->args
[2] = vflags
;
778 /* when pulling pointers from the callback, validate them
779 * against the list using rcu to make sure that we won't
780 * dereference pointers to free'd memory after the last
783 if (!wprobe_check_ptr(&wprobe_if
, &dev
->list
))
786 if (l
&& !wprobe_check_ptr(&dev
->links
, &l
->list
))
790 if (vflags
& WPROBE_F_LINK
) {
791 item
= dev
->link_items
;
792 n
= dev
->n_link_items
;
794 item
= dev
->global_items
;
795 n
= dev
->n_global_items
;
800 case WPROBE_CMD_GET_INFO
:
802 if (!wprobe_send_item_value(skb
, cb
, dev
, l
, item
, i
, vflags
))
807 case WPROBE_CMD_GET_LIST
:
809 if (!wprobe_send_item_info(skb
, cb
, dev
, item
, i
))
828 wprobe_update_auto_measurement(struct wprobe_iface
*dev
, u32 interval
)
830 if (interval
&& (interval
< WPROBE_MIN_INTERVAL
))
833 if (!interval
&& dev
->measure_interval
)
834 del_timer_sync(&dev
->measure_timer
);
836 dev
->measure_interval
= interval
;
840 /* kick of a new measurement immediately */
841 mod_timer(&dev
->measure_timer
, jiffies
+ 1);
847 wprobe_measure(struct sk_buff
*skb
, struct genl_info
*info
)
849 struct wprobe_iface
*dev
;
850 struct wprobe_link
*l
= NULL
;
854 dev
= wprobe_get_dev(info
->attrs
[WPROBE_ATTR_INTERFACE
]);
858 if (info
->attrs
[WPROBE_ATTR_MAC
]) {
859 l
= wprobe_find_link(dev
, nla_data(wprobe_fam
.attrbuf
[WPROBE_ATTR_MAC
]));
864 err
= wprobe_sync_data(dev
, l
, false);
872 wprobe_check_filter(void *data
, int datalen
, int gs
)
874 struct wprobe_filter_item_hdr
*hdr
;
875 void *orig_data
= data
;
876 void *end
= data
+ datalen
;
877 int i
, j
, k
, is
, cur_is
;
879 for (i
= j
= is
= 0; i
< gs
; i
++) {
881 data
+= sizeof(*hdr
);
887 cur_is
= be32_to_cpu(hdr
->n_items
);
888 hdr
->n_items
= cur_is
;
890 for (j
= 0; j
< cur_is
; j
++) {
891 struct sock_filter
*sf
;
895 data
+= sizeof(*hdr
);
900 n_items
= be32_to_cpu(hdr
->n_items
);
901 hdr
->n_items
= n_items
;
908 for (k
= 0; k
< n_items
; k
++) {
909 sf
->code
= be16_to_cpu(sf
->code
);
910 sf
->k
= be32_to_cpu(sf
->k
);
913 if (sk_chk_filter(data
, n_items
) != 0) {
914 printk("%s: filter check failed at group %d, item %d\n", __func__
, i
, j
);
918 data
+= n_items
* sizeof(struct sock_filter
);
924 printk(KERN_ERR
"%s: overrun during filter check at group %d, item %d, offset=%d, len=%d\n", __func__
, i
, j
, (data
- orig_data
), datalen
);
929 wprobe_free_filter(struct wprobe_filter
*f
)
944 wprobe_set_filter(struct wprobe_iface
*dev
, void *data
, int len
)
946 struct wprobe_filter_hdr
*fhdr
;
947 struct wprobe_rtap_hdr
*rtap
;
948 struct wprobe_filter
*f
;
949 int i
, j
, cur_is
, is
, gs
;
951 if (len
< sizeof(*fhdr
))
955 data
+= sizeof(*fhdr
);
956 len
-= sizeof(*fhdr
);
958 if (memcmp(fhdr
->magic
, "WPFF", 4) != 0) {
959 printk(KERN_ERR
"%s: filter rejected (invalid magic)\n", __func__
);
963 gs
= be16_to_cpu(fhdr
->n_groups
);
964 is
= wprobe_check_filter(data
, len
, gs
);
968 f
= kzalloc(sizeof(struct wprobe_filter
) +
969 gs
* sizeof(struct wprobe_filter_group
), GFP_ATOMIC
);
973 f
->skb
= alloc_skb(WPROBE_MAX_FRAME_SIZE
, GFP_ATOMIC
);
977 f
->data
= kmalloc(len
, GFP_ATOMIC
);
981 f
->items
= kzalloc(sizeof(struct wprobe_filter_item
*) * is
, GFP_ATOMIC
);
985 f
->counters
= kzalloc(sizeof(struct wprobe_filter_counter
) * is
, GFP_ATOMIC
);
989 spin_lock_init(&f
->lock
);
990 memcpy(f
->data
, data
, len
);
993 if (f
->hdrlen
< sizeof(struct wprobe_wlan_hdr
))
994 f
->hdrlen
= sizeof(struct wprobe_wlan_hdr
);
996 rtap
= (struct wprobe_rtap_hdr
*)skb_put(f
->skb
, sizeof(*rtap
));
997 memset(rtap
, 0, sizeof(*rtap
));
998 rtap
->len
= cpu_to_le16(sizeof(struct wprobe_rtap_hdr
) + f
->hdrlen
);
1002 for (i
= 0; i
< gs
; i
++) {
1003 struct wprobe_filter_item_hdr
*hdr
= data
;
1004 struct wprobe_filter_group
*g
= &f
->groups
[i
];
1006 data
+= sizeof(*hdr
);
1007 g
->name
= hdr
->name
;
1008 g
->items
= &f
->items
[cur_is
];
1009 g
->counters
= &f
->counters
[cur_is
];
1010 g
->n_items
= hdr
->n_items
;
1012 for (j
= 0; j
< g
->n_items
; j
++) {
1014 f
->items
[cur_is
++] = data
;
1015 data
+= sizeof(*hdr
) + hdr
->n_items
* sizeof(struct sock_filter
);
1018 rcu_assign_pointer(dev
->active_filter
, f
);
1022 wprobe_free_filter(f
);
1027 wprobe_set_config(struct sk_buff
*skb
, struct genl_info
*info
)
1029 struct wprobe_iface
*dev
;
1030 unsigned long flags
;
1032 u32 scale_min
, scale_max
;
1033 u32 scale_m
, scale_d
;
1034 struct nlattr
*attr
;
1035 struct wprobe_filter
*filter_free
= NULL
;
1038 dev
= wprobe_get_dev(info
->attrs
[WPROBE_ATTR_INTERFACE
]);
1043 spin_lock_irqsave(&dev
->lock
, flags
);
1044 if (info
->attrs
[WPROBE_ATTR_MAC
]) {
1045 /* not supported yet */
1049 if (info
->attrs
[WPROBE_ATTR_FLAGS
]) {
1050 u32 flags
= nla_get_u32(info
->attrs
[WPROBE_ATTR_FLAGS
]);
1052 if (flags
& BIT(WPROBE_F_RESET
)) {
1053 struct wprobe_link
*l
;
1055 memset(dev
->val
, 0, sizeof(struct wprobe_value
) * dev
->n_global_items
);
1056 list_for_each_entry_rcu(l
, &dev
->links
, list
) {
1057 memset(l
->val
, 0, sizeof(struct wprobe_value
) * dev
->n_link_items
);
1062 if (info
->attrs
[WPROBE_ATTR_SAMPLES_MIN
] ||
1063 info
->attrs
[WPROBE_ATTR_SAMPLES_MAX
]) {
1064 if ((attr
= info
->attrs
[WPROBE_ATTR_SAMPLES_MIN
]))
1065 scale_min
= nla_get_u32(attr
);
1067 scale_min
= dev
->scale_min
;
1069 if ((attr
= info
->attrs
[WPROBE_ATTR_SAMPLES_MAX
]))
1070 scale_max
= nla_get_u32(attr
);
1072 scale_max
= dev
->scale_max
;
1074 if ((!scale_min
&& !scale_max
) ||
1075 (scale_min
&& scale_max
&& (scale_min
< scale_max
))) {
1076 dev
->scale_min
= scale_min
;
1077 dev
->scale_max
= scale_max
;
1083 if (info
->attrs
[WPROBE_ATTR_SAMPLES_SCALE_M
] &&
1084 info
->attrs
[WPROBE_ATTR_SAMPLES_SCALE_D
]) {
1086 scale_m
= nla_get_u32(info
->attrs
[WPROBE_ATTR_SAMPLES_SCALE_M
]);
1087 scale_d
= nla_get_u32(info
->attrs
[WPROBE_ATTR_SAMPLES_SCALE_D
]);
1089 if (!scale_d
|| (scale_m
> scale_d
))
1092 dev
->scale_m
= scale_m
;
1093 dev
->scale_d
= scale_d
;
1096 if ((attr
= info
->attrs
[WPROBE_ATTR_FILTER
])) {
1097 filter_free
= rcu_dereference(dev
->active_filter
);
1098 rcu_assign_pointer(dev
->active_filter
, NULL
);
1099 if (nla_len(attr
) > 0)
1100 wprobe_set_filter(dev
, nla_data(attr
), nla_len(attr
));
1104 if (info
->attrs
[WPROBE_ATTR_INTERVAL
]) {
1105 /* change of measurement interval requested */
1106 err
= wprobe_update_auto_measurement(dev
,
1107 (u32
) nla_get_u64(info
->attrs
[WPROBE_ATTR_INTERVAL
]));
1111 spin_unlock_irqrestore(&dev
->lock
, flags
);
1116 wprobe_free_filter(filter_free
);
1121 static struct genl_ops wprobe_ops
[] = {
1123 .cmd
= WPROBE_CMD_GET_INFO
,
1124 .dumpit
= wprobe_dump_info
,
1125 .policy
= wprobe_policy
,
1128 .cmd
= WPROBE_CMD_GET_LIST
,
1129 .dumpit
= wprobe_dump_info
,
1130 .policy
= wprobe_policy
,
1133 .cmd
= WPROBE_CMD_MEASURE
,
1134 .doit
= wprobe_measure
,
1135 .policy
= wprobe_policy
,
1138 .cmd
= WPROBE_CMD_GET_LINKS
,
1139 .dumpit
= wprobe_dump_links
,
1140 .policy
= wprobe_policy
,
1143 .cmd
= WPROBE_CMD_CONFIG
,
1144 .doit
= wprobe_set_config
,
1145 .policy
= wprobe_policy
,
1148 .cmd
= WPROBE_CMD_GET_FILTER
,
1149 .dumpit
= wprobe_dump_filters
,
1150 .policy
= wprobe_policy
,
1157 BUG_ON(!list_empty(&wprobe_if
));
1158 genl_unregister_family(&wprobe_fam
);
1167 spin_lock_init(&wprobe_lock
);
1168 INIT_LIST_HEAD(&wprobe_if
);
1170 err
= genl_register_family(&wprobe_fam
);
1174 for (i
= 0; i
< ARRAY_SIZE(wprobe_ops
); i
++) {
1175 err
= genl_register_ops(&wprobe_fam
, &wprobe_ops
[i
]);
1183 genl_unregister_family(&wprobe_fam
);
1187 module_init(wprobe_init
);
1188 module_exit(wprobe_exit
);
1189 MODULE_LICENSE("GPL");