From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mail-pd0-f176.google.com (mail-pd0-f176.google.com [209.85.192.176]) by dpdk.org (Postfix) with ESMTP id 14744C990 for ; Wed, 29 Apr 2015 19:04:44 +0200 (CEST) Received: by pdbqa5 with SMTP id qa5so33686922pdb.1 for ; Wed, 29 Apr 2015 10:04:43 -0700 (PDT) X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20130820; h=x-gm-message-state:from:to:cc:subject:date:message-id:in-reply-to :references; bh=voYTjQl84rD4G+mVuuAR5xPGw/BkY2BoMaLNUd/uGVw=; b=HOBx/kdpwpmuqU0T/VQsAREty5MTF+8T63+i+jAnn2Cl2YZeHUtcGLvL8ouxgeCpyp ftfRbWXMI6EFU8NyMPPQ5QlINj+eQTpjgNgn4NvPN3AmQK6EiMNqO/X6tgGgkkc05H8W Q5tjCKBymtIuu0yWSGEtiQLvyTkBe3e5zoFLKe0t2e2Xxn21hijKm3+hQAHI+kVOE8DQ 6T9K05lAjzjcZWZxfYky/LcN+/HUC80dk2f/5JZsGc58HZrSrh+qvoSYDeNSt/jgiJWu h7w0UY3xncOJ+A9BFc5zuzOgwwpwJcbF1bAX2TzztT9pWTkZKxNcDEitvhcpY9Flg/QY e98A== X-Gm-Message-State: ALoCoQns6QAcCCEEk1a4YaULfsBBfmzHJ0bN38wqZl4uD1CzDF4Rif9kbNwUB3+bxa6wjPEb3gtL X-Received: by 10.70.123.168 with SMTP id mb8mr130993pdb.100.1430327083271; Wed, 29 Apr 2015 10:04:43 -0700 (PDT) Received: from urahara.home.lan (static-50-53-82-155.bvtn.or.frontiernet.net. [50.53.82.155]) by mx.google.com with ESMTPSA id i9sm25995113pdj.27.2015.04.29.10.04.42 (version=TLSv1.2 cipher=ECDHE-RSA-AES128-SHA bits=128/128); Wed, 29 Apr 2015 10:04:42 -0700 (PDT) From: Stephen Hemminger To: cristian.dumitrescu@intel.com Date: Wed, 29 Apr 2015 10:04:38 -0700 Message-Id: <1430327080-12642-5-git-send-email-stephen@networkplumber.org> X-Mailer: git-send-email 2.1.4 In-Reply-To: <1430327080-12642-1-git-send-email-stephen@networkplumber.org> References: <1430327080-12642-1-git-send-email-stephen@networkplumber.org> Cc: dev@dpdk.org Subject: [dpdk-dev] [PATCH 4/6] rte_sched: allow reading without clearing X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: patches and discussions about DPDK List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , X-List-Received-Date: Wed, 29 Apr 2015 17:04:44 -0000 The rte_sched statistics API should allow reading statistics without clearing. Make auto-clear optional. Signed-off-by: Stephen Hemminger --- app/test/test_sched.c | 4 ++-- examples/qos_sched/stats.c | 16 +++++++++++----- lib/librte_sched/rte_sched.c | 44 ++++++++++++++++++++++---------------------- lib/librte_sched/rte_sched.h | 18 ++++++++++-------- 4 files changed, 45 insertions(+), 37 deletions(-) diff --git a/app/test/test_sched.c b/app/test/test_sched.c index c7239f8..1526ad7 100644 --- a/app/test/test_sched.c +++ b/app/test/test_sched.c @@ -198,13 +198,13 @@ test_sched(void) struct rte_sched_subport_stats subport_stats; uint32_t tc_ov; - rte_sched_subport_read_stats(port, SUBPORT, &subport_stats, &tc_ov); + rte_sched_subport_read_stats(port, SUBPORT, &subport_stats, &tc_ov, 1); #if 0 TEST_ASSERT_EQUAL(subport_stats.n_pkts_tc[TC-1], 10, "Wrong subport stats\n"); #endif struct rte_sched_queue_stats queue_stats; uint16_t qlen; - rte_sched_queue_read_stats(port, QUEUE, &queue_stats, &qlen); + rte_sched_queue_read_stats(port, QUEUE, &queue_stats, &qlen, 1); #if 0 TEST_ASSERT_EQUAL(queue_stats.n_pkts, 10, "Wrong queue stats\n"); #endif diff --git a/examples/qos_sched/stats.c b/examples/qos_sched/stats.c index b4db7b5..88caa54 100644 --- a/examples/qos_sched/stats.c +++ b/examples/qos_sched/stats.c @@ -61,7 +61,7 @@ qavg_q(uint8_t port_id, uint32_t subport_id, uint32_t pipe_id, uint8_t tc, uint8 average = 0; for (count = 0; count < qavg_ntimes; count++) { - rte_sched_queue_read_stats(port, queue_id, &stats, &qlen); + rte_sched_queue_read_stats(port, queue_id, &stats, &qlen, 1); average += qlen; usleep(qavg_period); } @@ -99,7 +99,9 @@ qavg_tcpipe(uint8_t port_id, uint32_t subport_id, uint32_t pipe_id, uint8_t tc) for (count = 0; count < qavg_ntimes; count++) { part_average = 0; for (i = 0; i < RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS; i++) { - rte_sched_queue_read_stats(port, queue_id + (tc * RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS + i), &stats, &qlen); + rte_sched_queue_read_stats(port, + queue_id + (tc * RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS + i), + &stats, &qlen, 1); part_average += qlen; } average += part_average / RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS; @@ -138,7 +140,8 @@ qavg_pipe(uint8_t port_id, uint32_t subport_id, uint32_t pipe_id) for (count = 0; count < qavg_ntimes; count++) { part_average = 0; for (i = 0; i < RTE_SCHED_TRAFFIC_CLASSES_PER_PIPE * RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS; i++) { - rte_sched_queue_read_stats(port, queue_id + i, &stats, &qlen); + rte_sched_queue_read_stats(port, queue_id + i, + &stats, &qlen, 1); part_average += qlen; } average += part_average / (RTE_SCHED_TRAFFIC_CLASSES_PER_PIPE * RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS); @@ -178,7 +181,9 @@ qavg_tcsubport(uint8_t port_id, uint32_t subport_id, uint8_t tc) queue_id = RTE_SCHED_TRAFFIC_CLASSES_PER_PIPE * RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS * (subport_id * port_params.n_pipes_per_subport + i); for (j = 0; j < RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS; j++) { - rte_sched_queue_read_stats(port, queue_id + (tc * RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS + j), &stats, &qlen); + rte_sched_queue_read_stats(port, + queue_id + (tc * RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS + j), + &stats, &qlen, 1); part_average += qlen; } } @@ -220,7 +225,8 @@ qavg_subport(uint8_t port_id, uint32_t subport_id) queue_id = RTE_SCHED_TRAFFIC_CLASSES_PER_PIPE * RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS * (subport_id * port_params.n_pipes_per_subport + i); for (j = 0; j < RTE_SCHED_TRAFFIC_CLASSES_PER_PIPE * RTE_SCHED_QUEUES_PER_TRAFFIC_CLASS; j++) { - rte_sched_queue_read_stats(port, queue_id + j, &stats, &qlen); + rte_sched_queue_read_stats(port, queue_id + j, + &stats, &qlen, 1); part_average += qlen; } } diff --git a/lib/librte_sched/rte_sched.c b/lib/librte_sched/rte_sched.c index c044c09..74b3111 100644 --- a/lib/librte_sched/rte_sched.c +++ b/lib/librte_sched/rte_sched.c @@ -909,56 +909,56 @@ rte_sched_pipe_config(struct rte_sched_port *port, int rte_sched_subport_read_stats(struct rte_sched_port *port, - uint32_t subport_id, - struct rte_sched_subport_stats *stats, - uint32_t *tc_ov) + uint32_t subport_id, + struct rte_sched_subport_stats *stats, + uint32_t *tc_ov, int clear) { struct rte_sched_subport *s; /* Check user parameters */ - if ((port == NULL) || - (subport_id >= port->n_subports_per_port) || - (stats == NULL) || - (tc_ov == NULL)) { + if (port == NULL || subport_id >= port->n_subports_per_port) return -1; - } + s = port->subport + subport_id; /* Copy subport stats and clear */ - memcpy(stats, &s->stats, sizeof(struct rte_sched_subport_stats)); - memset(&s->stats, 0, sizeof(struct rte_sched_subport_stats)); + if (stats) + *stats = s->stats; + if (clear) + memset(&s->stats, 0, sizeof(struct rte_sched_subport_stats)); /* Subport TC ovesubscription status */ - *tc_ov = s->tc_ov; + if (tc_ov) + *tc_ov = s->tc_ov; return 0; } int rte_sched_queue_read_stats(struct rte_sched_port *port, - uint32_t queue_id, - struct rte_sched_queue_stats *stats, - uint16_t *qlen) + uint32_t queue_id, + struct rte_sched_queue_stats *stats, + uint16_t *qlen, int clear) { struct rte_sched_queue *q; struct rte_sched_queue_extra *qe; /* Check user parameters */ - if ((port == NULL) || - (queue_id >= rte_sched_port_queues_per_port(port)) || - (stats == NULL) || - (qlen == NULL)) { + if (port == NULL || queue_id >= rte_sched_port_queues_per_port(port)) return -1; - } + q = port->queue + queue_id; qe = port->queue_extra + queue_id; /* Copy queue stats and clear */ - memcpy(stats, &qe->stats, sizeof(struct rte_sched_queue_stats)); - memset(&qe->stats, 0, sizeof(struct rte_sched_queue_stats)); + if (stats) + *stats = qe->stats; + if (clear) + memset(&qe->stats, 0, sizeof(struct rte_sched_queue_stats)); /* Queue length */ - *qlen = q->qw - q->qr; + if (qlen) + *qlen = q->qw - q->qr; return 0; } diff --git a/lib/librte_sched/rte_sched.h b/lib/librte_sched/rte_sched.h index 3fd1fe1..dff7f85 100644 --- a/lib/librte_sched/rte_sched.h +++ b/lib/librte_sched/rte_sched.h @@ -308,14 +308,15 @@ rte_sched_port_get_memory_footprint(struct rte_sched_port_params *params); * @param tc_ov * Pointer to pre-allocated 4-entry array where the oversubscription status for * each of the 4 subport traffic classes should be stored. + * @parm clear + * Reset statistics after read * @return * 0 upon success, error code otherwise */ int -rte_sched_subport_read_stats(struct rte_sched_port *port, - uint32_t subport_id, - struct rte_sched_subport_stats *stats, - uint32_t *tc_ov); +rte_sched_subport_read_stats(struct rte_sched_port *port, uint32_t subport_id, + struct rte_sched_subport_stats *stats, + uint32_t *tc_ov, int clear); /** * Hierarchical scheduler queue statistics read @@ -329,14 +330,15 @@ rte_sched_subport_read_stats(struct rte_sched_port *port, * counters should be stored * @param qlen * Pointer to pre-allocated variable where the current queue length should be stored. + * @parm clear + * Reset statistics after read * @return * 0 upon success, error code otherwise */ int -rte_sched_queue_read_stats(struct rte_sched_port *port, - uint32_t queue_id, - struct rte_sched_queue_stats *stats, - uint16_t *qlen); +rte_sched_queue_read_stats(struct rte_sched_port *port, uint32_t queue_id, + struct rte_sched_queue_stats *stats, + uint16_t *qlen, int clear); /* * Run-time -- 2.1.4