Added additional counters in a bat_stats structure, which are exported through the ethtool api. The counters are specific to batman-adv and includes: forwarded packets management packets (OGMs at this point) translation table packets distributed arp table packets
I would like you all to check if the increments are added at the right locations and also if more counters would be relevant. (E.g. in bridge loop avoidance code?)
This is the reworked approach from the previous stat counters patch I send, where ethtool stats was suggested.
v2: Changed to per_cpu variables. Added ifdefs for optional submodules.
Signed-off-by: Martin Hundebøll martin@hundeboll.net --- bat_iv_ogm.c | 6 +++- distributed-arp-table.c | 8 ++++- main.h | 22 +++++++++++++ routing.c | 9 ++++++ soft-interface.c | 81 +++++++++++++++++++++++++++++++++++++++++++++-- translation-table.c | 8 +++++ types.h | 19 +++++++++++ 7 files changed, 149 insertions(+), 4 deletions(-)
diff --git a/bat_iv_ogm.c b/bat_iv_ogm.c index 994369d..327af94 100644 --- a/bat_iv_ogm.c +++ b/bat_iv_ogm.c @@ -196,8 +196,10 @@ static void bat_iv_ogm_send_to_if(struct forw_packet *forw_packet,
/* create clone because function is called more than once */ skb = skb_clone(forw_packet->skb, GFP_ATOMIC); - if (skb) + if (skb) { + inc_counter(bat_priv, mgmt_tx); send_skb_packet(skb, hard_iface, broadcast_addr); + } }
/* send a batman ogm packet */ @@ -956,6 +958,8 @@ static void bat_iv_ogm_process(const struct ethhdr *ethhdr, if (batman_ogm_packet->header.packet_type != BAT_IV_OGM) return;
+ inc_counter(bat_priv, mgmt_rx); + /* could be changed by schedule_own_packet() */ if_incoming_seqno = atomic_read(&if_incoming->seqno);
diff --git a/distributed-arp-table.c b/distributed-arp-table.c index b43bece..b771162 100644 --- a/distributed-arp-table.c +++ b/distributed-arp-table.c @@ -395,9 +395,11 @@ bool dat_snoop_outgoing_arp_request(struct bat_priv *bat_priv,
netif_rx(skb_new); bat_dbg(DBG_DAT, bat_priv, "ARP request replied locally\n"); - } else + } else { /* Send the request on the DHT */ + inc_counter(bat_priv, dat_request_tx); ret = dht_send_data(bat_priv, skb, ip_dst, BAT_P_DAT_DHT_GET); + } out: if (n) neigh_release(n); @@ -450,6 +452,8 @@ bool dat_snoop_incoming_arp_request(struct bat_priv *bat_priv, if (!skb_new) goto out;
+ inc_counter(bat_priv, dat_reply_tx); + unicast_4addr_send_skb(skb_new, bat_priv, BAT_P_DAT_CACHE_REPLY);
ret = true; @@ -488,6 +492,8 @@ bool dat_snoop_outgoing_arp_reply(struct bat_priv *bat_priv, arp_neigh_update(bat_priv, ip_src, hw_src); arp_neigh_update(bat_priv, ip_dst, hw_dst);
+ inc_counter(bat_priv, dat_reply_tx); + /* Send the ARP reply to the candidates for both the IP addresses we * fetched from the ARP reply */ dht_send_data(bat_priv, skb, ip_src, BAT_P_DAT_DHT_PUT); diff --git a/main.h b/main.h index c8bfe28..015b4fa 100644 --- a/main.h +++ b/main.h @@ -150,6 +150,7 @@ enum dbg_level { #include <linux/kthread.h> /* kernel threads */ #include <linux/pkt_sched.h> /* schedule types */ #include <linux/workqueue.h> /* workqueue */ +#include <linux/percpu.h> #include <linux/slab.h> #include <net/sock.h> /* struct sock */ #include <linux/jiffies.h> @@ -259,4 +260,25 @@ static inline bool has_timed_out(unsigned long timestamp, unsigned int timeout) _dummy > smallest_signed_int(_dummy); }) #define seq_after(x, y) seq_before(y, x)
+/* Stop preemption on local cpu and increment the named counter */ +#define inc_counter(__bp, __counter) \ + do { \ + struct bat_stats *__bs; \ + int __cpu; \ + __cpu = get_cpu(); \ + __bs = per_cpu_ptr(__bp->bat_stats_cpu, __cpu); \ + __bs->__counter++; \ + put_cpu(); \ + } while (0); + +#define sum_counter(__bp, __counter, __sum) \ + do { \ + struct bat_stats *__bs; \ + int __cpu; \ + for_each_possible_cpu(__cpu) { \ + __bs = per_cpu_ptr(__bp->bat_stats_cpu, __cpu); \ + __sum += __bs->__counter; \ + } \ + } while (0); + #endif /* _NET_BATMAN_ADV_MAIN_H_ */ diff --git a/routing.c b/routing.c index 795d3af..bb5b338 100644 --- a/routing.c +++ b/routing.c @@ -600,6 +600,8 @@ int recv_tt_query(struct sk_buff *skb, struct hard_iface *recv_if)
switch (tt_query->flags & TT_QUERY_TYPE_MASK) { case TT_REQUEST: + inc_counter(bat_priv, tt_request_rx); + /* If we cannot provide an answer the tt_request is * forwarded */ if (!send_tt_response(bat_priv, tt_query)) { @@ -612,6 +614,8 @@ int recv_tt_query(struct sk_buff *skb, struct hard_iface *recv_if) } break; case TT_RESPONSE: + inc_counter(bat_priv, tt_response_rx); + if (is_my_mac(tt_query->dst)) { /* packet needs to be linearized to access the TT * changes */ @@ -663,6 +667,8 @@ int recv_roam_adv(struct sk_buff *skb, struct hard_iface *recv_if) if (is_broadcast_ether_addr(ethhdr->h_source)) goto out;
+ inc_counter(bat_priv, tt_roam_adv_rx); + roam_adv_packet = (struct roam_adv_packet *)skb->data;
if (!is_my_mac(roam_adv_packet->dst)) @@ -869,6 +875,9 @@ static int route_unicast_packet(struct sk_buff *skb, struct hard_iface *recv_if) /* decrement ttl */ unicast_packet->header.ttl--;
+ /* Update stats counter */ + inc_counter(bat_priv, forward); + /* route it */ send_skb_packet(skb, neigh_node->if_incoming, neigh_node->addr); ret = NET_RX_SUCCESS; diff --git a/soft-interface.c b/soft-interface.c index 92137af..b510d2e 100644 --- a/soft-interface.c +++ b/soft-interface.c @@ -46,6 +46,10 @@ static void bat_get_drvinfo(struct net_device *dev, static u32 bat_get_msglevel(struct net_device *dev); static void bat_set_msglevel(struct net_device *dev, u32 value); static u32 bat_get_link(struct net_device *dev); +static void bat_get_strings(struct net_device *dev, u32 stringset, u8 *data); +static void bat_get_ethtool_stats(struct net_device *dev, + struct ethtool_stats *stats, u64 *data); +static int bat_get_sset_count(struct net_device *dev, int stringset);
static const struct ethtool_ops bat_ethtool_ops = { .get_settings = bat_get_settings, @@ -53,6 +57,9 @@ static const struct ethtool_ops bat_ethtool_ops = { .get_msglevel = bat_get_msglevel, .set_msglevel = bat_set_msglevel, .get_link = bat_get_link, + .get_strings = bat_get_strings, + .get_ethtool_stats = bat_get_ethtool_stats, + .get_sset_count = bat_get_sset_count, };
int my_skb_head_push(struct sk_buff *skb, unsigned int len) @@ -411,13 +418,17 @@ struct net_device *softif_create(const char *name) bat_priv->primary_if = NULL; bat_priv->num_ifaces = 0;
+ bat_priv->bat_stats_cpu = alloc_percpu(struct bat_stats); + if (!bat_priv->bat_stats_cpu) + goto unreg_soft_iface; + ret = bat_algo_select(bat_priv, bat_routing_algo); if (ret < 0) - goto unreg_soft_iface; + goto free_bat_stats;
ret = sysfs_add_meshif(soft_iface); if (ret < 0) - goto unreg_soft_iface; + goto free_bat_stats;
ret = debugfs_add_meshif(soft_iface); if (ret < 0) @@ -433,6 +444,8 @@ unreg_debugfs: debugfs_del_meshif(soft_iface); unreg_sysfs: sysfs_del_meshif(soft_iface); +free_bat_stats: + free_percpu(bat_priv->bat_stats_cpu); unreg_soft_iface: unregister_netdevice(soft_iface); return NULL; @@ -445,6 +458,8 @@ out:
void softif_destroy(struct net_device *soft_iface) { + struct bat_priv *bat_priv = netdev_priv(soft_iface); + free_percpu(bat_priv->bat_stats_cpu); debugfs_del_meshif(soft_iface); sysfs_del_meshif(soft_iface); mesh_free(soft_iface); @@ -498,3 +513,65 @@ static u32 bat_get_link(struct net_device *dev) { return 1; } + +/* Inspired by drivers/net/ethernet/dlink/sundance.c:1702 */ +static const struct { + const char name[ETH_GSTRING_LEN]; +} bat_stats_strings[] = { + { "forward" }, + { "mgmt_tx" }, + { "mgmt_rx" }, + { "tt_request_tx" }, + { "tt_request_rx" }, + { "tt_response_tx" }, + { "tt_response_rx" }, + { "tt_roam_adv_tx" }, + { "tt_roam_adv_rx" }, +#ifdef CONFIG_BATMAN_ADV_DAT + { "dat_request_tx" }, + { "dat_request_rx" }, + { "dat_reply_tx" }, + { "dat_reply_rx" }, +#endif +}; +#define BAT_STATS_NUM (sizeof(bat_stats_strings)/ETH_GSTRING_LEN) + +static void bat_get_strings(struct net_device *dev, uint32_t stringset, + uint8_t *data) +{ + if (stringset == ETH_SS_STATS) + memcpy(data, bat_stats_strings, sizeof(bat_stats_strings)); +} + +static void bat_get_ethtool_stats(struct net_device *dev, + struct ethtool_stats *stats, uint64_t *data) +{ + struct bat_priv *bat_priv = netdev_priv(dev); + int i = 0; + + memset(data, 0, BAT_STATS_NUM*sizeof(*data)); + + sum_counter(bat_priv, forward, data[i++]); + sum_counter(bat_priv, mgmt_tx, data[i++]); + sum_counter(bat_priv, mgmt_rx, data[i++]); + sum_counter(bat_priv, tt_request_tx, data[i++]); + sum_counter(bat_priv, tt_request_rx, data[i++]); + sum_counter(bat_priv, tt_response_tx, data[i++]); + sum_counter(bat_priv, tt_response_rx, data[i++]); + sum_counter(bat_priv, tt_roam_adv_tx, data[i++]); + sum_counter(bat_priv, tt_roam_adv_rx, data[i++]); +#ifdef CONFIG_BATMAN_ADV_DAT + sum_counter(bat_priv, dat_request_tx, data[i++]); + sum_counter(bat_priv, dat_request_rx, data[i++]); + sum_counter(bat_priv, dat_reply_tx, data[i++]); + sum_counter(bat_priv, dat_reply_rx, data[i++]); +#endif +} + +static int bat_get_sset_count(struct net_device *dev, int stringset) +{ + if (stringset == ETH_SS_STATS) + return BAT_STATS_NUM; + + return -EOPNOTSUPP; +} diff --git a/translation-table.c b/translation-table.c index b3e608a..32aa22c 100644 --- a/translation-table.c +++ b/translation-table.c @@ -1352,6 +1352,8 @@ static int send_tt_request(struct bat_priv *bat_priv, dst_orig_node->orig, neigh_node->addr, (full_table ? 'F' : '.'));
+ inc_counter(bat_priv, tt_request_tx); + send_skb_packet(skb, neigh_node->if_incoming, neigh_node->addr); ret = 0;
@@ -1476,6 +1478,8 @@ static bool send_other_tt_response(struct bat_priv *bat_priv, res_dst_orig_node->orig, neigh_node->addr, req_dst_orig_node->orig, req_ttvn);
+ inc_counter(bat_priv, tt_response_tx); + send_skb_packet(skb, neigh_node->if_incoming, neigh_node->addr); ret = true; goto out; @@ -1592,6 +1596,8 @@ static bool send_my_tt_response(struct bat_priv *bat_priv, orig_node->orig, neigh_node->addr, (tt_response->flags & TT_FULL_TABLE ? 'F' : '.'));
+ inc_counter(bat_priv, tt_response_tx); + send_skb_packet(skb, neigh_node->if_incoming, neigh_node->addr); ret = true; goto out; @@ -1891,6 +1897,8 @@ static void send_roam_adv(struct bat_priv *bat_priv, uint8_t *client, "Sending ROAMING_ADV to %pM (client %pM) via %pM\n", orig_node->orig, client, neigh_node->addr);
+ inc_counter(bat_priv, tt_roam_adv_tx); + send_skb_packet(skb, neigh_node->if_incoming, neigh_node->addr); ret = 0;
diff --git a/types.h b/types.h index 15f538a..dd87e8b 100644 --- a/types.h +++ b/types.h @@ -162,9 +162,28 @@ struct bcast_duplist_entry { }; #endif
+struct bat_stats { + uint64_t forward; + uint64_t mgmt_tx; + uint64_t mgmt_rx; + uint64_t tt_request_tx; + uint64_t tt_request_rx; + uint64_t tt_response_tx; + uint64_t tt_response_rx; + uint64_t tt_roam_adv_tx; + uint64_t tt_roam_adv_rx; +#ifdef CONFIG_BATMAN_ADV_DAT + uint64_t dat_request_tx; + uint64_t dat_request_rx; + uint64_t dat_reply_tx; + uint64_t dat_reply_rx; +#endif +}; + struct bat_priv { atomic_t mesh_state; struct net_device_stats stats; + struct bat_stats *bat_stats_cpu; /* Per cpu counters */ atomic_t aggregated_ogms; /* boolean */ atomic_t bonding; /* boolean */ atomic_t fragmentation; /* boolean */