summaryrefslogtreecommitdiff
path: root/lib/librte_port
diff options
context:
space:
mode:
authorMaciej Gajdzica <maciejx.t.gajdzica@intel.com>2015-06-19 11:41:24 +0200
committerThomas Monjalon <thomas.monjalon@6wind.com>2015-06-23 23:31:14 +0200
commit4d7eabf9f72e2b03e3a44684067481f29dc99f78 (patch)
tree866bb77e22936bde9c2de0d388d10f84b8c72618 /lib/librte_port
parent3276f38f3ee5797ba9f678abbd369209fa298313 (diff)
downloaddpdk-next-eventdev-4d7eabf9f72e2b03e3a44684067481f29dc99f78.zip
dpdk-next-eventdev-4d7eabf9f72e2b03e3a44684067481f29dc99f78.tar.gz
dpdk-next-eventdev-4d7eabf9f72e2b03e3a44684067481f29dc99f78.tar.xz
port: add source stats
Added statistics for source port. Signed-off-by: Maciej Gajdzica <maciejx.t.gajdzica@intel.com> Acked-by: Cristian Dumitrescu <cristian.dumitrescu@intel.com>
Diffstat (limited to 'lib/librte_port')
-rw-r--r--lib/librte_port/rte_port_source_sink.c35
1 files changed, 35 insertions, 0 deletions
diff --git a/lib/librte_port/rte_port_source_sink.c b/lib/librte_port/rte_port_source_sink.c
index b9a25bb..234ab18 100644
--- a/lib/librte_port/rte_port_source_sink.c
+++ b/lib/librte_port/rte_port_source_sink.c
@@ -42,7 +42,23 @@
/*
* Port SOURCE
*/
+#ifdef RTE_PORT_STATS_COLLECT
+
+#define RTE_PORT_SOURCE_STATS_PKTS_IN_ADD(port, val) \
+ port->stats.n_pkts_in += val
+#define RTE_PORT_SOURCE_STATS_PKTS_DROP_ADD(port, val) \
+ port->stats.n_pkts_drop += val
+
+#else
+
+#define RTE_PORT_SOURCE_STATS_PKTS_IN_ADD(port, val)
+#define RTE_PORT_SOURCE_STATS_PKTS_DROP_ADD(port, val)
+
+#endif
+
struct rte_port_source {
+ struct rte_port_in_stats stats;
+
struct rte_mempool *mempool;
};
@@ -93,9 +109,27 @@ rte_port_source_rx(void *port, struct rte_mbuf **pkts, uint32_t n_pkts)
if (rte_mempool_get_bulk(p->mempool, (void **) pkts, n_pkts) != 0)
return 0;
+ RTE_PORT_SOURCE_STATS_PKTS_IN_ADD(p, n_pkts);
+
return n_pkts;
}
+static int
+rte_port_source_stats_read(void *port,
+ struct rte_port_in_stats *stats, int clear)
+{
+ struct rte_port_source *p =
+ (struct rte_port_source *) port;
+
+ if (stats != NULL)
+ memcpy(stats, &p->stats, sizeof(p->stats));
+
+ if (clear)
+ memset(&p->stats, 0, sizeof(p->stats));
+
+ return 0;
+}
+
/*
* Port SINK
*/
@@ -147,6 +181,7 @@ struct rte_port_in_ops rte_port_source_ops = {
.f_create = rte_port_source_create,
.f_free = rte_port_source_free,
.f_rx = rte_port_source_rx,
+ .f_stats = rte_port_source_stats_read,
};
struct rte_port_out_ops rte_port_sink_ops = {