From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from mails.dpdk.org (mails.dpdk.org [217.70.189.124]) by inbox.dpdk.org (Postfix) with ESMTP id 2E2E545B01; Tue, 15 Oct 2024 15:01:49 +0200 (CEST) Received: from mails.dpdk.org (localhost [127.0.0.1]) by mails.dpdk.org (Postfix) with ESMTP id 9A956402EF; Tue, 15 Oct 2024 15:01:37 +0200 (CEST) Received: from forward500a.mail.yandex.net (forward500a.mail.yandex.net [178.154.239.80]) by mails.dpdk.org (Postfix) with ESMTP id 64154402E3 for ; Tue, 15 Oct 2024 15:01:36 +0200 (CEST) Received: from mail-nwsmtp-smtp-production-main-84.iva.yp-c.yandex.net (mail-nwsmtp-smtp-production-main-84.iva.yp-c.yandex.net [IPv6:2a02:6b8:c0c:9519:0:640:299f:0]) by forward500a.mail.yandex.net (Yandex) with ESMTPS id 955C4617F5; Tue, 15 Oct 2024 16:01:35 +0300 (MSK) Received: by mail-nwsmtp-smtp-production-main-84.iva.yp-c.yandex.net (smtp/Yandex) with ESMTPSA id C1LmJKRThCg0-ufJvUhbf; Tue, 15 Oct 2024 16:01:34 +0300 X-Yandex-Fwd: 1 DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=yandex.ru; s=mail; t=1728997294; bh=KFuLOFS43ZY03N3PodaeXfUJRqq0AmpoVGaGbLFv02o=; h=Message-Id:Date:In-Reply-To:Cc:Subject:References:To:From; b=nY/xRuTp5KBfETBlSbsKpw9p+UsFGl1N48mLvpr43RtCMoRInmS5oCWRFoMKPiGpM eg9hj/zwp/xhYZvuAl/UqVQKrefIQIS0pqeicnocXRgNXnWAqxhLDjiX2xw4rDl0qO EEl6fk3y6/HGJI+Szuxn/iaN7XcgC7MUPLkPSEt4= Authentication-Results: mail-nwsmtp-smtp-production-main-84.iva.yp-c.yandex.net; dkim=pass header.i=@yandex.ru From: Konstantin Ananyev To: dev@dpdk.org Cc: honnappa.nagarahalli@arm.com, jerinj@marvell.com, hemant.agrawal@nxp.com, bruce.richardson@intel.com, drc@linux.vnet.ibm.com, ruifeng.wang@arm.com, mb@smartsharesystems.com, eimear.morrissey@huawei.com, stephen@networkplumber.org Subject: [PATCH v5 3/6] ring: make dump function more verbose Date: Tue, 15 Oct 2024 14:01:08 +0100 Message-Id: <20241015130111.826-4-konstantin.v.ananyev@yandex.ru> X-Mailer: git-send-email 2.25.1 In-Reply-To: <20241015130111.826-1-konstantin.v.ananyev@yandex.ru> References: <20240917120946.1212-1-konstantin.v.ananyev@yandex.ru> <20241015130111.826-1-konstantin.v.ananyev@yandex.ru> MIME-Version: 1.0 Content-Transfer-Encoding: 8bit X-Yandex-Filter: 1 X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.29 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org From: Eimear Morrissey The current rte_ring_dump function uses the generic rte_ring_headtail structure to access head/tail positions. This is incorrect for the RTS case where the head is stored in a different offset in the union of structs. Switching to a separate function for each sync type allows to dump correct head/tail values and extra metadata. Signed-off-by: Eimear Morrissey --- .mailmap | 1 + app/test/test_ring_stress_impl.h | 1 + lib/ring/rte_ring.c | 87 ++++++++++++++++++++++++++++++-- lib/ring/rte_ring.h | 15 ++++++ lib/ring/version.map | 7 +++ 5 files changed, 107 insertions(+), 4 deletions(-) diff --git a/.mailmap b/.mailmap index f51b1dda5d..2b8d0e4b4f 100644 --- a/.mailmap +++ b/.mailmap @@ -383,6 +383,7 @@ Eduard Serra Edward Makarov Edwin Brossette Eelco Chaudron +Eimear Morrissey Elad Nachman Elad Persiko Elena Agostini diff --git a/app/test/test_ring_stress_impl.h b/app/test/test_ring_stress_impl.h index 8b0bfb11fe..8449cb4b15 100644 --- a/app/test/test_ring_stress_impl.h +++ b/app/test/test_ring_stress_impl.h @@ -380,6 +380,7 @@ test_mt1(int (*test)(void *)) } lcore_stat_dump(stdout, UINT32_MAX, &arg[mc].stats); + rte_ring_dump(stdout, r); mt1_fini(r, data); return rc; } diff --git a/lib/ring/rte_ring.c b/lib/ring/rte_ring.c index aebb6d6728..261f2a06db 100644 --- a/lib/ring/rte_ring.c +++ b/lib/ring/rte_ring.c @@ -364,20 +364,99 @@ rte_ring_free(struct rte_ring *r) rte_free(te); } +static const char * +ring_get_sync_type(const enum rte_ring_sync_type st) +{ + switch (st) { + case RTE_RING_SYNC_ST: + return "single thread"; + case RTE_RING_SYNC_MT: + return "multi thread"; + case RTE_RING_SYNC_MT_RTS: + return "multi thread - RTS"; + case RTE_RING_SYNC_MT_HTS: + return "multi thread - HTS"; + default: + return "unknown"; + } +} + +static void +ring_dump_ht_headtail(FILE *f, const char *prefix, + const struct rte_ring_headtail *ht) +{ + fprintf(f, "%ssync_type=%s\n", prefix, + ring_get_sync_type(ht->sync_type)); + fprintf(f, "%shead=%"PRIu32"\n", prefix, ht->head); + fprintf(f, "%stail=%"PRIu32"\n", prefix, ht->tail); +} + +static void +ring_dump_rts_headtail(FILE *f, const char *prefix, + const struct rte_ring_rts_headtail *rts) +{ + fprintf(f, "%ssync_type=%s\n", prefix, + ring_get_sync_type(rts->sync_type)); + fprintf(f, "%shead.pos=%"PRIu32"\n", prefix, rts->head.val.pos); + fprintf(f, "%shead.cnt=%"PRIu32"\n", prefix, rts->head.val.cnt); + fprintf(f, "%stail.pos=%"PRIu32"\n", prefix, rts->tail.val.pos); + fprintf(f, "%stail.cnt=%"PRIu32"\n", prefix, rts->tail.val.cnt); + fprintf(f, "%shtd_max=%"PRIu32"\n", prefix, rts->htd_max); +} + +static void +ring_dump_hts_headtail(FILE *f, const char *prefix, + const struct rte_ring_hts_headtail *hts) +{ + fprintf(f, "%ssync_type=%s\n", prefix, + ring_get_sync_type(hts->sync_type)); + fprintf(f, "%shead=%"PRIu32"\n", prefix, hts->ht.pos.head); + fprintf(f, "%stail=%"PRIu32"\n", prefix, hts->ht.pos.tail); +} + +void +rte_ring_headtail_dump(FILE *f, const char *prefix, + const struct rte_ring_headtail *r) +{ + if (f == NULL || r == NULL) + return; + + prefix = (prefix != NULL) ? prefix : ""; + + switch (r->sync_type) { + case RTE_RING_SYNC_ST: + case RTE_RING_SYNC_MT: + ring_dump_ht_headtail(f, prefix, r); + break; + case RTE_RING_SYNC_MT_RTS: + ring_dump_rts_headtail(f, prefix, + (const struct rte_ring_rts_headtail *)r); + break; + case RTE_RING_SYNC_MT_HTS: + ring_dump_hts_headtail(f, prefix, + (const struct rte_ring_hts_headtail *)r); + break; + default: + RING_LOG(ERR, "Invalid ring sync type detected"); + } +} + /* dump the status of the ring on the console */ void rte_ring_dump(FILE *f, const struct rte_ring *r) { + if (f == NULL || r == NULL) + return; + fprintf(f, "ring <%s>@%p\n", r->name, r); fprintf(f, " flags=%x\n", r->flags); fprintf(f, " size=%"PRIu32"\n", r->size); fprintf(f, " capacity=%"PRIu32"\n", r->capacity); - fprintf(f, " ct=%"PRIu32"\n", r->cons.tail); - fprintf(f, " ch=%"PRIu32"\n", r->cons.head); - fprintf(f, " pt=%"PRIu32"\n", r->prod.tail); - fprintf(f, " ph=%"PRIu32"\n", r->prod.head); fprintf(f, " used=%u\n", rte_ring_count(r)); fprintf(f, " avail=%u\n", rte_ring_free_count(r)); + + rte_ring_headtail_dump(f, " cons.", &(r->cons)); + rte_ring_headtail_dump(f, " prod.", &(r->prod)); } /* dump the status of all rings on the console */ diff --git a/lib/ring/rte_ring.h b/lib/ring/rte_ring.h index 11ca69c73d..33ac5e4423 100644 --- a/lib/ring/rte_ring.h +++ b/lib/ring/rte_ring.h @@ -204,6 +204,21 @@ void rte_ring_free(struct rte_ring *r); */ void rte_ring_dump(FILE *f, const struct rte_ring *r); +/** + * Dump the status of a headtail to a file. + * + * @param f + * A pointer to a file for output + * @param prefix + * A string to prefix each output line with + * @param r + * A pointer to a ring headtail structure. + */ +__rte_experimental +void +rte_ring_headtail_dump(FILE *f, const char *prefix, + const struct rte_ring_headtail *r); + /** * Enqueue several objects on the ring (multi-producers safe). * diff --git a/lib/ring/version.map b/lib/ring/version.map index 8da094a69a..61f7464f5a 100644 --- a/lib/ring/version.map +++ b/lib/ring/version.map @@ -14,3 +14,10 @@ DPDK_25 { local: *; }; + +EXPERIMENTAL { + global: + + # added in 24.11 + rte_ring_headtail_dump; +}; -- 2.35.3