From mboxrd@z Thu Jan  1 00:00:00 1970
Return-Path: <Pavan.Bhagavatula@cavium.com>
Received: from NAM02-CY1-obe.outbound.protection.outlook.com
 (mail-cys01nam02hn0201.outbound.protection.outlook.com [104.47.37.201])
 by dpdk.org (Postfix) with ESMTP id 515CD1B1A6
 for <dev@dpdk.org>; Mon, 18 Dec 2017 22:45:29 +0100 (CET)
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=aIqzsoHOyBsq3D8WxB0wpNWN/zv7GjBkqz0cgd1uEdU=;
 b=mkY6oDCdYdHDYhGWFe0rV8Lm/2nnRWnSbHBZ/rvBlEjD6fPaEgpPOZvFmpptNOg1/i5RnXMr+Z3H8yPUURFSExLeLrJlFdUN5khsxo5Y8JE3kk1w+ge9rYkrnJmvJNX/VqfX2h7IrZ12qdbIB7CVAiFNdc/DumIPuueO6kUh9ww=
Authentication-Results: spf=none (sender IP is )
 smtp.mailfrom=Pavan.Bhagavatula@cavium.com; 
Received: from localhost.localdomain (111.93.218.67) by
 DM5PR07MB3467.namprd07.prod.outlook.com (10.164.153.22) with Microsoft SMTP
 Server (version=TLS1_2, cipher=TLS_ECDHE_RSA_WITH_AES_256_CBC_SHA384_P256) id
 15.20.323.15; Mon, 18 Dec 2017 21:45:24 +0000
From: Pavan Nikhilesh <pbhagavatula@caviumnetworks.com>
To: jerin.jacob@caviumnetworks.com, santosh.shukla@caviumnetworks.com,
 bruce.richardson@intel.com, harry.van.haaren@intel.com,
 gage.eads@intel.com, hemant.agrawal@nxp.com, nipun.gupta@nxp.com,
 liang.j.ma@intel.com
Cc: dev@dpdk.org,
	Pavan Nikhilesh <pbhagavatula@caviumnetworks.com>
Date: Tue, 19 Dec 2017 03:14:03 +0530
Message-Id: <20171218214405.26763-10-pbhagavatula@caviumnetworks.com>
X-Mailer: git-send-email 2.14.1
In-Reply-To: <20171218214405.26763-1-pbhagavatula@caviumnetworks.com>
References: <20171130072406.15605-1-pbhagavatula@caviumnetworks.com>
 <20171218214405.26763-1-pbhagavatula@caviumnetworks.com>
MIME-Version: 1.0
Content-Type: text/plain
X-Originating-IP: [111.93.218.67]
X-ClientProxiedBy: HK2PR02CA0163.apcprd02.prod.outlook.com (10.171.30.23) To
 DM5PR07MB3467.namprd07.prod.outlook.com (10.164.153.22)
X-MS-PublicTrafficType: Email
X-MS-Office365-Filtering-Correlation-Id: bebd8266-da86-425c-d404-08d54660a746
X-Microsoft-Antispam: UriScan:; BCL:0; PCL:0;
 RULEID:(5600026)(4604075)(4534020)(4602075)(4627115)(201703031133081)(201702281549075)(2017052603307);
 SRVR:DM5PR07MB3467; 
X-Microsoft-Exchange-Diagnostics: 1; DM5PR07MB3467;
 3:CyH0ScHKwE9ubS9sDJSKmO6lRZq4r+55m68GVwBBSlrS5Urew1ANHdqzrrwqjAjTbRl08dlZU1XyZDtlSGuwOL67N/NLr6LXVJNabVUPSs9zqOr7i26B8j9L2RvY48hnK4hGXlPFxkGBGuhNQKoa3WlsFVR+zAoqqlikbSnH6vF+gQafnvvaP+A9hMPGDQXc6VQoGYAihaI2cOcuraDLbbSxfQr3ezd9IQwWiy4tjm/jQbHWvJQwVgjSISdTqbSn;
 25:N6bDv/O5H2sdW3jKcwV2LHlI99Isgf5Qvvd9nc5O9YIGPCvRAJG7BuTNuhAwOdmc/woyjIH/f0CZbfuwbxKQyTkrvsrBr78XfMDA1Qcp3nbfy14xWwaRccnyDOmvJynfMldwE94630RYZOGtj6+BWbjMowG8lSZpOStxV1Ht3OJM0akU5OneJWmY2dcg7Tn+J7UvvRmwpWD6CTn7kOSYOhYljb0jmtGPrJ0/ABb5T1XogWcWDo3QyCbxPBXeKjdrftD899cCoqlzvsqmbvFwdR1ppNZtmMe1gd9bEHYlqL1QQnF+dpMHbhzRAe2cYWLuRa5tVCvvHr48wTErOe9vOg==;
 31:85MPMx1r9WSSxqKDkwaxT4n60H8M/1B7TuYvxycjANNSjl6uxrKAT79UotNabRa8LSo/MVenVUCK7EXnr1t+krshvyOsy5PMPNM4oNceMfwmWauqIY3Jzvqh3D2+EYlC+MKgkW/6xt9RQLJBP8nLrkMG7hCskXTwd8k+AlE7dohJTR0NzdOLKyCXLiRZTkuwJQitMWXYUBrTQWmdVKfYXAH23AZH+mBGqq8g87NoCas=
