Skip to content

Commit

Permalink
wiggle: choose between &mut self and &self (#5428)
Browse files Browse the repository at this point in the history
Previously, all Wiggle-generated traits were generated with `&mut self`
signatures. With the addition of the `mutable` configuration option to
`from_witx!` and `wasmtime_integration!`, one can disable this, emitting
instead traits that use `&self` (i.e., `mutable: false`). This change is
helpful for implementing wasi-threads: WASI implementations with
interior mutability will now be able to communitcate this to their
Wiggle-generated code.

The other side of this change is the `get_cx` closure passed to Wiggle's
generated `add_to_linker` function. When `mutability` is set to `true`
(default), the `get_cx` function takes a `&mut` data structure from the
store and returns a corresponding `&mut` reference, usually to a field
of the passed-in structure. When `mutability: false`, the `get_cx`
closure will still take a `&mut` data structure but now will return a
`&` reference.
  • Loading branch information
abrown committed Dec 13, 2022
1 parent df923f1 commit 3ce896f
Show file tree
Hide file tree
Showing 6 changed files with 52 additions and 9 deletions.
11 changes: 8 additions & 3 deletions crates/wiggle/generate/src/codegen_settings.rs
Original file line number Diff line number Diff line change
Expand Up @@ -12,10 +12,13 @@ pub struct CodegenSettings {
pub errors: ErrorTransform,
pub async_: AsyncConf,
pub wasmtime: bool,
// Disabling this feature makes it possible to remove all of the tracing
// code emitted in the Wiggle-generated code; this can be helpful while
// inspecting the code (e.g., with `cargo expand`).
/// Disabling this feature makes it possible to remove all of the tracing
/// code emitted in the Wiggle-generated code; this can be helpful while
/// inspecting the code (e.g., with `cargo expand`).
pub tracing: TracingConf,
/// Determine whether the context structure will use `&mut self` (true) or
/// simply `&self`.
pub mutable: bool,
}
impl CodegenSettings {
pub fn new(
Expand All @@ -24,13 +27,15 @@ impl CodegenSettings {
doc: &Document,
wasmtime: bool,
tracing: &TracingConf,
mutable: bool,
) -> Result<Self, Error> {
let errors = ErrorTransform::new(error_conf, doc)?;
Ok(Self {
errors,
async_: async_.clone(),
wasmtime,
tracing: tracing.clone(),
mutable,
})
}
pub fn get_async(&self, module: &Module, func: &InterfaceFunc) -> Asyncness {
Expand Down
21 changes: 21 additions & 0 deletions crates/wiggle/generate/src/config.rs
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ pub struct Config {
pub async_: AsyncConf,
pub wasmtime: bool,
pub tracing: TracingConf,
pub mutable: bool,
}

mod kw {
Expand All @@ -25,6 +26,7 @@ mod kw {
syn::custom_keyword!(errors);
syn::custom_keyword!(target);
syn::custom_keyword!(wasmtime);
syn::custom_keyword!(mutable);
syn::custom_keyword!(tracing);
syn::custom_keyword!(disable_for);
syn::custom_keyword!(trappable);
Expand All @@ -37,6 +39,7 @@ pub enum ConfigField {
Async(AsyncConf),
Wasmtime(bool),
Tracing(TracingConf),
Mutable(bool),
}

impl Parse for ConfigField {
Expand Down Expand Up @@ -76,6 +79,10 @@ impl Parse for ConfigField {
input.parse::<kw::tracing>()?;
input.parse::<Token![:]>()?;
Ok(ConfigField::Tracing(input.parse()?))
} else if lookahead.peek(kw::mutable) {
input.parse::<kw::mutable>()?;
input.parse::<Token![:]>()?;
Ok(ConfigField::Mutable(input.parse::<syn::LitBool>()?.value))
} else {
Err(lookahead.error())
}
Expand All @@ -89,6 +96,7 @@ impl Config {
let mut async_ = None;
let mut wasmtime = None;
let mut tracing = None;
let mut mutable = None;
for f in fields {
match f {
ConfigField::Witx(c) => {
Expand Down Expand Up @@ -121,6 +129,12 @@ impl Config {
}
tracing = Some(c);
}
ConfigField::Mutable(c) => {
if mutable.is_some() {
return Err(Error::new(err_loc, "duplicate `mutable` field"));
}
mutable = Some(c);
}
}
}
Ok(Config {
Expand All @@ -131,6 +145,7 @@ impl Config {
async_: async_.take().unwrap_or_default(),
wasmtime: wasmtime.unwrap_or(true),
tracing: tracing.unwrap_or_default(),
mutable: mutable.unwrap_or(true),
})
}

Expand Down Expand Up @@ -601,6 +616,12 @@ impl Parse for WasmtimeConfigField {
blocking: true,
functions: input.parse()?,
})))
} else if lookahead.peek(kw::mutable) {
input.parse::<kw::mutable>()?;
input.parse::<Token![:]>()?;
Ok(WasmtimeConfigField::Core(ConfigField::Mutable(
input.parse::<syn::LitBool>()?.value,
)))
} else {
Err(lookahead.error())
}
Expand Down
11 changes: 8 additions & 3 deletions crates/wiggle/generate/src/funcs.rs
Original file line number Diff line number Diff line change
Expand Up @@ -77,6 +77,11 @@ fn _define_func(
function = #func_name
);
);
let ctx_type = if settings.mutable {
quote!(&'a mut)
} else {
quote!(&'a)
};
if settings.get_async(&module, &func).is_sync() {
let traced_body = if settings.tracing.enabled_for(&mod_name, &func_name) {
quote!(
Expand All @@ -91,8 +96,8 @@ fn _define_func(
(
quote!(
#[allow(unreachable_code)] // deals with warnings in noreturn functions
pub fn #ident(
ctx: &mut (impl #(#bounds)+*),
pub fn #ident<'a>(
ctx: #ctx_type (impl #(#bounds)+*),
memory: &dyn wiggle::GuestMemory,
#(#abi_params),*
) -> wiggle::anyhow::Result<#abi_ret> {
Expand Down Expand Up @@ -122,7 +127,7 @@ fn _define_func(
quote!(
#[allow(unreachable_code)] // deals with warnings in noreturn functions
pub fn #ident<'a>(
ctx: &'a mut (impl #(#bounds)+*),
ctx: #ctx_type (impl #(#bounds)+*),
memory: &'a dyn wiggle::GuestMemory,
#(#abi_params),*
) -> impl std::future::Future<Output = wiggle::anyhow::Result<#abi_ret>> + 'a {
Expand Down
9 changes: 7 additions & 2 deletions crates/wiggle/generate/src/module_trait.rs
Original file line number Diff line number Diff line change
Expand Up @@ -81,10 +81,15 @@ pub fn define_module_trait(m: &Module, settings: &CodegenSettings) -> TokenStrea
quote!(async)
};

let self_ = if settings.mutable {
quote!(&mut self)
} else {
quote!(&self)
};
if is_anonymous {
quote!(#asyncness fn #funcname(&mut self, #(#args),*) -> #result; )
quote!(#asyncness fn #funcname(#self_, #(#args),*) -> #result; )
} else {
quote!(#asyncness fn #funcname<#lifetime>(&mut self, #(#args),*) -> #result;)
quote!(#asyncness fn #funcname<#lifetime>(#self_, #(#args),*) -> #result;)
}
});

Expand Down
7 changes: 6 additions & 1 deletion crates/wiggle/generate/src/wasmtime.rs
Original file line number Diff line number Diff line change
Expand Up @@ -46,11 +46,16 @@ pub fn link_module(
format_ident!("add_{}_to_linker", module_ident)
};

let u = if settings.mutable {
quote!(&mut U)
} else {
quote!(&U)
};
quote! {
/// Adds all instance items to the specified `Linker`.
pub fn #func_name<T, U>(
linker: &mut wiggle::wasmtime_crate::Linker<T>,
get_cx: impl Fn(&mut T) -> &mut U + Send + Sync + Copy + 'static,
get_cx: impl Fn(&mut T) -> #u + Send + Sync + Copy + 'static,
) -> wiggle::anyhow::Result<()>
where
U: #ctx_bound #send_bound
Expand Down
2 changes: 2 additions & 0 deletions crates/wiggle/macro/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -157,6 +157,7 @@ pub fn from_witx(args: TokenStream) -> TokenStream {
&doc,
config.wasmtime,
&config.tracing,
config.mutable,
)
.expect("validating codegen settings");

Expand Down Expand Up @@ -198,6 +199,7 @@ pub fn wasmtime_integration(args: TokenStream) -> TokenStream {
&doc,
true,
&config.c.tracing,
config.c.mutable,
)
.expect("validating codegen settings");

Expand Down

0 comments on commit 3ce896f

Please sign in to comment.