Received: by 2002:a05:6358:3188:b0:123:57c1:9b43 with SMTP id q8csp1982440rwd; Fri, 2 Jun 2023 03:08:26 -0700 (PDT) X-Google-Smtp-Source: ACHHUZ57I3xVJsUh478NxE3AKxj1z9Ml6B1PYUzvVkBxQH/9YYg1yzhri4LLv2izfGX9GJIxBNSu X-Received: by 2002:a05:6870:e815:b0:17a:c7ff:ccf5 with SMTP id o21-20020a056870e81500b0017ac7ffccf5mr1490712oan.32.1685700506474; Fri, 02 Jun 2023 03:08:26 -0700 (PDT) ARC-Seal: i=1; a=rsa-sha256; t=1685700506; cv=none; d=google.com; s=arc-20160816; b=SMQqn07nZd/aNyriSJIwe3pELjuc/HV22FWcqY3iruIbFy0Jor6hAK0XZBPrMWkUFK HItpxJrkEFmtlO5X0C03GeofJeKei5Yl2W9HFePZ0ZWBa7BcQTosYbKbexLf6gWcpbpo FcTOy3EzWlWH390I4akKpS+8BoJXYIggTCPkRPEZlftzQhBqVLzxcsYlklQsg/3LmV5m aT04bzRfVXNnFc58y8J8VcFEnPXXni/rvdTw/xgsR4PFON71vNX3cXGgaAeH5ZOMPjjn CMtrVTgUvtnVtMHInHo2Vivr8JM3Udvud0bItclClHLBRibKo/SsAq2sED/q+Tn2Ys4u GYtA== ARC-Message-Signature: i=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=arc-20160816; h=list-id:precedence:cc:to:from:subject:message-id:references :mime-version:in-reply-to:date:dkim-signature; bh=Olx8k/dMqft+QmN4YpoMce08+qwb537I3TMS0ysCxZA=; b=CXxruMuXblkrfMEJMMQYZkqnOeJG7Gr6J+22pz3Iy3LffYLiky5FFjRsyq86U/DMz7 8rntrcMJqtNuKmpt9Jwg3mPzPSGDAWfJCvjLZXlV1N2b2JBFMCwrzov7MG56D42KDZv/ oglILZsvtlefFVoHOHH7skI0Z9tc+bIkp5NznbNlNn1WByimQoR7HbA+I9T5H10Fvok9 yNny+qPM9deWSIrpnKGamrrA+Htku2EoQ77TOblKTyozeTrkcVCYbx46d+NINz3A9eWs CrTsOGt1aiN8Ipt+CFw9X+W2EUWeFhMnBamhPSSw8pY4N8As9qUp5CvyJB4FnnNQjz14 s8Gw== ARC-Authentication-Results: i=1; mx.google.com; dkim=pass header.i=@google.com header.s=20221208 header.b=ezjQZoRV; spf=pass (google.com: domain of linux-kernel-owner@vger.kernel.org designates 2620:137:e000::1:20 as permitted sender) smtp.mailfrom=linux-kernel-owner@vger.kernel.org; dmarc=pass (p=REJECT sp=REJECT dis=NONE) header.from=google.com Return-Path: Received: from out1.vger.email (out1.vger.email. [2620:137:e000::1:20]) by mx.google.com with ESMTP id h16-20020a633850000000b005303bf3e14bsi776669pgn.412.2023.06.02.03.08.14; Fri, 02 Jun 2023 03:08:26 -0700 (PDT) Received-SPF: pass (google.com: domain of linux-kernel-owner@vger.kernel.org designates 2620:137:e000::1:20 as permitted sender) client-ip=2620:137:e000::1:20; Authentication-Results: mx.google.com; dkim=pass header.i=@google.com header.s=20221208 header.b=ezjQZoRV; spf=pass (google.com: domain of linux-kernel-owner@vger.kernel.org designates 2620:137:e000::1:20 as permitted sender) smtp.mailfrom=linux-kernel-owner@vger.kernel.org; dmarc=pass (p=REJECT sp=REJECT dis=NONE) header.from=google.com Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S234870AbjFBJjj (ORCPT + 99 others); Fri, 2 Jun 2023 05:39:39 -0400 Received: from lindbergh.monkeyblade.net ([23.128.96.19]:51668 "EHLO lindbergh.monkeyblade.net" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S234767AbjFBJjh (ORCPT ); Fri, 2 Jun 2023 05:39:37 -0400 Received: from mail-ed1-x54a.google.com (mail-ed1-x54a.google.com [IPv6:2a00:1450:4864:20::54a]) by lindbergh.monkeyblade.net (Postfix) with ESMTPS id 0B508CE for ; Fri, 2 Jun 2023 02:39:29 -0700 (PDT) Received: by mail-ed1-x54a.google.com with SMTP id 4fb4d7f45d1cf-5163c33e60bso700826a12.1 for ; Fri, 02 Jun 2023 02:39:28 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=google.com; s=20221208; t=1685698767; x=1688290767; h=cc:to:from:subject:message-id:references:mime-version:in-reply-to :date:from:to:cc:subject:date:message-id:reply-to; bh=Olx8k/dMqft+QmN4YpoMce08+qwb537I3TMS0ysCxZA=; b=ezjQZoRV8omv8Hob3qBLfYZbMOSH4dDn3kv5BKMrZuM3LgKvuFJYiI05O5kFVGvifx a/fJ24Bk6+nmAgHXfawsb8+IvudoFoCX6sRZ27IZumaPDjhM05qi4p5jt9dEk8pVCqda fqv6JLn+ipCNIueD0s8H40ZHhJxqleMFSY+obFVIIVpY8nCnt/dzABdbx4TYtB+v/Me3 R2MZwpNepVuSosWJPipPrnC8fgLsV9n7N+f0ly8oN1cnQrA+YXtsBvxdHuELy+x+871v 7l8pWy5OSmnrNyogS7dk6xpg5vlNuT8s5yCqR8Z3klAmJMBxTyMZLOBfNAnuS9sLFkpU Y7pw== X-Google-DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=1e100.net; s=20221208; t=1685698767; x=1688290767; h=cc:to:from:subject:message-id:references:mime-version:in-reply-to :date:x-gm-message-state:from:to:cc:subject:date:message-id:reply-to; bh=Olx8k/dMqft+QmN4YpoMce08+qwb537I3TMS0ysCxZA=; b=LkoF91KoBUFmENzufiMjwtfo4n4uA1gMupJlz5956G1f708SuO8tIj4qggh1aRyxrR 63+u45J0rUfSvRfB0x4xdFP/OiEB6Gcaz18iCA0zBMbrrbaU8hzuGT6Yx+3e8ikinWM6 +jBvgKK8edylUK+gVpvtHIy02tnfetVHEtJqnvt3gYB4TNxji0DykB61FXMDE556diig XT5D3jiPwb4atY2EdRvKytNyWLjryseELcNXOUOP2t2hs/GUrEhbTfg/5foruxpF4qGm JpfCKQvjHmNb7JdmPPpzdtm9sA7kFzsYg1ZAlRQt2+1WvXj4VLF/dFAsOmbUxQgO4eOp 0tGw== X-Gm-Message-State: AC+VfDwrohJNOc/ImJR8ib7u9R+ZL2j/npNRI0jKpu13rDX+5Go24mz4 Ze0nrqZ5ROR674QboLOFG1bpppuehKoNGuo= X-Received: from aliceryhl.c.googlers.com ([fda3:e722:ac3:cc00:31:98fb:c0a8:6c8]) (user=aliceryhl job=sendgmr) by 2002:a50:9f28:0:b0:50c:749:b407 with SMTP id b37-20020a509f28000000b0050c0749b407mr905313edf.0.1685698767529; Fri, 02 Jun 2023 02:39:27 -0700 (PDT) Date: Fri, 2 Jun 2023 09:39:25 +0000 In-Reply-To: <20230601183209.371fd898.gary@garyguo.net> Mime-Version: 1.0 References: <20230601183209.371fd898.gary@garyguo.net> X-Mailer: git-send-email 2.41.0.rc0.172.g3f132b7071-goog Message-ID: <20230602093925.1040727-1-aliceryhl@google.com> Subject: Re: [PATCH v2 8/8] rust: workqueue: add examples From: Alice Ryhl To: gary@garyguo.net Cc: alex.gaynor@gmail.com, aliceryhl@google.com, benno.lossin@proton.me, bjorn3_gh@protonmail.com, boqun.feng@gmail.com, jiangshanlai@gmail.com, linux-kernel@vger.kernel.org, ojeda@kernel.org, patches@lists.linux.dev, rust-for-linux@vger.kernel.org, tj@kernel.org, wedsonaf@gmail.com Content-Type: text/plain; charset="UTF-8" X-Spam-Status: No, score=-9.6 required=5.0 tests=BAYES_00,DKIMWL_WL_MED, DKIM_SIGNED,DKIM_VALID,DKIM_VALID_AU,DKIM_VALID_EF,PDS_OTHER_BAD_TLD, RCVD_IN_DNSWL_NONE,SPF_HELO_NONE,SPF_PASS,T_SCC_BODY_TEXT_LINE, URIBL_BLOCKED,USER_IN_DEF_DKIM_WL autolearn=unavailable autolearn_force=no version=3.4.6 X-Spam-Checker-Version: SpamAssassin 3.4.6 (2021-04-09) on lindbergh.monkeyblade.net Precedence: bulk List-ID: X-Mailing-List: linux-kernel@vger.kernel.org Gary Guo writes: > On Thu, 1 Jun 2023 13:49:46 +0000 > Alice Ryhl wrote: >> This adds two examples of how to use the workqueue. The first example >> shows how to use it when you only have one `work_struct` field, and the >> second example shows how to use it when you have multiple `work_struct` >> fields. >> >> Signed-off-by: Alice Ryhl >> --- >> rust/kernel/workqueue.rs | 104 +++++++++++++++++++++++++++++++++++++++ >> 1 file changed, 104 insertions(+) >> >> diff --git a/rust/kernel/workqueue.rs b/rust/kernel/workqueue.rs >> index c302e8b8624b..cefcf43ff40e 100644 >> --- a/rust/kernel/workqueue.rs >> +++ b/rust/kernel/workqueue.rs >> @@ -26,6 +26,110 @@ >> //! * The `WorkItemPointer` trait is implemented for the pointer type that points at a something >> //! that implements `WorkItem`. >> //! >> +//! ## Example >> +//! >> +//! This example defines a struct that holds an integer and can be scheduled on the workqueue. When >> +//! the struct is executed, it will print the integer. Since there is only one `work_struct` field, >> +//! we do not need to specify ids for the fields. >> +//! >> +//! ``` >> +//! use kernel::prelude::*; >> +//! use kernel::sync::Arc; >> +//! use kernel::workqueue::{self, Work, WorkItem}; >> +//! >> +//! #[pin_data] >> +//! struct MyStruct { >> +//! value: i32, >> +//! #[pin] >> +//! work: Work, >> +//! } >> +//! >> +//! impl_has_work! { >> +//! impl HasWork for MyStruct { self.work } >> +//! } >> +//! >> +//! impl MyStruct { >> +//! fn new(value: i32) -> Result> { >> +//! Arc::pin_init(pin_init!(MyStruct { >> +//! value, >> +//! work <- Work::new(), >> +//! })) >> +//! } >> +//! } >> +//! >> +//! impl WorkItem for MyStruct { >> +//! type Pointer = Arc; >> +//! >> +//! fn run(this: Arc) { >> +//! pr_info!("The value is: {}", this.value); >> +//! } >> +//! } >> +//! >> +//! /// This method will enqueue the struct for execution on the system workqueue, where its value >> +//! /// will be printed. >> +//! fn print_later(val: Arc) { >> +//! let _ = workqueue::system().enqueue(val); >> +//! } >> +//! ``` >> +//! >> +//! The following example shows how multiple `work_struct` fields can be used: >> +//! >> +//! ``` >> +//! use kernel::prelude::*; >> +//! use kernel::sync::Arc; >> +//! use kernel::workqueue::{self, Work, WorkItem}; >> +//! >> +//! #[pin_data] >> +//! struct MyStruct { >> +//! value_1: i32, >> +//! value_2: i32, >> +//! #[pin] >> +//! work_1: Work, >> +//! #[pin] >> +//! work_2: Work, >> +//! } >> +//! >> +//! impl_has_work! { >> +//! impl HasWork for MyStruct { self.work_1 } >> +//! impl HasWork for MyStruct { self.work_2 } >> +//! } >> +//! >> +//! impl MyStruct { >> +//! fn new(value_1: i32, value_2: i32) -> Result> { >> +//! Arc::pin_init(pin_init!(MyStruct { >> +//! value_1, >> +//! value_2, >> +//! work_1 <- Work::new(), >> +//! work_2 <- Work::new(), >> +//! })) >> +//! } >> +//! } >> +//! >> +//! impl WorkItem<1> for MyStruct { >> +//! type Pointer = Arc; >> +//! >> +//! fn run(this: Arc) { >> +//! pr_info!("The value is: {}", this.value_1); >> +//! } >> +//! } >> +//! >> +//! impl WorkItem<2> for MyStruct { >> +//! type Pointer = Arc; >> +//! >> +//! fn run(this: Arc) { >> +//! pr_info!("The second value is: {}", this.value_2); >> +//! } >> +//! } >> +//! >> +//! fn print_1_later(val: Arc) { >> +//! let _ = workqueue::system().enqueue::, 1>(val); > > Nothing bad about explicit, but I just want to confirm that you could > write > > let _ = workqueue::system().enqueue::<_, 1>(val); > > here, right? Yes, you can also do that.