Patch Detail
get:
Show a patch.
patch:
Update a patch.
put:
Update a patch.
GET /api/patches/66947/?format=api
{ "id": 66947, "url": "http://patches.dpdk.org/api/patches/66947/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/patch/20200319171907.60891-9-ciara.power@intel.com/", "project": { "id": 1, "url": "http://patches.dpdk.org/api/projects/1/?format=api", "name": "DPDK", "link_name": "dpdk", "list_id": "dev.dpdk.org", "list_email": "dev@dpdk.org", "web_url": "http://core.dpdk.org", "scm_url": "git://dpdk.org/dpdk", "webscm_url": "http://git.dpdk.org/dpdk", "list_archive_url": "https://inbox.dpdk.org/dev", "list_archive_url_format": "https://inbox.dpdk.org/dev/{}", "commit_url_format": "" }, "msgid": "<20200319171907.60891-9-ciara.power@intel.com>", "list_archive_url": "https://inbox.dpdk.org/dev/20200319171907.60891-9-ciara.power@intel.com", "date": "2020-03-19T17:19:03", "name": "[08/12] examples/l3fwd-power: enable use of new telemetry", "commit_ref": null, "pull_url": null, "state": "superseded", "archived": true, "hash": "3476c09493898f730a88af99661e2fdb7fd19a12", "submitter": { "id": 978, "url": "http://patches.dpdk.org/api/people/978/?format=api", "name": "Power, Ciara", "email": "ciara.power@intel.com" }, "delegate": { "id": 24651, "url": "http://patches.dpdk.org/api/users/24651/?format=api", "username": "dmarchand", "first_name": "David", "last_name": "Marchand", "email": "david.marchand@redhat.com" }, "mbox": "http://patches.dpdk.org/project/dpdk/patch/20200319171907.60891-9-ciara.power@intel.com/mbox/", "series": [ { "id": 8987, "url": "http://patches.dpdk.org/api/series/8987/?format=api", "web_url": "http://patches.dpdk.org/project/dpdk/list/?series=8987", "date": "2020-03-19T17:18:55", "name": "update and simplify telemetry library.", "version": 1, "mbox": "http://patches.dpdk.org/series/8987/mbox/" } ], "comments": "http://patches.dpdk.org/api/patches/66947/comments/", "check": "fail", "checks": "http://patches.dpdk.org/api/patches/66947/checks/", "tags": {}, "related": [], "headers": { "Return-Path": "<dev-bounces@dpdk.org>", "X-Original-To": "patchwork@inbox.dpdk.org", "Delivered-To": "patchwork@inbox.dpdk.org", "Received": [ "from dpdk.org (dpdk.org [92.243.14.124])\n\tby inbox.dpdk.org (Postfix) with ESMTP id 075E8A0583;\n\tThu, 19 Mar 2020 18:36:52 +0100 (CET)", "from [92.243.14.124] (localhost [127.0.0.1])\n\tby dpdk.org (Postfix) with ESMTP id 475B21C0C1;\n\tThu, 19 Mar 2020 18:35:10 +0100 (CET)", "from mga02.intel.com (mga02.intel.com [134.134.136.20])\n by dpdk.org (Postfix) with ESMTP id 6203D1C0C1\n for <dev@dpdk.org>; Thu, 19 Mar 2020 18:35:08 +0100 (CET)", "from orsmga004.jf.intel.com ([10.7.209.38])\n by orsmga101.jf.intel.com with ESMTP/TLS/ECDHE-RSA-AES256-GCM-SHA384;\n 19 Mar 2020 10:35:08 -0700", "from silpixa00399953.ir.intel.com (HELO\n silpixa00399953.ger.corp.intel.com) ([10.237.222.53])\n by orsmga004.jf.intel.com with ESMTP; 19 Mar 2020 10:35:06 -0700" ], "IronPort-SDR": [ "\n jCi2ih9X6i+l40haHEeLv3jdckrmFJRu/pf7JiM0+WUBd3OHObNsQmXsqfOPeLKm/etdYc65dG\n NvGjalNwLPvQ==", "\n sSDsoWGbl42qJbfk+HHTIQ3RrAtE6NvZXxP/ZyH/fonxM8eXu4XcRQPckCfYWdYTr4Fv1RszLj\n iw5muQNkpYTQ==" ], "X-Amp-Result": "SKIPPED(no attachment in message)", "X-Amp-File-Uploaded": "False", "X-ExtLoop1": "1", "X-IronPort-AV": "E=Sophos;i=\"5.70,572,1574150400\"; d=\"scan'208\";a=\"391872701\"", "From": "Ciara Power <ciara.power@intel.com>", "To": "kevin.laatz@intel.com", "Cc": "dev@dpdk.org, reshma.pattan@intel.com,\n Ciara Power <ciara.power@intel.com>,\n Bruce Richardson <bruce.richardson@intel.com>", "Date": "Thu, 19 Mar 2020 17:19:03 +0000", "Message-Id": "<20200319171907.60891-9-ciara.power@intel.com>", "X-Mailer": "git-send-email 2.17.1", "In-Reply-To": "<20200319171907.60891-1-ciara.power@intel.com>", "References": "<20200319171907.60891-1-ciara.power@intel.com>", "Subject": "[dpdk-dev] [PATCH 08/12] examples/l3fwd-power: enable use of new\n\ttelemetry", "X-BeenThere": "dev@dpdk.org", "X-Mailman-Version": "2.1.15", "Precedence": "list", "List-Id": "DPDK patches and discussions <dev.dpdk.org>", "List-Unsubscribe": "<https://mails.dpdk.org/options/dev>,\n <mailto:dev-request@dpdk.org?subject=unsubscribe>", "List-Archive": "<http://mails.dpdk.org/archives/dev/>", "List-Post": "<mailto:dev@dpdk.org>", "List-Help": "<mailto:dev-request@dpdk.org?subject=help>", "List-Subscribe": "<https://mails.dpdk.org/listinfo/dev>,\n <mailto:dev-request@dpdk.org?subject=subscribe>", "Errors-To": "dev-bounces@dpdk.org", "Sender": "\"dev\" <dev-bounces@dpdk.org>" }, "content": "The l3fwd-power example app now registers a stats command with\ntelemetry, and provides a callback function to handle formatting the\npower stats.\n\nAn example usage is shown below:\n\nConnecting to /var/run/dpdk/rte/dpdk_telemetry.23863\n--> /\n{\"/\": [\"/\", \"/ethdev/list\", \"/ethdev/stats\", \"/l3fwd-power/stats\"]}\n--> /l3fwd-power/stats\n{\"/l3fwd-power/stats\": {\"empty_poll\": 281625000, \"full_poll\": 0,\n \"busy_percent\": 0}}\n\nThe existing stats tracking done by the app using the metrics\nlibrary is unaffected. This will still be used to ensure backward\ncompatibility.\n\nSigned-off-by: Bruce Richardson <bruce.richardson@intel.com>\nSigned-off-by: Ciara Power <ciara.power@intel.com>\n---\n examples/l3fwd-power/Makefile | 4 +++\n examples/l3fwd-power/main.c | 62 ++++++++++++++++++++++++--------\n examples/l3fwd-power/meson.build | 4 +++\n 3 files changed, 56 insertions(+), 14 deletions(-)", "diff": "diff --git a/examples/l3fwd-power/Makefile b/examples/l3fwd-power/Makefile\nindex 729d49639..531a1d81c 100644\n--- a/examples/l3fwd-power/Makefile\n+++ b/examples/l3fwd-power/Makefile\n@@ -68,6 +68,10 @@ ifeq ($(CONFIG_RTE_TOOLCHAIN_GCC),y)\n CFLAGS_main.o += -Wno-return-type\n endif\n \n+ifeq ($(CONFIG_RTE_LIBRTE_TELEMETRY),y)\n+LDLIBS += -lrte_telemetry\n+endif\n+\n include $(RTE_SDK)/mk/rte.extapp.mk\n endif\n endif\ndiff --git a/examples/l3fwd-power/main.c b/examples/l3fwd-power/main.c\nindex c7fe0ec03..de52a47b6 100644\n--- a/examples/l3fwd-power/main.c\n+++ b/examples/l3fwd-power/main.c\n@@ -46,6 +46,9 @@\n #include <rte_spinlock.h>\n #include <rte_power_empty_poll.h>\n #include <rte_metrics.h>\n+#ifdef RTE_LIBRTE_TELEMETRY\n+#include <rte_telemetry.h>\n+#endif\n \n #include \"perf_core.h\"\n #include \"main.h\"\n@@ -131,7 +134,7 @@\n #define EMPTY_POLL_MED_THRESHOLD 350000UL\n #define EMPTY_POLL_HGH_THRESHOLD 580000UL\n \n-\n+#define NUM_TELSTATS RTE_DIM(telstats_strings)\n \n static uint16_t nb_rxd = RTE_TEST_RX_DESC_DEFAULT;\n static uint16_t nb_txd = RTE_TEST_TX_DESC_DEFAULT;\n@@ -2079,14 +2082,11 @@ init_power_library(void)\n \treturn ret;\n }\n static void\n-update_telemetry(__attribute__((unused)) struct rte_timer *tim,\n-\t\t__attribute__((unused)) void *arg)\n+get_current_stat_values(uint64_t *values)\n {\n \tunsigned int lcore_id = rte_lcore_id();\n \tstruct lcore_conf *qconf;\n \tuint64_t app_eps = 0, app_fps = 0, app_br = 0;\n-\tuint64_t values[3] = {0};\n-\tint ret;\n \tuint64_t count = 0;\n \n \tRTE_LCORE_FOREACH_SLAVE(lcore_id) {\n@@ -2105,17 +2105,48 @@ update_telemetry(__attribute__((unused)) struct rte_timer *tim,\n \t\tvalues[0] = app_eps/count;\n \t\tvalues[1] = app_fps/count;\n \t\tvalues[2] = app_br/count;\n-\t} else {\n-\t\tvalues[0] = 0;\n-\t\tvalues[1] = 0;\n-\t\tvalues[2] = 0;\n-\t}\n+\t} else\n+\t\tmemset(values, 0, sizeof(uint64_t) * NUM_TELSTATS);\n+\n+}\n \n+static void\n+update_telemetry(__attribute__((unused)) struct rte_timer *tim,\n+\t\t__attribute__((unused)) void *arg)\n+{\n+\tint ret;\n+\tuint64_t values[3] = {0};\n+\n+\tget_current_stat_values(values);\n \tret = rte_metrics_update_values(RTE_METRICS_GLOBAL, telstats_index,\n \t\t\t\t\tvalues, RTE_DIM(values));\n \tif (ret < 0)\n \t\tRTE_LOG(WARNING, POWER, \"failed to update metrcis\\n\");\n }\n+#ifdef RTE_LIBRTE_TELEMETRY\n+static int\n+handle_app_stats(const char *cmd __rte_unused,\n+\t\tconst char *params __rte_unused,\n+\t\tchar *buffer, int buf_len)\n+{\n+\tint ret, used = 0;\n+\tuint64_t values[3] = {0};\n+\tuint32_t i;\n+\n+\tused = strlcpy(buffer, \"{\", buf_len);\n+\tget_current_stat_values(values);\n+\tfor (i = 0; i < NUM_TELSTATS; i++) {\n+\t\tret = snprintf(buffer + used, buf_len - used, \"\\\"%s\\\":%\"PRIu64\",\",\n+\t\t\t\ttelstats_strings[i].name, values[i]);\n+\t\tif (ret + used >= buf_len)\n+\t\t\tbreak;\n+\t\tused += ret;\n+\t}\n+\n+\tbuffer[used - 1] = '}';\n+\treturn used;\n+}\n+#endif\n static void\n telemetry_setup_timer(void)\n {\n@@ -2203,8 +2234,7 @@ main(int argc, char **argv)\n \tuint32_t dev_rxq_num, dev_txq_num;\n \tuint8_t nb_rx_queue, queue, socketid;\n \tuint16_t portid;\n-\tuint8_t num_telstats = RTE_DIM(telstats_strings);\n-\tconst char *ptr_strings[num_telstats];\n+\tconst char *ptr_strings[NUM_TELSTATS];\n \n \t/* catch SIGINT and restore cpufreq governor to ondemand */\n \tsignal(SIGINT, signal_exit_now);\n@@ -2503,10 +2533,10 @@ main(int argc, char **argv)\n \t\t/* Init metrics library */\n \t\trte_metrics_init(rte_socket_id());\n \t\t/** Register stats with metrics library */\n-\t\tfor (i = 0; i < num_telstats; i++)\n+\t\tfor (i = 0; i < NUM_TELSTATS; i++)\n \t\t\tptr_strings[i] = telstats_strings[i].name;\n \n-\t\tret = rte_metrics_reg_names(ptr_strings, num_telstats);\n+\t\tret = rte_metrics_reg_names(ptr_strings, NUM_TELSTATS);\n \t\tif (ret >= 0)\n \t\t\ttelstats_index = ret;\n \t\telse\n@@ -2516,6 +2546,10 @@ main(int argc, char **argv)\n \t\t\trte_spinlock_init(&stats[lcore_id].telemetry_lock);\n \t\t}\n \t\trte_timer_init(&telemetry_timer);\n+#ifdef RTE_LIBRTE_TELEMETRY\n+\t\trte_telemetry_register_cmd(\"/l3fwd-power/stats\",\n+\t\t\t\thandle_app_stats);\n+#endif\n \t\trte_eal_mp_remote_launch(main_telemetry_loop, NULL,\n \t\t\t\t\t\tSKIP_MASTER);\n \t}\ndiff --git a/examples/l3fwd-power/meson.build b/examples/l3fwd-power/meson.build\nindex d5a3d4bb2..e7c6be647 100644\n--- a/examples/l3fwd-power/meson.build\n+++ b/examples/l3fwd-power/meson.build\n@@ -16,3 +16,7 @@ deps += ['power', 'timer', 'lpm', 'hash', 'metrics']\n sources = files(\n \t'main.c', 'perf_core.c'\n )\n+\n+if dpdk_conf.has('RTE_LIBRTE_TELEMETRY')\n+\tdeps += ['telemetry']\n+endif\n", "prefixes": [ "08/12" ] }