From nobody Wed Jul 1 04:16:15 2026 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 ECDEAC433EF for ; Thu, 30 Dec 2021 17:50:54 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S241523AbhL3Ruw (ORCPT ); Thu, 30 Dec 2021 12:50:52 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:55638 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S241512AbhL3Rus (ORCPT ); Thu, 30 Dec 2021 12:50:48 -0500 Received: from mail-pf1-x42b.google.com (mail-pf1-x42b.google.com [IPv6:2607:f8b0:4864:20::42b]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 3136FC06173E; Thu, 30 Dec 2021 09:50:48 -0800 (PST) Received: by mail-pf1-x42b.google.com with SMTP id t187so8403269pfb.11; Thu, 30 Dec 2021 09:50:48 -0800 (PST) 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=1m6Du5I3sa+4N+2VoevH+uREnRI1E6Wc5yP36akl1eY=; b=pEisFIYwefZLbMyOQ/5Nx7FSZTKrg4rIkMrI0cCA2Lr6PEbPWuXnO+xXbEukCLm506 UmU6w9TGGQUqkoBpRNi/9/lyfaaGizs+XsBEf2zTCwqqax5/k9wGGDwEf+AsLDoABrFl wdFCa1wkc5xAXR+gc1fUBbx6aIHexBPo/dMwmVYM3+ZcZFYAOEYdp5b4odFx6V1BJcVi 0u8+yfzuaVk/7U4kwSfTOEH67RF7wPLBAL1CRW7mkRgQfR4Ktzs7vMUyg7vkvBTpgrxd qOuKX3Zorj3Qrw1UlDTKwxeooguq6jYASx5EC6jluiYXYhtkRIFDGajU3rHWefWtw4KV Hd0Q== 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=1m6Du5I3sa+4N+2VoevH+uREnRI1E6Wc5yP36akl1eY=; b=ko51e/VnJFwy5Clk5HNxjP7npwoKxfLspStsreEqa2mvMqBjWyvKqgButkRPNDCsYL s5+OkQZTe6Nt5ldtW69vCHDFUEPpLb+WadaJ5t2+4grW4NvWyLINNofy5bHjsCmc2StX QW0I5bZ5kgETkvPNGOmRuUqIwxNxJ1EcSQ1LCTWnryQsVenV/5BJjTphfzRafnC3lxAx bWdeCwAfUSeP15W27kHBKCFjqrS+vS1uoKG+6DCHqYRdHIjgvWmzo7uzt5tLv0peVrOQ i9oXKjG6ogQaKyZENyxJdM6d8djJRCOXQJ2Spucsfx4djhRowoQjCew2QL3D91i9KdiK Yq9Q== X-Gm-Message-State: AOAM531vCeMqqFgdF1fgbTgU+6Z1GbsNgZ8P4CqaXJ+LYtSMPecVtB9T PIay+PmIeEQaE8ibpgdhkaeSsvzchsv9lA== X-Google-Smtp-Source: ABdhPJwkvyxU931dzrg7RRwBTSQVlzAlI2cjM3RJsqdv2NiibgxE1aricgJuLd6a1esGf18TVGOdXA== X-Received: by 2002:a05:6a00:2391:b0:4a2:cb64:2e01 with SMTP id f17-20020a056a00239100b004a2cb642e01mr32644900pfc.45.1640886647795; Thu, 30 Dec 2021 09:50:47 -0800 (PST) Received: from integral2.. ([180.254.126.2]) by smtp.gmail.com with ESMTPSA id s34sm29980811pfg.198.2021.12.30.09.50.44 (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Thu, 30 Dec 2021 09:50:47 -0800 (PST) From: Ammar Faizi To: Jens Axboe Cc: io-uring Mailing List , Pavel Begunkov , "David S . Miller" , Jakub Kicinski , netdev@vger.kernel.org, linux-kernel@vger.kernel.org, Ammar Faizi , Nugra Subject: [RFC PATCH liburing v1 1/5] .gitignore: Add `/test/xattr` and `/test/getdents` Date: Fri, 31 Dec 2021 00:50:15 +0700 Message-Id: <20211230174548.178641-2-ammar.faizi@intel.com> X-Mailer: git-send-email 2.32.0 In-Reply-To: <20211230174548.178641-1-ammar.faizi@intel.com> References: <20211230174548.178641-1-ammar.faizi@intel.com> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Type: text/plain; charset="utf-8" When Stefan added these two tests, he forgot to add them to the .gitignore. Add them. Signed-off-by: Ammar Faizi --- .gitignore | 2 ++ 1 file changed, 2 insertions(+) diff --git a/.gitignore b/.gitignore index 0a72f03..4e70f20 100644 --- a/.gitignore +++ b/.gitignore @@ -60,6 +60,7 @@ /test/files-exit-hang-timeout /test/fixed-link /test/fsync +/test/getdents /test/hardlink /test/io-cancel /test/io_uring_enter @@ -133,6 +134,7 @@ /test/submit-link-fail /test/exec-target /test/skip-cqe +/test/xattr /test/*.dmesg /test/output/ =20 --=20 2.32.0 From nobody Wed Jul 1 04:16:15 2026 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 F2188C433FE for ; Thu, 30 Dec 2021 17:50:56 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S241536AbhL3Rux (ORCPT ); Thu, 30 Dec 2021 12:50:53 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:55650 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S241518AbhL3Ruv (ORCPT ); Thu, 30 Dec 2021 12:50:51 -0500 Received: from mail-pf1-x430.google.com (mail-pf1-x430.google.com [IPv6:2607:f8b0:4864:20::430]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id C9E75C061574; Thu, 30 Dec 2021 09:50:51 -0800 (PST) Received: by mail-pf1-x430.google.com with SMTP id v13so21925179pfi.3; Thu, 30 Dec 2021 09:50:51 -0800 (PST) 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=8lod7fnVTBJHDQ4ufvLD8YBxdSNhFnY3bwtUaLmQ5+Y=; b=UsIw9MUXjcU60imQnPacUzRcXxSrChCUhx3tGsYqFpu+UvG4kXj+9Ncls/O7R/lvVO aCL47nsw2k76rzIP6KNNh3XhD/uTk/TJeNm9z027nLNvfOQRi89JVyIJEoBSJWiCTEoO dyjPVtE+pG86zh75tOJKHpm6f6DzeubiP/wVU5IsCl9fsPRAvv3xA6iPzTC4+DCnizq2 lK5IM5mDXzqKFddrp1p3hicTZzpcuUmgFR6DkRWP0YghciT7rwC80voeV24RvkyyJvpk 9m+8G5TPgkvTlMcqQtQ4d0fHF15LaFTMpQeczw1Ub2RoNEhX5DSV11fYcwBZhdbDkI+o X/rA== 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=8lod7fnVTBJHDQ4ufvLD8YBxdSNhFnY3bwtUaLmQ5+Y=; b=z7jEBMhb/pW9KBZ6/PYCrZ+b2xA/90Ri62UnEIyx4DGKihsV0sGXd6cheUr2/sUGuU 2X88FyaFMwv4dZ3B1t5TYc3v2cn31UolXEhJ82mNZHS38DUeZ/ZxnK6cL1DuALIpXVL/ w22t4a5YwvVBEB002MVVszElk79j6m8OWiDg+V0SvZkB3mDNDKHX7Yo0ZA7j5kv8k4D2 +uYOwumKe1UDmCgbhfVgczxQFu++di5qGIvtr/VSkHgkcXrNvGE9x6dK5rBddn+aFhNP w5IZ1zmJTqA2OrIUNDjP/wGXoRExCpL8hIeILPv3KYNw2VmgH42iLMmhwwv8R/HOS9Qf 9wZw== X-Gm-Message-State: AOAM530imAsmlUeNioktgsg4uTfj3IzIN7kNWiF8kOR9G/+IDmSjZpIe qI6UNn9Qy8gU8LqWD5OlPZKrHEfhN3tXag== X-Google-Smtp-Source: ABdhPJwtlzh7IbZExWB+yWgyqNpkT4IiBsPNnZ0BhtS3N8rJLaG6DG/TjKVDtDlWNIjLcCiRPf3bLA== X-Received: by 2002:a05:6a00:1311:b0:4ba:1288:67dc with SMTP id j17-20020a056a00131100b004ba128867dcmr32466272pfu.43.1640886651442; Thu, 30 Dec 2021 09:50:51 -0800 (PST) Received: from integral2.. ([180.254.126.2]) by smtp.gmail.com with ESMTPSA id s34sm29980811pfg.198.2021.12.30.09.50.48 (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Thu, 30 Dec 2021 09:50:51 -0800 (PST) From: Ammar Faizi To: Jens Axboe Cc: io-uring Mailing List , Pavel Begunkov , "David S . Miller" , Jakub Kicinski , netdev@vger.kernel.org, linux-kernel@vger.kernel.org, Ammar Faizi , Nugra Subject: [RFC PATCH liburing v1 2/5] io_uring.h: Add `IORING_OP_SENDTO` and `IORING_OP_RECVFROM` Date: Fri, 31 Dec 2021 00:50:16 +0700 Message-Id: <20211230174548.178641-3-ammar.faizi@intel.com> X-Mailer: git-send-email 2.32.0 In-Reply-To: <20211230174548.178641-1-ammar.faizi@intel.com> References: <20211230174548.178641-1-ammar.faizi@intel.com> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Type: text/plain; charset="utf-8" Sync with the kernel to support for `sendto(2)` and `recvfrom(2)`, this adds those two new opcodes. Signed-off-by: Ammar Faizi --- src/include/liburing/io_uring.h | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/include/liburing/io_uring.h b/src/include/liburing/io_urin= g.h index 9d8c7f9..47038f6 100644 --- a/src/include/liburing/io_uring.h +++ b/src/include/liburing/io_uring.h @@ -154,6 +154,8 @@ enum { IORING_OP_SETXATTR, IORING_OP_FGETXATTR, IORING_OP_GETXATTR, + IORING_OP_SENDTO, + IORING_OP_RECVFROM, =20 /* this goes last, obviously */ IORING_OP_LAST, --=20 2.32.0 From nobody Wed Jul 1 04:16:15 2026 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 7F9A8C4332F for ; Thu, 30 Dec 2021 17:51:00 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S241553AbhL3Ru7 (ORCPT ); Thu, 30 Dec 2021 12:50:59 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:55676 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S241524AbhL3Ruz (ORCPT ); Thu, 30 Dec 2021 12:50:55 -0500 Received: from mail-pl1-x636.google.com (mail-pl1-x636.google.com [IPv6:2607:f8b0:4864:20::636]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 7111BC06173F; Thu, 30 Dec 2021 09:50:55 -0800 (PST) Received: by mail-pl1-x636.google.com with SMTP id l15so3914548pls.7; Thu, 30 Dec 2021 09:50:55 -0800 (PST) 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=Vh9k3yzpWTJ0rz/QUtXD9eGCZU6BoOLDd0nqDuasgMs=; b=bLC7LU9IFRr8T9IhR8t7RD6GE/pLGh3Myyxff7R5nr7+oWdYtvx9Z3/5FjoW7mwvmm heWdTjyaLnM3SEt6/u1L/0Ds90tJo5y/m6EJDNoJWlhLTameWVCRPxu7U0mB8lMjXtTS aSh655R7ZroX8YfoYjAXMohOBekLJZAYtbc7mJ8DNai5t3cEcRKELkOUdcup7d3xsXYa 7mqy1YRMFjDLTdF+GoxcnO0NBaD0MOoKooiZwDMOFAvLwfQYbcTj+TvGAKYIBYlyjwac shyV80uMigZz6DM1OGwNd0KXIj4E8jsGFONsq2thlA7vMzO5RoO0Cl5j3U27TP8BlWFK Q9+A== 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=Vh9k3yzpWTJ0rz/QUtXD9eGCZU6BoOLDd0nqDuasgMs=; b=r5XFRiMavZMOLBONhg1AIyuLu9RS4z5AK2MrSbpVQrDvvDevjS9iYiJzcSqw24NP7q xOYvvH8KumgcagGJkrfncLvPWcZCm5p8dYvOVldw1OIBvOCiAjs4IN+KlCMTtHhpFp6u ZSwwuhliMStkLaakwX4h7+xGFd7fHCStKNDKiEnKRC/99Snh77rTL/sxhMTbZ1Zz+B5B oJ5fHZHqxU5ht2IhXYYIuIulkhOzGBSaWfznMCAoNRCrePQZOrge4bTni7IHyG6V2+QO 7FSu8KiSgm7m6JIQ2JSyCFVGhrRfSGtcfIj+bilUnZahE55lMgZ678EZ0y2D6fkdXSMK hwQQ== X-Gm-Message-State: AOAM533/8Hz4Lp+zYW2RB44Iyb5j0kQXRFdWWTNpXhvpo4XQV/ARISFE xk/6dJvdh4W1aWE7GqtoL8I= X-Google-Smtp-Source: ABdhPJycF9EoJav//XmpcGCl0ufu0e9LGgtjczpWifWk4k6AKFQ3x3mPSGZiHVdVw5YHjYQd/pgzvQ== X-Received: by 2002:a17:903:2307:b0:149:1bb6:fc28 with SMTP id d7-20020a170903230700b001491bb6fc28mr31692856plh.84.1640886655039; Thu, 30 Dec 2021 09:50:55 -0800 (PST) Received: from integral2.. ([180.254.126.2]) by smtp.gmail.com with ESMTPSA id s34sm29980811pfg.198.2021.12.30.09.50.51 (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Thu, 30 Dec 2021 09:50:54 -0800 (PST) From: Ammar Faizi To: Jens Axboe Cc: io-uring Mailing List , Pavel Begunkov , "David S . Miller" , Jakub Kicinski , netdev@vger.kernel.org, linux-kernel@vger.kernel.org, Ammar Faizi , Nugra Subject: [RFC PATCH liburing v1 3/5] liburing.h: Add `io_uring_prep_{sendto,sendto}` helper Date: Fri, 31 Dec 2021 00:50:17 +0700 Message-Id: <20211230174548.178641-4-ammar.faizi@intel.com> X-Mailer: git-send-email 2.32.0 In-Reply-To: <20211230174548.178641-1-ammar.faizi@intel.com> References: <20211230174548.178641-1-ammar.faizi@intel.com> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Type: text/plain; charset="utf-8" This adds IORING_OP_SENDTO and IORING_OP_RECVFROM prep helper. Signed-off-by: Ammar Faizi --- src/include/liburing.h | 22 ++++++++++++++++++++++ 1 file changed, 22 insertions(+) diff --git a/src/include/liburing.h b/src/include/liburing.h index a36d3f6..c22e69c 100644 --- a/src/include/liburing.h +++ b/src/include/liburing.h @@ -750,6 +750,28 @@ static inline void io_uring_prep_fsetxattr(struct io_u= ring_sqe *sqe, sqe->xattr_flags =3D flags; } =20 +static inline void io_uring_prep_sendto(struct io_uring_sqe *sqe, int sock= fd, + const void *buf, size_t len, int flags, + const struct sockaddr *dest_addr, + socklen_t addrlen) +{ + io_uring_prep_rw(IORING_OP_SENDTO, sqe, sockfd, buf, (__u32) len, 0); + sqe->msg_flags =3D (__u32) flags; + sqe->addr2 =3D (__u64) (uintptr_t) dest_addr; + sqe->addr3 =3D (__u64) addrlen; +} + +static inline void io_uring_prep_recvfrom(struct io_uring_sqe *sqe, int so= ckfd, + void *buf, size_t len, int flags, + struct sockaddr *src_addr, + socklen_t *addrlen) +{ + io_uring_prep_rw(IORING_OP_RECVFROM, sqe, sockfd, buf, (__u32) len, 0); + sqe->msg_flags =3D (__u32) flags; + sqe->addr2 =3D (__u64) (uintptr_t) src_addr; + sqe->addr3 =3D (__u64) (uintptr_t) addrlen; +} + /* * Returns number of unconsumed (if SQPOLL) or unsubmitted entries exist in * the SQ ring --=20 2.32.0 From nobody Wed Jul 1 04:16:15 2026 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 04978C4332F for ; Thu, 30 Dec 2021 17:51:05 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S241574AbhL3RvD (ORCPT ); Thu, 30 Dec 2021 12:51:03 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:55714 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S241558AbhL3RvA (ORCPT ); Thu, 30 Dec 2021 12:51:00 -0500 Received: from mail-pg1-x532.google.com (mail-pg1-x532.google.com [IPv6:2607:f8b0:4864:20::532]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 5F9F1C061756; Thu, 30 Dec 2021 09:50:59 -0800 (PST) Received: by mail-pg1-x532.google.com with SMTP id a23so22032037pgm.4; Thu, 30 Dec 2021 09:50:59 -0800 (PST) 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=Fz9vy7/aGEiUYf9pqOatTXUfbGE4vFMqOfv+wqNuBPo=; b=OFK7K3bj8a71PfLQC3FaToXZ19PqrSd9Wdr4xXqeXO4H03WV1QPDdoC/iL2Z9EUCc2 VRhoSQbngfAZg1zPYGJYY2NQlF28qZ6sMdI/aqD9OdAT3Noy5howVHkOaJiUoPl4qI+g y/Tg3uh1LLB16ApzIA2j5sNi/1qSBcFsFWak/rHSusv13hyuyqIQfbinyIe4V6WB33wo Z5nBDdiG5SiAHSH1iMpFt4giCdppWYnV6Il+k472IEIUvV07dD12coCU1jAHJqkvyqK3 fLCOk2eoK8PfZk5Hu2d6j1VOMLmFFy4W/hOWBWz7zp1ibqoTqfNTKXgzUXOwu6YwWhM6 uzLQ== 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=Fz9vy7/aGEiUYf9pqOatTXUfbGE4vFMqOfv+wqNuBPo=; b=PQ1QDGC29VT3srnbPNb+FziLgbVBoZZSyr6ageO1Py8WZvTFLW3s4lt58p06KEDj1+ UeOPqgqX/d3k7FLGJSBgETAgGtzvhreR0aTtyBBoRjDHwwat+J4TpqTGlVxKjd5JznAU cn2SoUEEhKYUSxgLLinrDrU/gCS6INqDvwisQ8nhXGYSxMI/uAc/ilSmGJjTEQ5fpTTX Sk4mvbZBeOsGGIHUcfq9DlN/lA4kDDpGeUxhghxAc17zO888U3kgcFSlbzHhsXW6cQpD cqgiqj80pvKg3w7uMulMQKx2ab0VO5+9vvitr5tw3JwhP5vvYq44hBp/3kNTTPWCy7ix AUeg== X-Gm-Message-State: AOAM531ouBSUShLDp7AC4K6gTJFfbbVDlCvOjdobnvzaDaO04IMeAWrC zAnT5d/mCyWpYO3RIYZV6UKbLhnQhiGj/g== X-Google-Smtp-Source: ABdhPJyUawROy3Zq8oZLjL8lgxurbqWkGAZ0xYzp6dEmZar09jXrcHGL1AW65InF086NVhXjWIaBcQ== X-Received: by 2002:a62:b503:0:b0:4bc:1f47:3b26 with SMTP id y3-20020a62b503000000b004bc1f473b26mr12460162pfe.9.1640886658858; Thu, 30 Dec 2021 09:50:58 -0800 (PST) Received: from integral2.. ([180.254.126.2]) by smtp.gmail.com with ESMTPSA id s34sm29980811pfg.198.2021.12.30.09.50.55 (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Thu, 30 Dec 2021 09:50:58 -0800 (PST) From: Ammar Faizi To: Jens Axboe Cc: io-uring Mailing List , Pavel Begunkov , "David S . Miller" , Jakub Kicinski , netdev@vger.kernel.org, linux-kernel@vger.kernel.org, Ammar Faizi , Nugra Subject: [RFC PATCH liburing v1 4/5] test: Add sendto_recvfrom test program Date: Fri, 31 Dec 2021 00:50:18 +0700 Message-Id: <20211230174548.178641-5-ammar.faizi@intel.com> X-Mailer: git-send-email 2.32.0 In-Reply-To: <20211230174548.178641-1-ammar.faizi@intel.com> References: <20211230174548.178641-1-ammar.faizi@intel.com> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Type: text/plain; charset="utf-8" Add a test program for `IORING_OP_SENDTO` and `IORING_OP_RECVFROM`. This test is based on `send_recv` test. Additional thing that needs extra attention here is that `sendto` and `recvfrom` can specify explicit destination and source. Apart from that, it is exactly the same with `send` and `recv`, but with 5-th and 6-th argument be zero. IOW: `recv(sockfd, buf, len, flags)` call is equivalent to: `recvfrom(sockfd, buf, len, flags, NULL, NULL)` call. And `send(sockfd, buf, len, flags)` call is equivalent to: `sendto(sockfd, buf, len, flags, NULL, 0)` call. Tested-by: Nugra Signed-off-by: Ammar Faizi --- .gitignore | 1 + test/Makefile | 2 + test/sendto_recvfrom.c | 384 +++++++++++++++++++++++++++++++++++++++++ 3 files changed, 387 insertions(+) create mode 100644 test/sendto_recvfrom.c diff --git a/.gitignore b/.gitignore index 4e70f20..6fe0df2 100644 --- a/.gitignore +++ b/.gitignore @@ -98,6 +98,7 @@ /test/send_recv /test/send_recvmsg /test/sendmsg_fs_cve +/test/sendto_recvfrom /test/shared-wq /test/short-read /test/shutdown diff --git a/test/Makefile b/test/Makefile index 357c9f7..48c8182 100644 --- a/test/Makefile +++ b/test/Makefile @@ -118,6 +118,7 @@ test_srcs :=3D \ rw_merge_test.c \ self.c \ sendmsg_fs_cve.c \ + sendto_recvfrom.c \ send_recv.c \ send_recvmsg.c \ shared-wq.c \ @@ -219,6 +220,7 @@ thread-exit: override LDFLAGS +=3D -lpthread ring-leak2: override LDFLAGS +=3D -lpthread poll-mshot-update: override LDFLAGS +=3D -lpthread exit-no-cleanup: override LDFLAGS +=3D -lpthread +sendto_recvfrom: override LDFLAGS +=3D -lpthread =20 install: $(test_targets) runtests.sh runtests-loop.sh $(INSTALL) -D -d -m 755 $(datadir)/liburing-test/ diff --git a/test/sendto_recvfrom.c b/test/sendto_recvfrom.c new file mode 100644 index 0000000..720f52f --- /dev/null +++ b/test/sendto_recvfrom.c @@ -0,0 +1,384 @@ +/* SPDX-License-Identifier: MIT */ +/* + * Simple test case showing using sendto and recvfrom through io_uring + */ +#include +#include +#include +#include +#include +#include +#include +#include +#include + +#include "liburing.h" +#include "helpers.h" + +static char str[] =3D "This is a test of sendto and recvfrom over io_uring= !"; + +#define MAX_MSG 128 + +#define PORT2 10201 +#define PORT 10200 +#define HOST "127.0.0.1" + +struct recvfrom_data { + pthread_mutex_t mutex; + int use_sqthread; + int registerfiles; + int explicit_dst_src; + struct sockaddr_in recvfrom_src; +}; + +static int recvfrom_prep(struct io_uring *ring, struct iovec *iov, int *so= ck, + struct recvfrom_data *rd) +{ + struct sockaddr_in saddr; + struct sockaddr *saddr_p; + socklen_t *saddr_len_p; + socklen_t saddr_len; + struct io_uring_sqe *sqe; + int sockfd, ret, val, use_fd; + + memset(&saddr, 0, sizeof(saddr)); + saddr.sin_family =3D AF_INET; + saddr.sin_addr.s_addr =3D htonl(INADDR_ANY); + saddr.sin_port =3D htons(PORT); + + sockfd =3D socket(AF_INET, SOCK_DGRAM, 0); + if (sockfd < 0) { + perror("socket"); + return 1; + } + + val =3D 1; + setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &val, sizeof(val)); + + ret =3D bind(sockfd, (struct sockaddr *)&saddr, sizeof(saddr)); + if (ret < 0) { + perror("bind"); + goto err; + } + + if (rd->explicit_dst_src) { + memset(&rd->recvfrom_src, 0, sizeof(rd->recvfrom_src)); + saddr_len =3D sizeof(rd->recvfrom_src); + saddr_p =3D (struct sockaddr *) &rd->recvfrom_src; + saddr_len_p =3D &saddr_len; + } else { + saddr_p =3D NULL; + saddr_len_p =3D NULL; + } + + if (rd->registerfiles) { + ret =3D io_uring_register_files(ring, &sockfd, 1); + if (ret) { + fprintf(stderr, "file reg failed\n"); + goto err; + } + use_fd =3D 0; + } else { + use_fd =3D sockfd; + } + + sqe =3D io_uring_get_sqe(ring); + io_uring_prep_recvfrom(sqe, use_fd, iov->iov_base, iov->iov_len, 0, + saddr_p, saddr_len_p); + + if (rd->registerfiles) + sqe->flags |=3D IOSQE_FIXED_FILE; + sqe->user_data =3D 2; + + ret =3D io_uring_submit(ring); + if (ret <=3D 0) { + fprintf(stderr, "submit failed: %d\n", ret); + goto err; + } + + *sock =3D sockfd; + return 0; +err: + close(sockfd); + return 1; +} + +static int do_recv(struct io_uring *ring, struct iovec *iov, + struct recvfrom_data *rd) +{ + struct io_uring_cqe *cqe; + int ret; + + ret =3D io_uring_wait_cqe(ring, &cqe); + if (ret) { + fprintf(stdout, "wait_cqe: %d\n", ret); + goto err; + } + if (cqe->res =3D=3D -EINVAL) { + fprintf(stdout, "recvfrom not supported, skipping\n"); + return 0; + } + if (cqe->res < 0) { + fprintf(stderr, "failed cqe: %d\n", cqe->res); + goto err; + } + + if (cqe->res -1 !=3D strlen(str)) { + fprintf(stderr, "got wrong length: %d/%d\n", cqe->res, + (int) strlen(str) + 1); + goto err; + } + + if (strcmp(str, iov->iov_base)) { + fprintf(stderr, "string mismatch\n"); + goto err; + } + + if (rd->explicit_dst_src) { + if (rd->recvfrom_src.sin_family !=3D AF_INET) { + fprintf(stderr, "wrong saddr2.sin_family\n"); + goto err; + } + + if (rd->recvfrom_src.sin_addr.s_addr !=3D inet_addr(HOST)) { + fprintf(stderr, "wrong saddr2.s_addr\n"); + goto err; + } + + if (rd->recvfrom_src.sin_port !=3D htons(PORT2)) { + fprintf(stderr, "wrong saddr2.sin_port\n"); + goto err; + } + } + + return 0; +err: + return 1; +} + +static void *recvfrom_fn(void *data) +{ + struct recvfrom_data *rd =3D data; + char buf[MAX_MSG + 1]; + struct iovec iov =3D { + .iov_base =3D buf, + .iov_len =3D sizeof(buf) - 1, + }; + struct io_uring_params p =3D { }; + struct io_uring ring; + int ret, sock; + + if (rd->use_sqthread) + p.flags =3D IORING_SETUP_SQPOLL; + ret =3D t_create_ring_params(1, &ring, &p); + if (ret =3D=3D T_SETUP_SKIP) { + pthread_mutex_unlock(&rd->mutex); + ret =3D 0; + goto err; + } else if (ret < 0) { + pthread_mutex_unlock(&rd->mutex); + goto err; + } + + if (rd->use_sqthread && !rd->registerfiles) { + if (!(p.features & IORING_FEAT_SQPOLL_NONFIXED)) { + fprintf(stdout, "Non-registered SQPOLL not available, skipping\n"); + pthread_mutex_unlock(&rd->mutex); + goto err; + } + } + + ret =3D recvfrom_prep(&ring, &iov, &sock, rd); + if (ret) { + fprintf(stderr, "recvfrom_prep failed: %d\n", ret); + goto err; + } + pthread_mutex_unlock(&rd->mutex); + ret =3D do_recv(&ring, &iov, rd); + + close(sock); + io_uring_queue_exit(&ring); +err: + return (void *)(intptr_t)ret; +} + +static int bind_socket_for_sendto(int sockfd) +{ + struct sockaddr_in saddr; + int ret, val; + + memset(&saddr, 0, sizeof(saddr)); + saddr.sin_family =3D AF_INET; + saddr.sin_addr.s_addr =3D inet_addr(HOST); + saddr.sin_port =3D htons(PORT2); + + val =3D 1; + setsockopt(sockfd, SOL_SOCKET, SO_REUSEADDR, &val, sizeof(val)); + + ret =3D bind(sockfd, (struct sockaddr *)&saddr, sizeof(saddr)); + if (ret < 0) { + perror("bind in bind_socket_for_sendto"); + return 1; + } + + + return 0; +} + +static int do_sendto(struct recvfrom_data *rd) +{ + struct sockaddr_in saddr; + struct iovec iov =3D { + .iov_base =3D str, + .iov_len =3D sizeof(str), + }; + struct io_uring ring; + struct io_uring_cqe *cqe; + struct io_uring_sqe *sqe; + struct sockaddr *saddr_p; + socklen_t saddr_len; + int sockfd, ret; + + ret =3D io_uring_queue_init(1, &ring, 0); + if (ret) { + fprintf(stderr, "queue init failed: %d\n", ret); + return 1; + } + + memset(&saddr, 0, sizeof(saddr)); + saddr.sin_family =3D AF_INET; + saddr.sin_port =3D htons(PORT); + inet_pton(AF_INET, HOST, &saddr.sin_addr); + + sockfd =3D socket(AF_INET, SOCK_DGRAM, 0); + if (sockfd < 0) { + perror("socket"); + return 1; + } + + if (rd->explicit_dst_src) { + saddr_p =3D (struct sockaddr *)&saddr; + saddr_len =3D sizeof(saddr); + + /* + * We need to bind() here because the recvfrom() side + * will use an explicit source (addr and port). + */ + bind_socket_for_sendto(sockfd); + } else { + saddr_p =3D NULL; + saddr_len =3D 0; + /* + * Only connect() when sendto() is done without explicit + * destination (addr and port). + */ + ret =3D connect(sockfd, (struct sockaddr *)&saddr, sizeof(saddr)); + if (ret < 0) { + perror("connect"); + return 1; + } + } + + sqe =3D io_uring_get_sqe(&ring); + io_uring_prep_sendto(sqe, sockfd, iov.iov_base, iov.iov_len, 0, + saddr_p, saddr_len); + sqe->user_data =3D 1; + + ret =3D io_uring_submit(&ring); + if (ret <=3D 0) { + fprintf(stderr, "submit failed: %d\n", ret); + goto err; + } + + ret =3D io_uring_wait_cqe(&ring, &cqe); + if (cqe->res =3D=3D -EINVAL) { + fprintf(stdout, "sendto not supported, skipping\n"); + close(sockfd); + return 0; + } + if (cqe->res !=3D iov.iov_len) { + fprintf(stderr, "failed cqe: %d\n", cqe->res); + goto err; + } + + close(sockfd); + return 0; +err: + close(sockfd); + return 1; +} + +static int test(int use_sqthread, int regfiles, int explicit_dst_src) +{ + pthread_mutexattr_t attr; + pthread_t recvfrom_thread; + struct recvfrom_data rd; + int ret; + void *retval; + + pthread_mutexattr_init(&attr); + pthread_mutexattr_setpshared(&attr, 1); + pthread_mutex_init(&rd.mutex, &attr); + pthread_mutex_lock(&rd.mutex); + rd.use_sqthread =3D use_sqthread; + rd.registerfiles =3D regfiles; + rd.explicit_dst_src =3D explicit_dst_src; + + ret =3D pthread_create(&recvfrom_thread, NULL, recvfrom_fn, &rd); + if (ret) { + fprintf(stderr, "Thread create failed: %d\n", ret); + pthread_mutex_unlock(&rd.mutex); + return 1; + } + + pthread_mutex_lock(&rd.mutex); + do_sendto(&rd); + pthread_join(recvfrom_thread, &retval); + return (int)(intptr_t)retval; +} + +int main(int argc, char *argv[]) +{ + int ret; + + if (argc > 1) + return 0; + + ret =3D test(0, 0, 0); + if (ret) { + fprintf(stderr, "test sqthread=3D0 failed\n"); + return ret; + } + + ret =3D test(1, 1, 0); + if (ret) { + fprintf(stderr, "test sqthread=3D1 reg=3D1 failed\n"); + return ret; + } + + ret =3D test(1, 0, 0); + if (ret) { + fprintf(stderr, "test sqthread=3D1 reg=3D0 failed\n"); + return ret; + } + + ret =3D test(0, 0, 1); + if (ret) { + fprintf(stderr, "test sqthread=3D0 explicit_dst_src=3D1 failed\n"); + return ret; + } + + ret =3D test(1, 1, 1); + if (ret) { + fprintf(stderr, "test sqthread=3D1 reg=3D1 explicit_dst_src=3D1 failed\n= "); + return ret; + } + + ret =3D test(1, 0, 1); + if (ret) { + fprintf(stderr, "test sqthread=3D1 reg=3D0 explicit_dst_src=3D1 failed\n= "); + return ret; + } + + return 0; +} --=20 2.32.0 From nobody Wed Jul 1 04:16:15 2026 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 1670EC4332F for ; Thu, 30 Dec 2021 17:51:08 +0000 (UTC) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S241576AbhL3RvH (ORCPT ); Thu, 30 Dec 2021 12:51:07 -0500 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:55728 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S241541AbhL3RvC (ORCPT ); Thu, 30 Dec 2021 12:51:02 -0500 Received: from mail-pf1-x435.google.com (mail-pf1-x435.google.com [IPv6:2607:f8b0:4864:20::435]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 1CF35C061574; Thu, 30 Dec 2021 09:51:02 -0800 (PST) Received: by mail-pf1-x435.google.com with SMTP id 196so21922700pfw.10; Thu, 30 Dec 2021 09:51:02 -0800 (PST) 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=6ju2VgPfHsj6DPGG27hsnZVYzZFDSJ2tinufjtPhmlw=; b=U+RyHlPuf+XH5Tq8K6Y/SFClgKqSssTqMO59CX1vV/Geo2kT53iIFVXZyaXvgdApke 136N5t+ffq3mMyZyh2Lu+arxBqGWARuwvYqnCO5lx20yOxtfqLFmWCxHAQMf8iXkcTP9 1zjUAt1Mz+ZB2+JfI5DCo/mcQ/cMOV4ZmKItafi9oD3Pg/z3dwNdZcLCBltSn8CKwPlO RuoZf1+kmnDQ4dcojQDNw+Gcgudm9xZL38XW3j+Em2VXp2hQR4hB/1kV2QlvdTL9i/mf dyOSRIqvK0UfuFlGxTMJrdlWIAj9WgPMj+TPI0cfUVNU/wtZrErCiMs4Jufz7QdOTxdM rRug== 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=6ju2VgPfHsj6DPGG27hsnZVYzZFDSJ2tinufjtPhmlw=; b=lTMj45nfWHn5FxkkuiMGrBwgQZvWZt1Epo+FtOq/FQZxIKgRShFLuA5piymmEGFN45 kE/GUycFawCCna4Ca9PgL8r4mq4F22/W4iqZYNexSTET/vmCMjRal9nvpqfzsHQ4vGZ9 bcB7dhUcARixg1qHEJD9FpQ/Tv98fJsCLebaFq9QeP5EJhpThCbuhW41y/Gd8vt1vVPk itvdKeNKeWEKewH4Nm1Jazid0mthfq1yunCbpYpoLcZ6wlDN9RoCzpyT5hIseE8oK/Ic MJKvJqIad9LElO9kuh37hp2OJEcogPJZm8qwYcGcv8c5VIIFY62ysYxFT3y3EIIl7Gka 6M2A== X-Gm-Message-State: AOAM530l+l+tb/gF+T4Cmp3xjomPcDpEfgKp67cynhFU9R0cNvdyFn0e AJ8dYwdFRlvUYc3SLdXI5+0= X-Google-Smtp-Source: ABdhPJzm4F1UvDkN7WWxskOS6Xwlx3ozewhFMgkxivjSV6TAn/DttM8oQxukAAuDXUb9nh6tOWpr1A== X-Received: by 2002:a05:6a00:1818:b0:4ba:c287:a406 with SMTP id y24-20020a056a00181800b004bac287a406mr32277721pfa.6.1640886661680; Thu, 30 Dec 2021 09:51:01 -0800 (PST) Received: from integral2.. ([180.254.126.2]) by smtp.gmail.com with ESMTPSA id s34sm29980811pfg.198.2021.12.30.09.50.59 (version=TLS1_3 cipher=TLS_AES_256_GCM_SHA384 bits=256/256); Thu, 30 Dec 2021 09:51:01 -0800 (PST) From: Ammar Faizi To: Jens Axboe Cc: io-uring Mailing List , Pavel Begunkov , "David S . Miller" , Jakub Kicinski , netdev@vger.kernel.org, linux-kernel@vger.kernel.org, Nugra , Ammar Faizi Subject: [RFC PATCH liburing v1 5/5] man: Add `io_uring_prep_{sendto,recvfrom}` docs Date: Fri, 31 Dec 2021 00:50:19 +0700 Message-Id: <20211230174548.178641-6-ammar.faizi@intel.com> X-Mailer: git-send-email 2.32.0 In-Reply-To: <20211230174548.178641-1-ammar.faizi@intel.com> References: <20211230174548.178641-1-ammar.faizi@intel.com> MIME-Version: 1.0 Content-Transfer-Encoding: quoted-printable Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Content-Type: text/plain; charset="utf-8" From: Nugra Cc: Ammar Faizi Signed-off-by: Nugra Signed-off-by: Ammar Faizi --- man/io_uring_prep_recvfrom.3 | 33 +++++++++++++++++++++++++++++++++ man/io_uring_prep_sendto.3 | 34 ++++++++++++++++++++++++++++++++++ 2 files changed, 67 insertions(+) create mode 100644 man/io_uring_prep_recvfrom.3 create mode 100644 man/io_uring_prep_sendto.3 diff --git a/man/io_uring_prep_recvfrom.3 b/man/io_uring_prep_recvfrom.3 new file mode 100644 index 0000000..b6cfea7 --- /dev/null +++ b/man/io_uring_prep_recvfrom.3 @@ -0,0 +1,33 @@ +.\" Copyright (C) 2021 Nugra +.\" +.\" SPDX-License-Identifier: LGPL-2.0-or-later +.\" +.TH io_uring_prep_recvfrom 3 "December 30, 2021" "liburing-2.1" "liburing = Manual" +.SH NAME +io_uring_prep_recvfrom - prepare I/O recvfrom request + +.SH SYNOPSIS +.nf +.BR "#include " +.PP +.BI "void io_uring_prep_recvfrom(struct io_uring_sqe *sqe, int sockfd," +.BI " void *buf, size_t len, int flags, +.BI " struct sockaddr *src_addr," +.BI " socklen_t *addrlen)" +.SH DESCRIPTION +The io_uring_prep_recvfrom() prepares receive messages from a socket. The = submission queue entry +.I sqe +is setup to use the file descriptor +.I fd +transmit the request. + +After the submission queue entry +.I sqe +has been prepared as +.I recvfrom +op, it can be submitted with one of the submit functions. + +.SH RETURN VALUE +None +.SH SEE ALSO +.BR io_uring_get_sqe (3), io_uring_submit (3) diff --git a/man/io_uring_prep_sendto.3 b/man/io_uring_prep_sendto.3 new file mode 100644 index 0000000..2ed8263 --- /dev/null +++ b/man/io_uring_prep_sendto.3 @@ -0,0 +1,34 @@ +.\" Copyright (C) 2021 Nugra +.\" +.\" SPDX-License-Identifier: LGPL-2.0-or-later +.\" +.TH io_uring_prep_sendto 3 "December 30, 2021" "liburing-2.1" "liburing Ma= nual" +.SH NAME +io_uring_prep_sendto - prepare I/O sendto request + +.SH SYNOPSIS +.nf +.BR "#include " +.PP +.BI "void io_uring_prep_sendto(struct io_uring_sqe *sqe, int sockfd," +.BI " const void *buf, size_t len, int flags," +.BI " const struct sockaddr *dest_addr," +.BI " socklen_t addrlen)" +.PP +.SH DESCRIPTION +The io_uring_prep_sendto() prepares transmit request to another socket. Th= e submission queue entry +.I sqe +is setup to use the file descriptor +.I fd +transmit the request. + +After the submission queue entry +.I sqe +has been prepared as +.I sendto +op, it can be submitted with one of the submit functions. + +.SH RETURN VALUE +None +.SH SEE ALSO +.BR io_uring_get_sqe (3), io_uring_submit (3) --=20 2.32.0