From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Received: from dpdk.org (dpdk.org [92.243.14.124]) by inbox.dpdk.org (Postfix) with ESMTP id 38DD2A04B1; Sat, 10 Oct 2020 18:07:43 +0200 (CEST) Received: from [92.243.14.124] (localhost [127.0.0.1]) by dpdk.org (Postfix) with ESMTP id AA4D21D927; Sat, 10 Oct 2020 18:05:46 +0200 (CEST) Received: from mailout2.w1.samsung.com (mailout2.w1.samsung.com [210.118.77.12]) by dpdk.org (Postfix) with ESMTP id D33601D921 for ; Sat, 10 Oct 2020 18:05:42 +0200 (CEST) Received: from eucas1p1.samsung.com (unknown [182.198.249.206]) by mailout2.w1.samsung.com (KnoxPortal) with ESMTP id 20201010160532euoutp02515c29b9ed173ef60d88a2c9588e38d1~8rSLdotYh2850728507euoutp02a for ; Sat, 10 Oct 2020 16:05:32 +0000 (GMT) DKIM-Filter: OpenDKIM Filter v2.11.0 mailout2.w1.samsung.com 20201010160532euoutp02515c29b9ed173ef60d88a2c9588e38d1~8rSLdotYh2850728507euoutp02a DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=samsung.com; s=mail20170921; t=1602345932; bh=LemR1YjnE+c23RXwEQzxMBn4x6DVQHDmQWboTCBU/MI=; h=From:To:Cc:Subject:Date:In-Reply-To:References:From; b=tO/HaCrMQIuMloPaWnpJgqDngHnbt3Pp0ZH8l6nhmwfBcrrnRmcDkrGJpGAe9r21C 4TG+1e5wM55IDlHM/7U4l2vhiavtb4IQ7DvVxoz91O7Uwd8oyA62j3gLe7wmuREUFU uZYnEVqs3lsafyayxE42N+OJumC5mSqu5GyzNbkE= Received: from eusmges2new.samsung.com (unknown [203.254.199.244]) by eucas1p2.samsung.com (KnoxPortal) with ESMTP id 20201010160527eucas1p2f9e48b635abf1537e9ed0ca181f23bc6~8rSGdTjFp1925919259eucas1p2k; Sat, 10 Oct 2020 16:05:27 +0000 (GMT) Received: from eucas1p2.samsung.com ( [182.198.249.207]) by eusmges2new.samsung.com (EUCPMTA) with SMTP id D6.58.05997.7CBD18F5; Sat, 10 Oct 2020 17:05:27 +0100 (BST) Received: from eusmtrp1.samsung.com (unknown [182.198.249.138]) by eucas1p2.samsung.com (KnoxPortal) with ESMTPA id 20201010160527eucas1p2f55cb0fc45bf3647234cdfa251e542fc~8rSGMsFuj0179501795eucas1p2s; Sat, 10 Oct 2020 16:05:27 +0000 (GMT) Received: from eusmgms1.samsung.com (unknown [182.198.249.179]) by eusmtrp1.samsung.com (KnoxPortal) with ESMTP id 20201010160527eusmtrp1832ee305a2cd8ca583181821339d4de0~8rSGMFNMA2920229202eusmtrp1v; Sat, 10 Oct 2020 16:05:27 +0000 (GMT) X-AuditID: cbfec7f4-677ff7000000176d-69-5f81dbc7372e Received: from eusmtip1.samsung.com ( [203.254.199.221]) by eusmgms1.samsung.com (EUCPMTA) with SMTP id 94.5A.06314.6CBD18F5; Sat, 10 Oct 2020 17:05:27 +0100 (BST) Received: from Padamandas.fritz.box (unknown [106.210.88.70]) by eusmtip1.samsung.com (KnoxPortal) with ESMTPA id 20201010160526eusmtip1f1743b61930a421b73c47ec3a9abbc3f~8rSFiTXqR2442224422eusmtip1z; Sat, 10 Oct 2020 16:05:26 +0000 (GMT) From: Lukasz Wojciechowski To: David Hunt , Bruce Richardson Cc: dev@dpdk.org, l.wojciechow@partner.samsung.com, stable@dpdk.org Date: Sat, 10 Oct 2020 18:04:56 +0200 Message-Id: <20201010160508.19709-6-l.wojciechow@partner.samsung.com> X-Mailer: git-send-email 2.17.1 In-Reply-To: <20201010160508.19709-1-l.wojciechow@partner.samsung.com> X-Brightmail-Tracker: H4sIAAAAAAAAA+NgFnrCIsWRmVeSWpSXmKPExsWy7djP87rHbzfGG6w7L2BxY5W9Rd+kj0wW 7z5tZ7J41rOO0eJfxx92B1aPXwuWsnos3vOSyePguz1MAcxRXDYpqTmZZalF+nYJXBlPnx1l KTgrVXFo/SbGBsbtol2MHBwSAiYSbZ8Suxi5OIQEVjBK3O79zQjhfGGUeL71FxOE85lRom3+ ReYuRk6wjiMHf0FVLWeUWN7/gQUkISTwiVFi5Rw9EJtNwFbiyMyvrCC2iECYRHPzXhaQdcwC zhJPvrKBhIUF3CVe/psB1soioCrRtKKZEcTmFXCV+P1rChPELnmJ1RsOgO3lFHCTONt1kA1k r4TAZTaJ34uvMUK84CKxoVkCol5Y4tXxLewQtozE6ck9LBD12xglrv7+yQjh7GeUuN67AqrK WuLwv99sEMdpSqzfpQ8RdpTobrwMNZ9P4sZbQZAwM5A5adt0Zogwr0RHmxBEtZ7E056pjDBr /6x9wgJhe0j82nWMDRI6VxklJuxym8AoPwth1wJGxlWM4qmlxbnpqcVGeanlesWJucWleel6 yfm5mxiBcX/63/EvOxh3/Uk6xCjAwajEwytxqjFeiDWxrLgy9xCjBAezkgiv09nTcUK8KYmV ValF+fFFpTmpxYcYpTlYlMR5jRe9jBUSSE8sSc1OTS1ILYLJMnFwSjUwrn3/QLOF3Wmh4M8Z YheeKj6Iqs97eEjnRdjm0ArDBkepINF3l1PO7g/VuxVcfMJLNU7m+sd75wz05hwRDcgu/tw/ ZY7an9XR6ROCjNKeNRlf2fL1hjdrdZHLJw3tfouEhxYfb0WcNds3U/+16wJx19VV3/Wdprjm s7A//rWg0dQz+s0bb3c+JZbijERDLeai4kQApw40rvcCAAA= X-Brightmail-Tracker: H4sIAAAAAAAAA+NgFjrOLMWRmVeSWpSXmKPExsVy+t/xu7rHbzfGG7wNsrixyt6ib9JHJot3 n7YzWTzrWcdo8a/jD7sDq8evBUtZPRbvecnkcfDdHqYA5ig9m6L80pJUhYz84hJbpWhDCyM9 Q0sLPSMTSz1DY/NYKyNTJX07m5TUnMyy1CJ9uwS9jKfPjrIUnJWqOLR+E2MD43bRLkZODgkB E4kjB38xdjFycQgJLGWU+HFkC1sXIwdQQkbiwyUBiBphiT/Xutggaj4wSkz5c4wRJMEmYCtx ZOZXVpB6EYEwiRMr/UHCzALuElsWT2UGsYWB7Jf/ZrCA2CwCqhJNK5rBWnkFXCV+/5rCBDFf XmL1hgNg9ZwCbhJnuw5C7WpklDhx+ybbBEa+BYwMqxhFUkuLc9Nziw31ihNzi0vz0vWS83M3 MQIDcduxn5t3MF7aGHyIUYCDUYmHV+JUY7wQa2JZcWXuIUYJDmYlEV6ns6fjhHhTEiurUovy 44tKc1KLDzGaAl01kVlKNDkfGCV5JfGGpobmFpaG5sbmxmYWSuK8HQIHY4QE0hNLUrNTUwtS i2D6mDg4pRoY21ZvNBU7w5zfqemb6sj2YlJioM9KyfW+p++9151x7nNs/eEJF53mLp/4JZi7 zNOFrXCrleyH/62GTNpRPRr8F+56Gtd9Osi2uWLTBeme9EfHjPsf7y2KK0mxmsR1w/5f8Ykm ht/cJ03uqX46Ucr35/6LyMnJZyep+YvJmDeXshwQiplluVJciaU4I9FQi7moOBEA4MhIU1oC AAA= X-CMS-MailID: 20201010160527eucas1p2f55cb0fc45bf3647234cdfa251e542fc X-Msg-Generator: CA Content-Type: text/plain; charset="utf-8" X-RootMTR: 20201010160527eucas1p2f55cb0fc45bf3647234cdfa251e542fc X-EPHeader: CA CMS-TYPE: 201P X-CMS-RootMailID: 20201010160527eucas1p2f55cb0fc45bf3647234cdfa251e542fc References: <20201009220202.20834-1-l.wojciechow@partner.samsung.com> <20201010160508.19709-1-l.wojciechow@partner.samsung.com> Subject: [dpdk-dev] [PATCH v7 05/16] test/distributor: fix shutdown of busy worker X-BeenThere: dev@dpdk.org X-Mailman-Version: 2.1.15 Precedence: list List-Id: DPDK patches and discussions List-Unsubscribe: , List-Archive: List-Post: List-Help: List-Subscribe: , Errors-To: dev-bounces@dpdk.org Sender: "dev" The sanity test with worker shutdown delegates all bufs to be processed by a single lcore worker, then it freezes one of the lcore workers and continues to send more bufs. The freezed core shuts down first by calling rte_distributor_return_pkt(). The test intention is to verify if packets assigned to the shut down lcore will be reassigned to another worker. However the shutdown core was not always the one, that was processing packets. The lcore processing mbufs might be different every time test is launched. This is caused by keeping the value of wkr static variable in rte_distributor_process() function between running test cases. Test freezed always lcore with 0 id. The patch stores the id of worker that is processing the data in zero_idx global atomic variable. This way the freezed lcore is always the proper one. Fixes: c3eabff124e6 ("distributor: add unit tests") Cc: bruce.richardson@intel.com Cc: stable@dpdk.org Signed-off-by: Lukasz Wojciechowski Tested-by: David Hunt --- app/test/test_distributor.c | 23 +++++++++++++++++++++-- 1 file changed, 21 insertions(+), 2 deletions(-) diff --git a/app/test/test_distributor.c b/app/test/test_distributor.c index 52230d250..6cd7a2edd 100644 --- a/app/test/test_distributor.c +++ b/app/test/test_distributor.c @@ -28,6 +28,7 @@ struct worker_params worker_params; static volatile int quit; /**< general quit variable for all threads */ static volatile int zero_quit; /**< var for when we just want thr0 to quit*/ static volatile unsigned worker_idx; +static volatile unsigned zero_idx; struct worker_stats { volatile unsigned handled_packets; @@ -340,26 +341,43 @@ handle_work_for_shutdown_test(void *arg) unsigned int total = 0; unsigned int i; unsigned int returned = 0; + unsigned int zero_id = 0; + unsigned int zero_unset; const unsigned int id = __atomic_fetch_add(&worker_idx, 1, __ATOMIC_RELAXED); num = rte_distributor_get_pkt(d, id, buf, NULL, 0); + if (num > 0) { + zero_unset = RTE_MAX_LCORE; + __atomic_compare_exchange_n(&zero_idx, &zero_unset, id, + false, __ATOMIC_ACQ_REL, __ATOMIC_ACQUIRE); + } + zero_id = __atomic_load_n(&zero_idx, __ATOMIC_ACQUIRE); + /* wait for quit single globally, or for worker zero, wait * for zero_quit */ - while (!quit && !(id == 0 && zero_quit)) { + while (!quit && !(id == zero_id && zero_quit)) { worker_stats[id].handled_packets += num; count += num; for (i = 0; i < num; i++) rte_pktmbuf_free(buf[i]); num = rte_distributor_get_pkt(d, id, buf, NULL, 0); + + if (num > 0) { + zero_unset = RTE_MAX_LCORE; + __atomic_compare_exchange_n(&zero_idx, &zero_unset, id, + false, __ATOMIC_ACQ_REL, __ATOMIC_ACQUIRE); + } + zero_id = __atomic_load_n(&zero_idx, __ATOMIC_ACQUIRE); + total += num; } worker_stats[id].handled_packets += num; count += num; returned = rte_distributor_return_pkt(d, id, buf, num); - if (id == 0) { + if (id == zero_id) { /* for worker zero, allow it to restart to pick up last packet * when all workers are shutting down. */ @@ -578,6 +596,7 @@ quit_workers(struct worker_params *wp, struct rte_mempool *p) rte_eal_mp_wait_lcore(); quit = 0; worker_idx = 0; + zero_idx = RTE_MAX_LCORE; } static int -- 2.17.1