X-MS-TrafficTypeDiagnostic: DM5PR07MB3467:
X-Microsoft-Exchange-Diagnostics: 1; DM5PR07MB3467;
 20:RxbuwGlIvmjqtqv16guGeQFVQJDkLisA/N9Ns3PsdNFDx814vCmBP2h1dP6meXuxdm5w03KAPU4uYj48gJOdDI7PUbHfYR3Ld+xWJJLQgcSLhQ9hyxF/hWSeJQ3Rdave7Pb7/5P9clkm7vg+3il28IN8nT8THozDOunwBEFBs2WcIrqzKZaHMfhX+bocCmUYGGtRU2YXsqw4XsqLSzXrjPq1qU6yBg+TFHMpe2nUwqbKKi4LTzibyqXTmhJg+chxdlbUqqS24Nnzo1SM1A4eMbueyVg9p2XGw61VfFRLnm8gk8a7gpFkYoQl9IhyCQiPfXLvc3asn6FOAe9KLJNk9YEI7vRHqAWp3oezFhuNXTnQwn9bL2DLzUXXBfqf5+MbTminkYPmZzm6JE8Bv4IXYBQriAb+xP9hzpSvF2Iks7aa7Rpmn7HLqv6Flmdkyz+wwnE1UGgtwJoLADXcYIH3AnsFUz1SlcX+2e6AykBKzJr1le6tikqueZzfoyTfPBFZrylSS+UPulyNmV0+nrf2n5i8ah4BP6Bo5MfAGb7glXQCNOMWqtJ9sSm7XE2m9DKhTzSbtMHQwcSF/ahiFQg7HujCyQ63WFY2vXxte0o0zSM=;
 4:k0Yq69Q+SsAthAqlWx+vSNWZs3p4k3HU0Q8FCpcsFAW/JY8VcxHy3DVzHkSxQlhgs6qGUFlv5srGbwGxZ0LlDFrefR2k9euh4uulaRLxLWgQsH6mxeWNfQA5BmH+4eEnpi9ttph3hjhWUTdq6JOmsztbMA6i/OPs5ztIsYeG8OjXSsB1CTWrAdWbNppfL3vv25wTdPQBiSysl9XJRRJ1y632AOgAbHgmWuY0fDmZjecPreBB7z5kvk9kr4YWj+GD7n0/KAjDuQOW/GTHzjk7zidVdsLLqPHBCAP+jSf3qOJHTfGuCr0kdnLYmUy82EyR
X-Microsoft-Antispam-PRVS: <DM5PR07MB34672256E3975B3E4444C183800E0@DM5PR07MB3467.namprd07.prod.outlook.com>
X-Exchange-Antispam-Report-Test: UriScan:(66839620246622);
X-Exchange-Antispam-Report-CFA-Test: BCL:0; PCL:0;
 RULEID:(6040450)(2401047)(8121501046)(5005006)(10201501046)(93006095)(3002001)(3231023)(2102001)(6041248)(201703131423075)(201702281528075)(201703061421075)(201703061406153)(20161123558100)(20161123562025)(20161123564025)(20161123555025)(20161123560025)(6072148)(201708071742011);
 SRVR:DM5PR07MB3467; BCL:0; PCL:0; RULEID:(100000803101)(100110400095);
 SRVR:DM5PR07MB3467; 
