From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id B74D1C43334 for ; Tue, 14 Jun 2022 14:37:22 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S236679AbiFNOhW (ORCPT ); Tue, 14 Jun 2022 10:37:22 -0400 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:59218 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S231584AbiFNOhV (ORCPT ); Tue, 14 Jun 2022 10:37:21 -0400 Received: from mail-wr1-x42f.google.com (mail-wr1-x42f.google.com [IPv6:2a00:1450:4864:20::42f]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 3AE5712625 for ; Tue, 14 Jun 2022 07:37:20 -0700 (PDT) Received: by mail-wr1-x42f.google.com with SMTP id q15so11535329wrc.11 for ; Tue, 14 Jun 2022 07:37:20 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20210112; h=from:to:cc:subject:date:message-id:in-reply-to:references :mime-version:content-transfer-encoding; bh=I/HN4gqc3ne5Wg/kirsMDgkzgQkt6tlEcJa4WcN66TU=; b=YDpvKfzk3DjJgnzscN6UpNvzkLSZRstZ9+qvgXxjb5W0+zcdYbb3axZUTngi6JKL0U L9nuD0mZqWwf6hFUyely+WT6dM/bi23Cn3Wcp/pl+tmPbH3s4tngxJuibmSi6NwGz2D9 qSDc1l3c3aTa09EuP515DF5UiUgTAHDk/3ylFQiZQN+6VbcxkUwlBIyhOlKn+cMIIVvC Liw03ia6Sj71xjgu9562/XGyaCZ2KjU9LbGV3JfHofys7DRJ6vSJIIOMcHp/3kretgWp 0dzNj9MAkPbuY+o/4/D6NDCoYMPzjLnm/kVvY5F32DxDOl2++ts5gg35wNIGKy5/Au09 zlFA== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=x-gm-message-state:from:to:cc:subject:date:message-id:in-reply-to :references:mime-version:content-transfer-encoding; bh=I/HN4gqc3ne5Wg/kirsMDgkzgQkt6tlEcJa4WcN66TU=; b=zYCbRFfQzkSKtBEsM9xNe5sTH02AskNbpare5yHcALAmGkfhunwMS30Wb+DjRaAtYk fTCPthOy7+xstC/bJZZZfX31qXT+XeJpHhRlVisxRoHvgJzAHEzBZDBEHT/WY6ljLk/t qwYHu9A1NKYUK0F3QjxuKF3v7C4Y9akNIRLa2qRP5Jh/fY5HIB9FYxFSqaKPUpnrWFjf FllR2WU0yNEQNHYXyN42JQN+MfUxE/JsKSMHeJDbTWSiGadFDGmNlTTmIaZU8Y06XNyf efnhoZFo4/To5o1TTFfNqtbylWX/M6rWth4grOyWTjEij5oLSEKYcXjSmqTLUB26O8kT fpjA== X-Gm-Message-State: AJIora99G9TmgCF4FEteTo9BUXWRdi6sgA8DVBoy18sOGCJ/KoHAgQQD qo9fAZDsybZCwWASq3TzwpVK5XAkbhcfmA== X-Google-Smtp-Source: AGRyM1uobIULCYvD8qZ4jXGwTV7JxAsI3m5WVWKIgmOJ8QVXdHVxmIC0s4S/nXzIrlfzZOPTFOZOGA== X-Received: by 2002:a05:6000:1acf:b0:218:5a30:9067 with SMTP id i15-20020a0560001acf00b002185a309067mr5372967wry.48.1655217438527; Tue, 14 Jun 2022 07:37:18 -0700 (PDT) Received: from 127.0.0.1localhost (188.28.125.106.threembb.co.uk. [188.28.125.106]) by smtp.gmail.com with ESMTPSA id f14-20020a5d58ee000000b0020fc6590a12sm12169254wrd.41.2022.06.14.07.37.17 (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Tue, 14 Jun 2022 07:37:18 -0700 (PDT) From: Pavel Begunkov To: io-uring@vger.kernel.org Cc: Jens Axboe , asml.silence@gmail.com Subject: [PATCH liburing 3/3] tests: test IORING_SETUP_SINGLE_ISSUER Date: Tue, 14 Jun 2022 15:36:33 +0100 Message-Id: <8d101e418097548d0d04de75c68996dfb6dabaa0.1655213733.git.asml.silence@gmail.com> X-Mailer: git-send-email 2.36.1 In-Reply-To: References: MIME-Version: 1.0 Content-Transfer-Encoding: 8bit Precedence: bulk List-ID: X-Mailing-List: io-uring@vger.kernel.org Signed-off-by: Pavel Begunkov --- test/Makefile | 1 + test/single-issuer.c | 173 +++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 174 insertions(+) create mode 100644 test/single-issuer.c diff --git a/test/Makefile b/test/Makefile index ab031e0..0750996 100644 --- a/test/Makefile +++ b/test/Makefile @@ -169,6 +169,7 @@ test_srcs := \ wakeup-hang.c \ xattr.c \ skip-cqe.c \ + single-issuer.c \ # EOL diff --git a/test/single-issuer.c b/test/single-issuer.c new file mode 100644 index 0000000..6d1b917 --- /dev/null +++ b/test/single-issuer.c @@ -0,0 +1,173 @@ +/* SPDX-License-Identifier: MIT */ +/* + * Description: run various nop tests + * + */ +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#include "liburing.h" +#include "test.h" + +static pid_t pid; + +static pid_t fork_t(void) +{ + pid = fork(); + if (pid == -1) { + fprintf(stderr, "fork failed\n"); + exit(1); + } + return pid; +} + +static int wait_child_t(void) +{ + int wstatus; + + if (waitpid(pid, &wstatus, 0) == (pid_t)-1) { + perror("waitpid()"); + exit(1); + } + if (!WIFEXITED(wstatus)) { + fprintf(stderr, "child failed %i\n", WEXITSTATUS(wstatus)); + exit(1); + } + + return WEXITSTATUS(wstatus); +} + +static int try_submit(struct io_uring *ring) +{ + struct io_uring_cqe *cqe; + struct io_uring_sqe *sqe; + int ret; + + sqe = io_uring_get_sqe(ring); + io_uring_prep_nop(sqe); + sqe->user_data = 42; + + ret = io_uring_submit(ring); + if (ret < 0) + return ret; + + if (ret != 1) + error(1, ret, "submit %i", ret); + ret = io_uring_wait_cqe(ring, &cqe); + if (ret) + error(1, ret, "wait fail %i", ret); + + if (cqe->res || cqe->user_data != 42) + error(1, ret, "invalid cqe"); + + io_uring_cqe_seen(ring, cqe); + return 0; +} + +int main(int argc, char *argv[]) +{ + struct io_uring ring; + int ret; + + if (argc > 1) + return 0; + + ret = io_uring_queue_init(8, &ring, IORING_SETUP_SINGLE_ISSUER); + if (ret == -EINVAL) { + fprintf(stderr, "SETUP_SINGLE_ISSUER is not supported, skip\n"); + return 0; + } else if (ret) { + error(1, ret, "ring init (1) %i", ret); + } + + /* test that the creator iw allowed to submit */ + ret = try_submit(&ring); + if (ret) { + fprintf(stderr, "the creater can't submit %i\n", ret); + return 1; + } + + /* test that a second submitter doesn't succeed */ + if (!fork_t()) { + ret = try_submit(&ring); + if (ret != -EEXIST) { + fprintf(stderr, "not owner child could submit %i\n", ret); + exit(1); + } + exit(0); + } else { + if (wait_child_t()) + return 1; + } + io_uring_queue_exit(&ring); + + + /* test that the first submitter but not creator can submit */ + ret = io_uring_queue_init(8, &ring, IORING_SETUP_SINGLE_ISSUER); + if (ret) + error(1, ret, "ring init (2) %i", ret); + + if (!fork_t()) { + ret = try_submit(&ring); + if (ret) { + fprintf(stderr, "not owner child could submit %i\n", ret); + exit(1); + } + exit(0); + } else { + if (wait_child_t()) + return 1; + } + io_uring_queue_exit(&ring); + + /* test that anyone can submit to a SQPOLL|SINGLE_ISSUER ring */ + ret = io_uring_queue_init(8, &ring, IORING_SETUP_SINGLE_ISSUER|IORING_SETUP_SQPOLL); + if (ret) + error(1, ret, "ring init (3) %i", ret); + + ret = try_submit(&ring); + if (ret) { + fprintf(stderr, "SQPOLL submit failed (creator) %i\n", ret); + exit(1); + } + + if (!fork_t()) { + ret = try_submit(&ring); + if (ret) { + fprintf(stderr, "SQPOLL submit failed (child) %i\n", ret); + exit(1); + } + exit(0); + } else { + if (wait_child_t()) + return 1; + } + io_uring_queue_exit(&ring); + + /* test that IORING_ENTER_REGISTERED_RING doesn't break anything */ + ret = io_uring_queue_init(8, &ring, IORING_SETUP_SINGLE_ISSUER); + if (ret) + error(1, ret, "ring init (4) %i", ret); + + if (!fork_t()) { + ret = try_submit(&ring); + if (ret) { + fprintf(stderr, "not owner child could submit %i\n", ret); + exit(1); + } + exit(0); + } else { + if (wait_child_t()) + return 1; + } + io_uring_queue_exit(&ring); + + return 0; +} -- 2.36.1 From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: X-Spam-Checker-Version: SpamAssassin 3.4.0 (2014-02-07) on aws-us-west-2-korg-lkml-1.web.codeaurora.org Received: from vger.kernel.org (vger.kernel.org [23.128.96.18]) by smtp.lore.kernel.org (Postfix) with ESMTP id B45C7C43334 for ; Wed, 15 Jun 2022 10:05:48 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S242154AbiFOKFs (ORCPT ); Wed, 15 Jun 2022 06:05:48 -0400 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:49898 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S238275AbiFOKFr (ORCPT ); Wed, 15 Jun 2022 06:05:47 -0400 Received: from mail-wr1-x434.google.com (mail-wr1-x434.google.com [IPv6:2a00:1450:4864:20::434]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 9F7BB3BF8D for ; Wed, 15 Jun 2022 03:05:46 -0700 (PDT) Received: by mail-wr1-x434.google.com with SMTP id o8so14673008wro.3 for ; Wed, 15 Jun 2022 03:05:46 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20210112; h=from:to:cc:subject:date:message-id:in-reply-to:references :mime-version:content-transfer-encoding; bh=I/HN4gqc3ne5Wg/kirsMDgkzgQkt6tlEcJa4WcN66TU=; b=GOogrPWXBTvGOVo4ofqSM9Xu2rhQo1rZoJ04/IGZLrbXhxDhI8Z+VBUFuzxUCIaJkf k+HGr4q/A50Yks7xTprn8r8Y7YwJiMmn8BlxTV90c7ZyHQOcch8cpYk6hTbCfabIzVi6 enkAfIIczWeH7xtSrX4o+pJ7GIlb8FwCMp2z4y1DwUDJJP/WSu+AZv7miO00ENS08Z// c9MjJWGEQKxxSoNyd3p3MY0rGMr1u9UpDerApi3tBW8aCgD6RoH7sUJbO3BlzKErTu02 38gAraXQHbh9axUp//JwY08rckkJdo9x7tOrSI7tZNL1onSH29p8S+udIvF4YzKL1yIk O+gQ== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20210112; h=x-gm-message-state:from:to:cc:subject:date:message-id:in-reply-to :references:mime-version:content-transfer-encoding; bh=I/HN4gqc3ne5Wg/kirsMDgkzgQkt6tlEcJa4WcN66TU=; b=0RnzX7cqy7RDGdWlbZe8yV7tiBzWcz4EEK4t8F0Ldc0WG71XWFOQ3eGrAPm49mCkUT 9T+c/g6p0BccBEvZBE1B5ppaT4zCEUMRHAxtWFHSA59GkOSjCqyPUhhTlE7eqAtM5TyZ 0PdHD67vZKJXvKv+XoBvof0stO/huetfL9kBzhIUWxSTEVSUvuHNYTPJECgtrNo19MdK xo3oHRGrkUX5t5/IFdp9Cr9wr7F2z5Ccv42fN1xzKd+1l+WHsUH44kQkyxtMvR1QVshm EL5IkSorPd6o2bOU4FYzr5YWUnzdivSTiKVMYQvXTIxyXXW7OEN8AffXDtQdD+Ftvxos dBaA== X-Gm-Message-State: AJIora/xBI2PH8tMTj3by2auHTPptGMunf4dCrXcfX4qLPf3XQWAC7Sn GMmb9bkKjcK9Bgsk5gRHpevwR0ntH5n4Uw== X-Google-Smtp-Source: AGRyM1sfM7x5LtF5LTPeyzqQ7ZkQKWSnAR3w7O2XF6Wt4/vHORGwtApCFVS77dNqXRA9GuHzFsHXwA== X-Received: by 2002:adf:eac8:0:b0:21a:271e:3d97 with SMTP id o8-20020adfeac8000000b0021a271e3d97mr3468492wrn.450.1655287544672; Wed, 15 Jun 2022 03:05:44 -0700 (PDT) Received: from 127.0.0.1localhost (188.28.125.106.threembb.co.uk. [188.28.125.106]) by smtp.gmail.com with ESMTPSA id w5-20020a5d6805000000b002119c1a03e4sm14074984wru.31.2022.06.15.03.05.43 (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Wed, 15 Jun 2022 03:05:44 -0700 (PDT) From: Pavel Begunkov To: io-uring@vger.kernel.org Cc: Jens Axboe , asml.silence@gmail.com Subject: [PATCH liburing 3/3] tests: test IORING_SETUP_SINGLE_ISSUER Date: Wed, 15 Jun 2022 11:05:12 +0100 Message-ID: <8d101e418097548d0d04de75c68996dfb6dabaa0.1655213733.git.asml.silence@gmail.com> X-Mailer: git-send-email 2.36.1 In-Reply-To: References: MIME-Version: 1.0 Content-Transfer-Encoding: 8bit Precedence: bulk List-ID: X-Mailing-List: io-uring@vger.kernel.org Message-ID: <20220615100512.Jrg8Fr0ibl4n0kUn_uMSAWMT8gFPEZ3cM4HfUVj46fE@z> Signed-off-by: Pavel Begunkov --- test/Makefile | 1 + test/single-issuer.c | 173 +++++++++++++++++++++++++++++++++++++++++++ 2 files changed, 174 insertions(+) create mode 100644 test/single-issuer.c diff --git a/test/Makefile b/test/Makefile index ab031e0..0750996 100644 --- a/test/Makefile +++ b/test/Makefile @@ -169,6 +169,7 @@ test_srcs := \ wakeup-hang.c \ xattr.c \ skip-cqe.c \ + single-issuer.c \ # EOL diff --git a/test/single-issuer.c b/test/single-issuer.c new file mode 100644 index 0000000..6d1b917 --- /dev/null +++ b/test/single-issuer.c @@ -0,0 +1,173 @@ +/* SPDX-License-Identifier: MIT */ +/* + * Description: run various nop tests + * + */ +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#include "liburing.h" +#include "test.h" + +static pid_t pid; + +static pid_t fork_t(void) +{ + pid = fork(); + if (pid == -1) { + fprintf(stderr, "fork failed\n"); + exit(1); + } + return pid; +} + +static int wait_child_t(void) +{ + int wstatus; + + if (waitpid(pid, &wstatus, 0) == (pid_t)-1) { + perror("waitpid()"); + exit(1); + } + if (!WIFEXITED(wstatus)) { + fprintf(stderr, "child failed %i\n", WEXITSTATUS(wstatus)); + exit(1); + } + + return WEXITSTATUS(wstatus); +} + +static int try_submit(struct io_uring *ring) +{ + struct io_uring_cqe *cqe; + struct io_uring_sqe *sqe; + int ret; + + sqe = io_uring_get_sqe(ring); + io_uring_prep_nop(sqe); + sqe->user_data = 42; + + ret = io_uring_submit(ring); + if (ret < 0) + return ret; + + if (ret != 1) + error(1, ret, "submit %i", ret); + ret = io_uring_wait_cqe(ring, &cqe); + if (ret) + error(1, ret, "wait fail %i", ret); + + if (cqe->res || cqe->user_data != 42) + error(1, ret, "invalid cqe"); + + io_uring_cqe_seen(ring, cqe); + return 0; +} + +int main(int argc, char *argv[]) +{ + struct io_uring ring; + int ret; + + if (argc > 1) + return 0; + + ret = io_uring_queue_init(8, &ring, IORING_SETUP_SINGLE_ISSUER); + if (ret == -EINVAL) { + fprintf(stderr, "SETUP_SINGLE_ISSUER is not supported, skip\n"); + return 0; + } else if (ret) { + error(1, ret, "ring init (1) %i", ret); + } + + /* test that the creator iw allowed to submit */ + ret = try_submit(&ring); + if (ret) { + fprintf(stderr, "the creater can't submit %i\n", ret); + return 1; + } + + /* test that a second submitter doesn't succeed */ + if (!fork_t()) { + ret = try_submit(&ring); + if (ret != -EEXIST) { + fprintf(stderr, "not owner child could submit %i\n", ret); + exit(1); + } + exit(0); + } else { + if (wait_child_t()) + return 1; + } + io_uring_queue_exit(&ring); + + + /* test that the first submitter but not creator can submit */ + ret = io_uring_queue_init(8, &ring, IORING_SETUP_SINGLE_ISSUER); + if (ret) + error(1, ret, "ring init (2) %i", ret); + + if (!fork_t()) { + ret = try_submit(&ring); + if (ret) { + fprintf(stderr, "not owner child could submit %i\n", ret); + exit(1); + } + exit(0); + } else { + if (wait_child_t()) + return 1; + } + io_uring_queue_exit(&ring); + + /* test that anyone can submit to a SQPOLL|SINGLE_ISSUER ring */ + ret = io_uring_queue_init(8, &ring, IORING_SETUP_SINGLE_ISSUER|IORING_SETUP_SQPOLL); + if (ret) + error(1, ret, "ring init (3) %i", ret); + + ret = try_submit(&ring); + if (ret) { + fprintf(stderr, "SQPOLL submit failed (creator) %i\n", ret); + exit(1); + } + + if (!fork_t()) { + ret = try_submit(&ring); + if (ret) { + fprintf(stderr, "SQPOLL submit failed (child) %i\n", ret); + exit(1); + } + exit(0); + } else { + if (wait_child_t()) + return 1; + } + io_uring_queue_exit(&ring); + + /* test that IORING_ENTER_REGISTERED_RING doesn't break anything */ + ret = io_uring_queue_init(8, &ring, IORING_SETUP_SINGLE_ISSUER); + if (ret) + error(1, ret, "ring init (4) %i", ret); + + if (!fork_t()) { + ret = try_submit(&ring); + if (ret) { + fprintf(stderr, "not owner child could submit %i\n", ret); + exit(1); + } + exit(0); + } else { + if (wait_child_t()) + return 1; + } + io_uring_queue_exit(&ring); + + return 0; +} -- 2.36.1