From patchwork Sun May 28 19:58:38 2017 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Jerin Jacob X-Patchwork-Id: 24824 X-Patchwork-Delegate: jerinj@marvell.com Return-Path: X-Original-To: patchwork@dpdk.org Delivered-To: patchwork@dpdk.org Received: from [92.243.14.124] (localhost [IPv6:::1]) by dpdk.org (Postfix) with ESMTP id 14F8E7CC4; Sun, 28 May 2017 22:01:24 +0200 (CEST) Received: from NAM03-DM3-obe.outbound.protection.outlook.com (mail-dm3nam03on0087.outbound.protection.outlook.com [104.47.41.87]) by dpdk.org (Postfix) with ESMTP id 7D5217CBC for ; Sun, 28 May 2017 22:01:22 +0200 (CEST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=CAVIUMNETWORKS.onmicrosoft.com; s=selector1-cavium-com; h=From:Date:Subject:Message-ID:Content-Type:MIME-Version; bh=2OoEHfEijSKO98lrmsC3tC3nz/nBtnEQEToNofjGiPE=; b=TFyFz1NCnU3/Y1Nf5AHMU+AoYerqLlGJSj2VuoCC12nDkLWxWyZgiVL4opRFJ6v6kDGuWy6vZhG9dWVKIUHVOK8aFQ0hs14q6Bz3tCD4/NwisMK9XRz34n/rTOW80VYQ3hiLs56PdbRJRctVxB7Pp6maB8HJLSx5wu5m+NxCkVk= Authentication-Results: dpdk.org; dkim=none (message not signed) header.d=none;dpdk.org; dmarc=none action=none header.from=caviumnetworks.com; Received: from jerin.domain.name (111.93.218.67) by CY1PR0701MB1725.namprd07.prod.outlook.com (10.163.21.14) with Microsoft SMTP Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_128_CBC_SHA256_P256) id 15.1.1124.9; Sun, 28 May 2017 20:01:17 +0000 From: Jerin Jacob To: dev@dpdk.org Cc: bruce.richardson@intel.com, harry.van.haaren@intel.com, hemant.agrawal@nxp.com, gage.eads@intel.com, nipun.gupta@nxp.com, narender.vangati@intel.com, nikhil.rao@intel.com, gprathyusha@caviumnetworks.com, Jerin Jacob Date: Mon, 29 May 2017 01:28:38 +0530 Message-Id: <20170528195854.6064-18-jerin.jacob@caviumnetworks.com> X-Mailer: git-send-email 2.13.0 In-Reply-To: <20170528195854.6064-1-jerin.jacob@caviumnetworks.com> References: <20170528195854.6064-1-jerin.jacob@caviumnetworks.com> MIME-Version: 1.0 X-Originating-IP: [111.93.218.67] X-ClientProxiedBy: BMXPR01CA0003.INDPRD01.PROD.OUTLOOK.COM (10.174.214.141) To CY1PR0701MB1725.namprd07.prod.outlook.com (10.163.21.14) X-MS-PublicTrafficType: Email X-MS-TrafficTypeDiagnostic: CY1PR0701MB1725: X-MS-Office365-Filtering-Correlation-Id: e0216134-72c1-4381-5477-08d4a6044fb1 X-Microsoft-Antispam: UriScan:; BCL:0; PCL:0; RULEID:(22001)(201703131423075)(201703031133081); SRVR:CY1PR0701MB1725; X-Microsoft-Exchange-Diagnostics: 1; CY1PR0701MB1725; 3:s//9Tie8MqDWrwDLYAoMJxNc4aH9eUyUAv/QINE9hAz/bK+OyoeE7naqIO0Oi4KpE3NYHOpMUlhHUOFlfOPo/bYIIB/xf0yBZk+cIvyB6Fw3uiDDZ1PRR7YhA3pdb95a0UaF7Ll7SrNJLRyhY0+V1Hekw5OOIwdzYnfpirNgqL/WVy9anJt3wMwX6j/CoY7R0t7ii0stuk8Mgyz1io3tr/9DMkq6c7wUxPb6iTjhjWCbGAcR3oicsAKy02CtWYwb0bajWH/EFbgz9x8V6II8EbMBlyWjccjy8z/E3qBdyvkIB7dBtnATCG4MmNTHpRXsqHJp2faf6G2c4UFnVz25Tg==; 25:WQ9En+tV4haXY8NJYabTyHL/2I+O8IByCn8hdeA+agIyH9HrzQ7u/xum+4TyBR7YGWcBWhKCh4gyz09t+KOFmGtkjPMUWdDnsL+qTaDskG7RB+MMnJyycJv+L0WiLZe71jKinO9ZQY9yGxiUSovSryPOrMIKze26P5Rm3gWOgMYM97zwxy0dYVlc/5H0WkM+7DhYtFo46BLz9NbqyClwD8f520jI/ZukI6OhKpTAOZRDS0HKPrc3+p9E3DmNNu/TZjIM2kDjKhmWVEBBZFlH6JeR3W55eh+e3w7z//v8D/4hPgIxAuGeRAgI/sBIAAjpGmP+xv8NHBKogEh4U1O4obMXCp3L9lEUXSaL/0khM3LLbm8Jct9Wm7EhIyz/aRElNT/Erxj/MENjQbPsXU4G7A0yYxBFreJQ15bPHTrgaT6MNCax+bsdRBqZuCrR6HyUECOj3QEvXCv2lmsgJ80UoNFknAZQeeY8vBCw1wThrt4= X-Microsoft-Exchange-Diagnostics: 1; CY1PR0701MB1725; 31:TVOQ6OfbJtkWdD92f9+rgKdTMRiTUCM8FrAb9ngMtf96YYl7wofZjyjMqUWgi2qD0E6jDTParTFQLBmr1SCCIxK1n6xfNrQ0eTbLxbCA+wJGkSs7yKkkFzZaWHjozgQQklqGQn/zXUDZpbdQDMYozdvPwCKRXJMzXoG4uGLQXgOapxMcxHGjDwuor1Ws3NeD1drSiHjqriT0Z9RPuUzQvv7YgdS/KVbQkCyAuUNqSb4=; 20:bQUVhr+4B6ajX20Ux0E1/CoeUvP5Z7Y1fBZWS2tBQ22nYhAa27DCwS47OBnN33atJ/6QnV+DLxBwcvOyhEuQx0Mv7qtWlTksOysfO9wXonDVvft8DYnANbbnhAOlXOUPjJkOgIgESvuuIeTwGlZiZzbGTzonr3GGsw+ULHeqg0EWkncWwiRmOBZq5EoeDH8wYHKAcb2sw/Ltjb52vYlwg5EDlJjvPvruMil7jwSKUUUAhaAq+V1PIVS7dxHNLsHXWE0NKmDRmxP/FcV3ZVIUI39sm5jij/hPBbYu/B/1ftyW+atBpibBGS0jhQoDl1T/UOKqtLKEw2HI7zOhaynrzQfRrbt/+m3VOipHGxj1fyNjOTSgJLvyMQRgRIUh8IVIhJuWYgS/t4HFXPicA/bE2FQ+IQnHjcNqvvUssv+spoLUjV8bBs60+g4Yg36S8Ntb13RURK5K4mAlR7sZ9r2OkFhfjXTcKJG7Cd79viZCenTtFObbmWbJ7WDWtQwOZ9CydpcT/Vha2pVmSsX7XVm7r8KJaC7FMkUBaajhRQ/ju9D4tcC8Yuk0JhEGljirn3J9PI1ANrzfc1uLcCHcQuv9M3ixx/xVeP1SMObD+cbwjMc= X-Microsoft-Antispam-PRVS: X-Exchange-Antispam-Report-Test: UriScan:; X-Exchange-Antispam-Report-CFA-Test: BCL:0; PCL:0; RULEID:(100000700073)(100105000095)(100000701073)(100105300095)(100000702073)(100105100095)(6040450)(601004)(2401047)(5005006)(8121501046)(3002001)(10201501046)(93006095)(100000703073)(100105400095)(6041248)(20161123562025)(20161123555025)(20161123560025)(20161123564025)(201703131423075)(201702281528075)(201703061421075)(201703061406153)(20161123558100)(6072148)(100000704073)(100105200095)(100000705073)(100105500095); SRVR:CY1PR0701MB1725; BCL:0; PCL:0; RULEID:(100000800073)(100110000095)(100000801073)(100110300095)(100000802073)(100110100095)(100000803073)(100110400095)(100000804073)(100110200095)(100000805073)(100110500095); SRVR:CY1PR0701MB1725; X-Microsoft-Exchange-Diagnostics: =?us-ascii?Q?1; CY1PR0701MB1725; 4:FIIFmiCBmf+6xOpLoQRtHOIErSBFtYGvHW5Yby0H?= OPOd1RkD/0ywUCqoAmTgEldHaWWwQEdAqW0immsZyFzDIr0m5GwSyOhS1wBgilFIFHmkBaiQ9jOdS5hqyRTz5w3KheegU4eL+tzU8eWaTIwJzFBMRpFk8WAb8tFyLfFllJGWMYDyTydGYGg+3lrzBiaFSDyMHM0QyAdYDRWNFn9KU292M8XxEmSt1OMYEUy96qZ/edn3BBym7B8M6JwFmu3khX5orDM1hOwc4bxnBJ82qDkseUBqiGbUCGxjsy6P950g48B4TfN2mLzBC43aKrpLId9omDkAOZaBckm++G+ZXFynbN0Es8FO/20txtdX6i95VHWvsXJIisZgS+L7MRY/2VaQWapGXNEeqviCYwWlBlofy+1OpkagKkuGR1JjnO3JhLFF4Q801EYJzoSYZ1mh4XKCn29M2FYf5UluFlC0WxBAFB8CUIcrfq3zCq2JElbcjA6XCsfTjX8hWgpwstCuVFa6tNRJDpUUG9sB3ONS3AQw65+307FCZKlYN+1IM46yN+CQw/6yij5GzD1DHI9Db3opcRvTrxawduq9rY5+A5TpbGw0vbmiiA4WV+2hbXGCsXcvW0aag7B0MoF+0K+dl38MaLHNluSQsYBJ64p+8DU6tuCf9nNyGfPmTeSGt6rq7Py5dQSLbFbvq8mipY6SWjwOm6JsStuxLOkR1VPRkLPg1MPErtGMquZ7tM0lGA4wpL0DPu4vUybYej8r/x0iNjbmGLwISekeooT5eqXUpF6KCs2J6Y3EKPfndwkf7XcTmciIaI0P6OvIDggElMksX/JZgS344fLrcsi4qrj8g5dx6jjbWaJC64n/UGn/tkX/ySNYvza5i/hQ2MFjj70ygDrNc6/cvSPLSEozaK+uojE02ME8fAgBItrpY2sKiHLyJLoCBq5/NVPxOIEngk/8A7JYCdzmHSLSiPqX1Q6+el9d4Aw4omGqGi/ligrIzQG4KfaFNmdVIlW3btGWvLbvscZbA/HEqfCCWx8smFKuuvFA1pR5oJ/TNmZdCiPrwq5g8UZOHJN7f+Bsu5isRlj5v6KRk7VuisebLcyU6NmXGSAKFW5Bwurh/UuWQKFT4Rk= X-Forefront-PRVS: 03218BFD9F X-Forefront-Antispam-Report: SFV:NSPM; SFS:(10009020)(4630300001)(6009001)(39450400003)(39850400002)(39410400002)(39840400002)(39400400002)(81166006)(6486002)(966005)(66066001)(4326008)(50986999)(76176999)(50226002)(189998001)(6306002)(72206003)(53376002)(36756003)(6506006)(38730400002)(5003940100001)(5009440100003)(110136004)(107886003)(42186005)(53416004)(7736002)(8676002)(48376002)(50466002)(1076002)(3846002)(6116002)(6512007)(2361001)(305945005)(2906002)(6666003)(478600001)(25786009)(5660300001)(2351001)(6916009)(42882006)(2950100002)(33646002)(8656002)(47776003)(53936002)(562404015)(563064011); DIR:OUT; SFP:1101; SCL:1; SRVR:CY1PR0701MB1725; H:jerin.domain.name; FPR:; SPF:None; MLV:sfv; LANG:en; X-Microsoft-Exchange-Diagnostics: =?us-ascii?Q?1; CY1PR0701MB1725; 23:4h+R7lrqB36pQNxGZEhv7Jrj6qBMAOxtn92+CrB?= pjLyBmHCqgudvioAMAmiFxLC9qk3Y/MUrI+zm/sxZP3Se8S/+mgM0dZNhagKoVZYKXa9GQ1bXFaOnEGFtqrZ0zXLc2+U0FyTNTzY4cbGpKcnXXVDZ1yEqsuet87VlqBToeni1boMU3llSDm+9bmETIm57h0D1NEdF+yJ8yKDeH8QU5bNx+i10xerGqSztoAXjgiASqSDrdtzzu9GlfV01qr66w+s4x/Ygmz3Pq+KdQmvwF0ctz4ib7jM5xD6JQxWQiIGwme1hNT5P9+8sut3BsXjwpuwinHeGWHw0nFheKsxZXDWtYRKjXy4taA7Xj0sLF+2kkSopghbOGbWX/WSFB07A/1DoUrCuWjlJ/YJJBTkWffECNdQmKvXUNG9ly++Y9bUX4IzsuzdEP8j6M6EHJqRCCkwS1balW6JGOOYk19yZSv66Z6ZNk1lnU/tqMEbqrbwfcU2nXqWWIg1EY8ZffFiuL15K8KqTzECWwqNkzQuX4D6j8WLU53pmBp8M5O2DOhUPPq6YVAr0ukp86Sx430hSobzNn2Xr7+XgYXswbp7V2A/5AA9ToljYTS65Mr9Sb4lN4ge7YpanOnLp6QoX9COcNsoL6nWuf+g2MSMicvgR5KW9aR6wY8H4o0taerSkgo5t5OJJcQ87W6py2vGysPN3D5O7rXmq1moAgBNMu+M2rqiyTg7IeC0KsJMukYQMSkSPTVhFxMVoJhrcnFStfnNkHLKMBROPKgcIvVvAexHPzW+8o3vb30dUTbFYhNZpaKbuwwcae36jWEUUtdzoW0DUb3EI/2QvyYyJADLkdnX42m1c48QneIvubilyz4UE6Fql+8AprZYjmIVY++9kwENgHziL3EG8DLYx7pi4COoScgR9uXerO/Ja7Gj5Zdsp+scoPGgP7/mauywZZ0WkX/sUvI90Nl4zcCiKfFpSryOV2OJdgP8vhZcnFHhz1nvCieTLcL9+xrphGr/CFxsFOpWTNfi8L5zW77asnW3nS/SJGXPylXP1M2D3R466Je0OolrTuj9/8cEmy9YnHnPLeBE/cd2/REv045m6VDZVxD0G2wJTCr5Pk9Sbv44NB//fpPqgIiRE+6wxjC4avmn1WXhbQpEziWtUgT2KJ1xXxnErdVIH/ZtDPtt1RT9sf3/F+/Bt03Ge69Y//bqoUFg4fUkdKCFxHm3OTvCkKpN3Qu4G7/goHZYXmpwM+cFCqtjYDhYLWb+um08dP8vOL4TvZXXGFDQxC2PLqn5tcH+i99hDLdFaxNUjH1Wh/iUFWlIzrn0= X-Microsoft-Exchange-Diagnostics: 1; CY1PR0701MB1725; 6:JHSWQ/BhYQqvy6Iv0XCv8vqlRtKeQr70JwOZZ2Zl7f9jzD+9uzA2JZSc9m0lJuvYsikDqhkPaZzHwXE1uQU/Sc1ODkW6QrsApClnjMIUTP5wH8C7jpKc2S/ZnmKvKanyA3Q//QJdkPFXK+t1J5TtGIAG1L0ju9RyIhFpxu/iiFsif/sFa7itXUzH5Psx+iytmKT/CWKj+DN9jw295bkl1Br3Kd+/p+T5buIZsSvX/b3Vsjoz/crLqUtBDo3cK15thUpylR1NNC6V86GBwV5qaWoSCGYwgSeumF6k/a9q9zRPL2kR8rJ2DMvkz6iHfCNH0u50oMskd4+BpkagAjbS+8cXZ5uvPhFe6E1R+P4uRajrxTuOVEz0011ych/2GGH05kT520FdLHQTL0Ysb/sdSpe/bo8VZCUf3FuI1rYCwvJ0CDeappIGu0bVLM6j9NeLU/34yBE1Sij45V/KK3h6GAUYHOCYOgy/rwkaDHUg3F9FvWFev3vQm/CPWpAqMTecY1SknSXsR/eF+bPzcvsj3g== X-Microsoft-Exchange-Diagnostics: 1; CY1PR0701MB1725; 5:rszfSM3EIJwqWhQuLMioYpKjol1hU/LRB0mE5WYkpGEYZtjeTcEKKQiKuliuc5tFqxaS5vlTberqhfCUc5d5Y6qaRp6Yq9cdj4xfiURviZlvAVzvngTzPQ62gsxdKdtYX7iRzjVm7K098Cgfk06pcsXteEJpqIuOoQQKL3wKR4OZEOOv97baTWX4Fn7EDvXG3k7lSYvyQcK6wQa1QmmevH1vbCL2RC+vMTKBLbZ4P9DL0+ObDCUnDN0DM/lQ9NGVo8SWJ3LvfAJoq1/GQNX24iaDb3UCdSpTHGUvzsztbsriwnlF/IjPpLuqLCfSxdvEBDbVVcZr53Oj77Wn3Pbz1agqJbni2xr4F1YCkJi2C1+9o+uTP2cM9+b8fOiC8REwufEWsliMmUnZ/9ulXsTUi5OHbqEnZ6+biSZp/BNJE77rkwl1JXbewMV3N7dvikwgEklo5hxR5CkqzLc91Hi3IDxh9dA1f5STTKxoOtTYX0zfVsNc5akXVb7JwEPMNaqK; 24:rq7ddqTCoPNOUKJszdLzXYQRgeGgRa6jUo9hTktVk9Dp/47yJPmB2LWQj/Le5TpcbTLqA5EjbI+z72RnNE6v9/PsySUTZGmY//MbWNi0rdo= SpamDiagnosticOutput: 1:99 SpamDiagnosticMetadata: NSPM X-Microsoft-Exchange-Diagnostics: 1; CY1PR0701MB1725; 7:/HAlPWo3GCoop2Vb41/aJpsQvrxWS9Lo7CqYL7woaB+8Ht6wQXm/4HeCx0Msu9vHl87UFyUF22cId/1soh6r6XAa+QnKQjkdPN81W9EWJoUEDC4mkmwSrUPmTHpu7dEdKZdKjml4lTI84DCC/e7p2O/D7P2l+YjZgih6ZAu9hVlatfiq6z0+K+xXWeD/PShFAd3BiWHJVVwTnansFTSbAxrJWOzyCWS8RHPMR7r/AcblMqAEL/J82ywi7pQcbTxZzWUxBvJiCAMpLgCt5vfgUkHyhiJhY/DXNHC7pqVmZx/n0lPQbIC/3wNwYavItNTDgzr+kSSsIkE/0D8u6MmGgg== X-OriginatorOrg: caviumnetworks.com X-MS-Exchange-CrossTenant-OriginalArrivalTime: 28 May 2017 20:01:17.2781 (UTC) X-MS-Exchange-CrossTenant-FromEntityHeader: Hosted X-MS-Exchange-Transport-CrossTenantHeadersStamped: CY1PR0701MB1725 Subject: [dpdk-dev] [PATCH 17/33] app/testeventdev: order queue: add worker functions 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" Signed-off-by: Jerin Jacob --- app/test-eventdev/test_order_common.h | 47 ++++++++++++++++ app/test-eventdev/test_order_queue.c | 100 ++++++++++++++++++++++++++++++++++ 2 files changed, 147 insertions(+) diff --git a/app/test-eventdev/test_order_common.h b/app/test-eventdev/test_order_common.h index a760b94bd..88cb2acd9 100644 --- a/app/test-eventdev/test_order_common.h +++ b/app/test-eventdev/test_order_common.h @@ -90,6 +90,53 @@ order_nb_event_ports(struct evt_options *opt) return evt_nr_active_lcores(opt->wlcores) + 1 /* producer */; } +static inline __attribute__((always_inline)) void +order_process_stage_1(struct test_order *const t, + struct rte_event *const ev, const uint32_t nb_flows, + uint32_t *const expected_flow_seq, + rte_atomic64_t *const outstand_pkts) +{ + const uint32_t flow = (uintptr_t)ev->mbuf % nb_flows; + /* compare the seqn against expected value */ + if (ev->mbuf->seqn != expected_flow_seq[flow]) { + evt_err("flow=%x seqn mismatch got=%x expected=%x", + flow, ev->mbuf->seqn, expected_flow_seq[flow]); + t->err = true; + rte_smp_wmb(); + } + /* + * Events from an atomic flow of an event queue can be scheduled only to + * a single port at a time. The port is guaranteed to have exclusive + * (atomic) access for given atomic flow.So we don't need to update + * expected_flow_seq in critical section. + */ + expected_flow_seq[flow]++; + rte_pktmbuf_free(ev->mbuf); + rte_atomic64_sub(outstand_pkts, 1); +} + +static inline __attribute__((always_inline)) void +order_process_stage_invalid(struct test_order *const t, + struct rte_event *const ev) +{ + evt_err("invalid queue %d", ev->queue_id); + t->err = true; + rte_smp_wmb(); +} + +#define ORDER_WORKER_INIT\ + struct worker_data *w = arg;\ + struct test_order *t = w->t;\ + struct evt_options *opt = t->opt;\ + const uint8_t dev_id = w->dev_id;\ + const uint8_t port = w->port_id;\ + const uint32_t nb_flows = t->nb_flows;\ + uint32_t *expected_flow_seq = t->expected_flow_seq;\ + rte_atomic64_t *outstand_pkts = &t->outstand_pkts;\ + if (opt->verbose_level > 1)\ + printf("%s(): lcore %d dev_id %d port=%d\n",\ + __func__, rte_lcore_id(), dev_id, port) + int order_test_result(struct evt_test *test, struct evt_options *opt); int order_opt_check(struct evt_options *opt); int order_test_setup(struct evt_test *test, struct evt_options *opt); diff --git a/app/test-eventdev/test_order_queue.c b/app/test-eventdev/test_order_queue.c index 17771ea74..b4ec79517 100644 --- a/app/test-eventdev/test_order_queue.c +++ b/app/test-eventdev/test_order_queue.c @@ -37,6 +37,105 @@ /* See http://dpdk.org/doc/guides/tools/testeventdev.html for test details */ +static inline __attribute__((always_inline)) void +order_queue_process_stage_0(struct rte_event *const ev) +{ + ev->queue_id = 1; /* q1 atomic queue */ + ev->op = RTE_EVENT_OP_FORWARD; + ev->sched_type = RTE_SCHED_TYPE_ATOMIC; + ev->event_type = RTE_EVENT_TYPE_CPU; +} + +static int +order_queue_worker(void *arg) +{ + ORDER_WORKER_INIT; + struct rte_event ev; + + while (t->err == false) { + uint16_t event = rte_event_dequeue_burst(dev_id, port, + &ev, 1, 0); + if (!event) { + if (rte_atomic64_read(outstand_pkts) <= 0) + break; + rte_pause(); + continue; + } + + if (ev.queue_id == 0) { /* from ordered queue */ + order_queue_process_stage_0(&ev); + while (rte_event_enqueue_burst(dev_id, port, &ev, 1) + != 1) + rte_pause(); + } else if (ev.queue_id == 1) { /* from atomic queue */ + order_process_stage_1(t, &ev, nb_flows, + expected_flow_seq, outstand_pkts); + } else { + order_process_stage_invalid(t, &ev); + } + } + return 0; +} + +static int +order_queue_worker_burst(void *arg) +{ + ORDER_WORKER_INIT; + struct rte_event ev[BURST_SIZE]; + uint16_t i; + + while (t->err == false) { + uint16_t const nb_rx = rte_event_dequeue_burst(dev_id, port, ev, + BURST_SIZE, 0); + + if (nb_rx == 0) { + if (rte_atomic64_read(outstand_pkts) <= 0) + break; + rte_pause(); + continue; + } + + for (i = 0; i < nb_rx; i++) { + if (ev[i].queue_id == 0) { /* from ordered queue */ + order_queue_process_stage_0(&ev[i]); + } else if (ev[i].queue_id == 1) {/* from atomic queue */ + order_process_stage_1(t, &ev[i], nb_flows, + expected_flow_seq, outstand_pkts); + ev[i].op = RTE_EVENT_OP_RELEASE; + } else { + order_process_stage_invalid(t, &ev[i]); + } + } + + uint16_t enq; + + enq = rte_event_enqueue_burst(dev_id, port, ev, nb_rx); + while (enq < nb_rx) { + enq += rte_event_enqueue_burst(dev_id, port, + ev + enq, nb_rx - enq); + } + } + return 0; +} + +static int +worker_wrapper(void *arg) +{ + /* FIXME: probe through device capability */ + const bool burst = 1; + + if (burst) + return order_queue_worker_burst(arg); + else + return order_queue_worker(arg); +} + +static int +order_queue_launch_lcores(struct evt_test *test, struct evt_options *opt) +{ + return order_launch_lcores(test, opt, worker_wrapper); +} + #define NB_QUEUES 2 static int order_queue_eventdev_setup(struct evt_test *test, struct evt_options *opt) @@ -133,6 +232,7 @@ static const struct evt_test_ops order_queue = { .test_setup = order_test_setup, .mempool_setup = order_mempool_setup, .eventdev_setup = order_queue_eventdev_setup, + .launch_lcores = order_queue_launch_lcores, .eventdev_destroy = order_eventdev_destroy, .mempool_destroy = order_mempool_destroy, .test_result = order_test_result,