X-Forefront-PRVS: 0525BB0ADF
X-Forefront-Antispam-Report: SFV:SPM;
 SFS:(10009020)(6069001)(396003)(366004)(376002)(39860400002)(346002)(199004)(189003)(4326008)(2906002)(53936002)(305945005)(25786009)(1076002)(8936002)(50226002)(16526018)(6506007)(19273905006)(386003)(68736007)(52116002)(478600001)(51416003)(48376002)(5009440100003)(3846002)(6116002)(72206003)(53376002)(36756003)(966005)(6486002)(107886003)(8676002)(5660300001)(106356001)(105586002)(8656006)(2950100002)(42882006)(6306002)(6512007)(6666003)(59450400001)(16586007)(7736002)(66066001)(47776003)(76176011)(50466002)(81166006)(81156014)(316002)(97736004)(50929007)(562404015);
 DIR:OUT; SFP:1501; SCL:5; SRVR:DM5PR07MB3467; H:localhost.localdomain; FPR:;
 SPF:None; PTR:InfoNoRecords; A:1; MX:1; LANG:en; 
Received-SPF: None (protection.outlook.com: cavium.com does not designate
 permitted sender hosts)
X-Microsoft-Exchange-Diagnostics: =?us-ascii?Q?1; DM5PR07MB3467;
 23:B5qkev+hSQ9Leu0w76yKS0HLtyigNXdRp4RZ2KB8r?=
 =?us-ascii?Q?y/Tk+gWeuTSwIKkaAmIrV1gtrXbj7dR6upJS1BtazS0IRrRKWaxp2LB4HrcI?=
 =?us-ascii?Q?xWjr+j8JgRld8YwYcgnDm09qvhHrqXKkvbR8AAfi0o5glYRz76CRHcY0E1GL?=
 =?us-ascii?Q?ALcbKxcwlfaPxec7V89mY+2wlMP2Ryv1bVwrPW3gb3EgWRhuqagTIq2SRAMC?=
 =?us-ascii?Q?Wbr5uY7gVZEYZK4xiWp77MyCTjxmBzQ/g2z54zH6ObvFtFb7XQrPzR+aDZC/?=
 =?us-ascii?Q?mjiJMKYCvH/NIJdScCTPopHWYM3lXcFSyiuO/AgWNyyrVcN14cizm5fE0r6u?=
 =?us-ascii?Q?+IsVnG5XDdFUaplKy89u7DAKIx2adTPVHAISORaijvPMRSSiyq8KDUyNUzaM?=
 =?us-ascii?Q?YEF1foWA0L5YRHSLyUlRJ+p5ewSBHQqVHozhMc5CgnrcnpuqdBooSccZMQBB?=
 =?us-ascii?Q?hdX5aH8A9yC+rBrPOSvzJzHSU77UrUUapPu2qH1iNBBnvrAXl959TBWPX6wX?=
 =?us-ascii?Q?iRxWQBYzCwYqG3bvM/MftIdEi3+xAD7Qg/YdtI7GGl0h7+qPzgO5hc2hvmBo?=
 =?us-ascii?Q?cWsEcotjFrA8/GqnaHxzEHcYaK1QCJAO/IMj6n7D4k4Sq8UBj6t1fqXmCqu1?=
 =?us-ascii?Q?t6qcPDEecOMDxfrjN491UOZSUT1mOCxHpmqcdlZgqo17OkbfT/DWn64DypAN?=
 =?us-ascii?Q?otQ/e//s1W3nKz46LdLrR4WdXlGwpHy+srHa9ysdQuZ99Krdd/RuTWWaJspj?=
 =?us-ascii?Q?1/qeX2OnUyYWUMN9mlB6A84ZjhG+6l4l10uElr6sebOaOvsE0ok5ZqH/rDUM?=
 =?us-ascii?Q?K3ZYNWykkNgW5sqQwdj29eNmLLoYsLNV1W8r4Od5/DjtevxM4CkKoNfLZWF5?=
 =?us-ascii?Q?+hS7vk3S6PUgCrmsCjCFeMGUG/ex2Xf/VBHzaX5VQwNsipuzIL/0yMqlxac2?=
 =?us-ascii?Q?em1aS3Zq2DlnxJbOUaAup6g9z47H3JAK+WcLu5UnvWtZFr8yYNT8vDCnFix6?=
 =?us-ascii?Q?F37+n5t+AUVTxMaBy6K2pT+LxPpeRX80zTIIfvBuZraU2Oc3K/TJMtMV5+IQ?=
 =?us-ascii?Q?eEMezbeU7mNfdRXjhKWt/EIdS/jpV9fdZB3y6STYa/NbCKEPf604dtLQhK7o?=
 =?us-ascii?Q?GFKgcE/+vgyjYX4FLBW/vSw+WDqOPQRWcORUR+wUB6UH0+fG12pY1dN0ItA0?=
 =?us-ascii?Q?J+0REv8vbTSW1ZuL46CoE44JLweIg1Ze4i0BzDAwF+9KMeEP1IdMrDv3uHp5?=
 =?us-ascii?Q?nOzOjuc5ShQJXZz/6yz9/87QTrSqKN9b318jCpRuuxJDLCJUQBfndcqy+Jh2?=
 =?us-ascii?Q?5jNyKA6F63oDslHJ3j8uruvSpXBHbI3p+CuUI9npl2bB+H112KUI7xQ7V8vt?=
 =?us-ascii?Q?KGUsw=3D=3D?=
X-Microsoft-Exchange-Diagnostics: 1; DM5PR07MB3467;
 6:UPXXagH6JcLTA1E9al3Io9R0tsXaN56+YD1RGOJ3uMZPaC88+5hfNqcpsKdRU8d4yXD7ZogW4aZeuDNleVQOlHzqFjVcMmTFTkO+Pd3zWWHRpFaKWMIauW2AR8k+sLAlNMBMo/z4E2d0HoZuhgktAmuZK+IyiS1rUt19R0gejofyRCugWtKBmR6BcWLpZnrRJzJItDxr3dDvYsHx21JXL20nZp1OMlW9GiQcNAereRZVXIg/UH3U7ZVxpDzCeeG5/3X9EdmohP2mZVdUoID6dxdGKB9+GInYBTjU+UdlmuejGkAJLVjM4vkDLdcJxZYuzlJpGzge7rj0Y7aGGCtGN4oii5mGBSzlxzOynu3P3yE=;
 5:eWvreGgBqIQSm/jnjLNwG8/3Kruso7kkdvPB2uAbvIo1bpiQw4P/AtLS50iPf3uyNp2BTRxmvpiTyARtHHXyapXTkGo4TJuLL1c8gS1n0u8fzJd9L8eHXvUIf1gh4v7Ou25XiY1Q+bFTsq9dfDpB3f/N9L0wDMhYPg7gyqemBkw=;
 24:pjYRcUKu3f63W1XZnXbhCkE8Hw8rpHYpH52C1Cj+mmBDtSQOdk+QpHX6NJZPdJzikVkQTdeRP4m8L0QvYbltSg==;
 7:NGMuSoLKA2T41ls7RoH5DC7mKdgvdnE214fIGxz5D+KrUzwd0sl0+GhM/sLA/kinsU+VVJZvah0twMx4fj3jow8MNvW5aIw01YQW5WKj2rEX+/MtlHyAnhUxMWZXxQjvm6ibZKn5B1LeItcKnH0eqSKt+p1kOKQ3ehaiZGEINCfE9xpvz1M67DksU80lN1Zp7di3c2OZM4V8XU3odKdxPkBVg0FcdA8pE/GVgqYQrW19oGiIeKar2Br6vFTrfH+s
SpamDiagnosticOutput: 1:22
X-OriginatorOrg: caviumnetworks.com
X-MS-Exchange-CrossTenant-OriginalArrivalTime: 18 Dec 2017 21:45:24.3004 (UTC)
X-MS-Exchange-CrossTenant-Network-Message-Id: bebd8266-da86-425c-d404-08d54660a746
X-MS-Exchange-CrossTenant-FromEntityHeader: Hosted
X-MS-Exchange-CrossTenant-Id: 711e4ccf-2e9b-4bcf-a551-4094005b6194
X-MS-Exchange-Transport-CrossTenantHeadersStamped: DM5PR07MB3467
Subject: [dpdk-dev]  [PATCH v2 10/12] app/eventdev: add pipeline atq test
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://dpdk.org/ml/options/dev>,
 <mailto:dev-request@dpdk.org?subject=unsubscribe>
List-Archive: <http://dpdk.org/ml/archives/dev/>
List-Post: <mailto:dev@dpdk.org>
List-Help: <mailto:dev-request@dpdk.org?subject=help>
List-Subscribe: <https://dpdk.org/ml/listinfo/dev>,
 <mailto:dev-request@dpdk.org?subject=subscribe>
X-List-Received-Date: Mon, 18 Dec 2017 21:45:29 -0000

This is a pipeline test case that aims at testing the following with
``all types queue`` eventdev scheme.
1. Measure the end-to-end performance of an event dev with a ethernet dev.
2. Maintain packet ordering from Rx to Tx.

The atq queue test functions as same as ``pipeline_queue`` test.
The difference is, It uses, ``all type queue scheme`` instead of separate
queues for each stage and thus reduces the number of queues required to
realize the use case.

Note: The --prod_type_ethdev is mandatory for running the application.

Example command to run pipeline atq test:
sudo build/app/dpdk-test-eventdev -c 0xf -s 0x8 --vdev=event_sw0 -- \
--test=pipeline_atq --wlcore=1 --prod_type_ethdev --stlist=ao

Signed-off-by: Pavan Nikhilesh <pbhagavatula@caviumnetworks.com>
---
 app/test-eventdev/Makefile            |   1 +
 app/test-eventdev/test_pipeline_atq.c | 187 ++++++++++++++++++++++++++++++++++
 2 files changed, 188 insertions(+)
 create mode 100644 app/test-eventdev/test_pipeline_atq.c

diff --git a/app/test-eventdev/Makefile b/app/test-eventdev/Makefile
index 30bebfb2f..6e3e36fb8 100644
--- a/app/test-eventdev/Makefile
+++ b/app/test-eventdev/Makefile
@@ -53,5 +53,6 @@ SRCS-y += test_perf_atq.c
 
 SRCS-y += test_pipeline_common.c
 SRCS-y += test_pipeline_queue.c
+SRCS-y += test_pipeline_atq.c
 
 include $(RTE_SDK)/mk/rte.app.mk
diff --git a/app/test-eventdev/test_pipeline_atq.c b/app/test-eventdev/test_pipeline_atq.c
new file mode 100644
index 000000000..f625b04b1
--- /dev/null
+++ b/app/test-eventdev/test_pipeline_atq.c
@@ -0,0 +1,187 @@
+/*
+ *   BSD LICENSE
+ *
+ *   Copyright (C) Cavium, Inc 2017.
+ *
+ *   Redistribution and use in source and binary forms, with or without
+ *   modification, are permitted provided that the following conditions
+ *   are met:
+ *
+ *     * Redistributions of source code must retain the above copyright
+ *       notice, this list of conditions and the following disclaimer.
+ *     * Redistributions in binary form must reproduce the above copyright
+ *       notice, this list of conditions and the following disclaimer in
+ *       the documentation and/or other materials provided with the
+ *       distribution.
+ *     * Neither the name of Cavium, Inc nor the names of its
+ *       contributors may be used to endorse or promote products derived
+ *       from this software without specific prior written permission.
+ *
+ *   THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ *   "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
+ *   LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
+ *   A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
+ *   OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
+ *   SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
+ *   LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
+ *   DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
+ *   THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
+ *   (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
+ *   OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+#include "test_pipeline_common.h"
+
+/* See http://dpdk.org/doc/guides/tools/testeventdev.html for test details */
+
+static __rte_always_inline int
+pipeline_atq_nb_event_queues(struct evt_options *opt)
+{
+	uint16_t eth_count = rte_eth_dev_count();
+
+	return (eth_count * opt->nb_stages);
+}
+
+static int
+worker_wrapper(void *arg)
+{
+	RTE_SET_USED(arg);
+	rte_panic("invalid worker\n");
+}
+
+static int
+pipeline_atq_launch_lcores(struct evt_test *test, struct evt_options *opt)
+{
+	return pipeline_launch_lcores(test, opt, worker_wrapper);
+}
+
+static int
+pipeline_atq_eventdev_setup(struct evt_test *test, struct evt_options *opt)
+{
+	int ret;
+	int nb_ports;
+	int nb_queues;
+	int nb_stages = opt->nb_stages;
+	uint8_t queue;
+	struct rte_event_dev_info info;
+
+	nb_ports = evt_nr_active_lcores(opt->wlcores);
+	nb_queues = rte_eth_dev_count() * (nb_stages);
+
+	rte_event_dev_info_get(opt->dev_id, &info);
+
+	const struct rte_event_dev_config config = {
+			.nb_event_queues = nb_queues,
+			.nb_event_ports = nb_ports,
+			.nb_events_limit  = info.max_num_events,
+			.nb_event_queue_flows = opt->nb_flows,
+			.nb_event_port_dequeue_depth =
+				info.max_event_port_dequeue_depth,
+			.nb_event_port_enqueue_depth =
+				info.max_event_port_enqueue_depth,
+	};
+	ret = rte_event_dev_configure(opt->dev_id, &config);
+	if (ret) {
+		evt_err("failed to configure eventdev %d", opt->dev_id);
+		return ret;
+	}
+
+	struct rte_event_queue_conf q_conf = {
+			.priority = RTE_EVENT_DEV_PRIORITY_NORMAL,
+			.nb_atomic_flows = opt->nb_flows,
+			.nb_atomic_order_sequences = opt->nb_flows,
+	};
+	/* queue configurations */
+	for (queue = 0; queue < nb_queues; queue++) {
+		q_conf.event_queue_cfg = RTE_EVENT_QUEUE_CFG_ALL_TYPES;
+
+		ret = rte_event_queue_setup(opt->dev_id, queue, &q_conf);
+		if (ret) {
+			evt_err("failed to setup queue=%d", queue);
+			return ret;
+		}
+	}
+
+	/* port configuration */
+	const struct rte_event_port_conf p_conf = {
+			.dequeue_depth = opt->wkr_deq_dep,
+			.enqueue_depth = info.max_event_port_dequeue_depth,
+			.new_event_threshold = info.max_num_events,
+	};
+
+	ret = pipeline_event_port_setup(test, opt, nb_queues, p_conf);
+	if (ret)
+		return ret;
+
+	ret = pipeline_event_rx_adapter_setup(opt, nb_stages,
+			p_conf);
+	if (ret)
+		return ret;
+
+	if (!evt_has_distributed_sched(opt->dev_id)) {
+		uint32_t service_id;
+		rte_event_dev_service_id_get(opt->dev_id, &service_id);
+		ret = evt_service_setup(service_id);
+		if (ret) {
+			evt_err("No service lcore found to run event dev.");
+			return ret;
+		}
+	}
+
+	ret = rte_event_dev_start(opt->dev_id);
+	if (ret) {
+		evt_err("failed to start eventdev %d", opt->dev_id);
+		return ret;
+	}
+
+	return 0;
+}
+
+static void
+pipeline_atq_opt_dump(struct evt_options *opt)
+{
+	pipeline_opt_dump(opt, pipeline_atq_nb_event_queues(opt));
+}
+
+static int
+pipeline_atq_opt_check(struct evt_options *opt)
+{
+	return pipeline_opt_check(opt, pipeline_atq_nb_event_queues(opt));
+}
+
+static bool
+pipeline_atq_capability_check(struct evt_options *opt)
+{
+	struct rte_event_dev_info dev_info;
+
+	rte_event_dev_info_get(opt->dev_id, &dev_info);
+	if (dev_info.max_event_queues < pipeline_atq_nb_event_queues(opt) ||
+			dev_info.max_event_ports <
+			evt_nr_active_lcores(opt->wlcores)) {
+		evt_err("not enough eventdev queues=%d/%d or ports=%d/%d",
+			pipeline_atq_nb_event_queues(opt),
+			dev_info.max_event_queues,
+			evt_nr_active_lcores(opt->wlcores),
+			dev_info.max_event_ports);
+	}
+
+	return true;
+}
+
+static const struct evt_test_ops pipeline_atq =  {
+	.cap_check          = pipeline_atq_capability_check,
+	.opt_check          = pipeline_atq_opt_check,
+	.opt_dump           = pipeline_atq_opt_dump,
+	.test_setup         = pipeline_test_setup,
+	.mempool_setup      = pipeline_mempool_setup,
+	.ethdev_setup	    = pipeline_ethdev_setup,
+	.eventdev_setup     = pipeline_atq_eventdev_setup,
+	.launch_lcores      = pipeline_atq_launch_lcores,
+	.eventdev_destroy   = pipeline_eventdev_destroy,
+	.mempool_destroy    = pipeline_mempool_destroy,
+	.ethdev_destroy	    = pipeline_ethdev_destroy,
+	.test_result        = pipeline_test_result,
+	.test_destroy       = pipeline_test_destroy,
+};
+
+EVT_TEST_REGISTER(pipeline_atq);
-- 
2.14.1