-
Notifications
You must be signed in to change notification settings - Fork 16
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Start work on zero copy support (#35)
- Loading branch information
Showing
44 changed files
with
2,958 additions
and
37 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -177,9 +177,7 @@ where | |
| { | ||
| #[inline] | ||
| fn clone(&self) -> Self { | ||
| Self { | ||
| _marker: marker::PhantomData, | ||
| } | ||
| *self | ||
| } | ||
| } | ||
|
|
||
|
|
||
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,178 @@ | ||
| use std::cell::RefCell; | ||
|
|
||
| use proc_macro2::TokenStream; | ||
| use quote::quote; | ||
| use syn::meta::ParseNestedMeta; | ||
| use syn::parse::ParseStream; | ||
| use syn::punctuated::Punctuated; | ||
| use syn::{DeriveInput, Token}; | ||
|
|
||
| #[derive(Default)] | ||
| struct Ctxt { | ||
| errors: RefCell<Vec<syn::Error>>, | ||
| } | ||
|
|
||
| impl Ctxt { | ||
| fn error(&self, error: syn::Error) { | ||
| self.errors.borrow_mut().push(error); | ||
| } | ||
| } | ||
|
|
||
| pub struct Expander<'a> { | ||
| input: &'a DeriveInput, | ||
| } | ||
|
|
||
| impl<'a> Expander<'a> { | ||
| pub fn new(input: &'a DeriveInput) -> Self { | ||
| Self { input } | ||
| } | ||
| } | ||
|
|
||
| impl<'a> Expander<'a> { | ||
| pub fn expand(&self) -> Result<TokenStream, Vec<syn::Error>> { | ||
| let cx = Ctxt::default(); | ||
|
|
||
| let Ok(output) = expand(&cx, self.input) else { | ||
| return Err(cx.errors.into_inner()); | ||
| }; | ||
|
|
||
| let errors = cx.errors.into_inner(); | ||
|
|
||
| if !errors.is_empty() { | ||
| return Err(errors); | ||
| } | ||
|
|
||
| Ok(output) | ||
| } | ||
| } | ||
|
|
||
| fn expand(cx: &Ctxt, input: &DeriveInput) -> Result<TokenStream, ()> { | ||
| let st = match &input.data { | ||
| syn::Data::Struct(st) => st, | ||
| syn::Data::Enum(data) => { | ||
| cx.error(syn::Error::new_spanned( | ||
| data.enum_token, | ||
| "ZeroCopy: not supported for enums", | ||
| )); | ||
| return Err(()); | ||
| } | ||
| syn::Data::Union(data) => { | ||
| cx.error(syn::Error::new_spanned( | ||
| data.union_token, | ||
| "ZeroCopy: not supported for unions", | ||
| )); | ||
| return Err(()); | ||
| } | ||
| }; | ||
|
|
||
| let mut generics = input.generics.clone(); | ||
|
|
||
| let mut is_repr_c = false; | ||
|
|
||
| for attr in &input.attrs { | ||
| if attr.path().is_ident("repr") { | ||
| let result = attr.parse_args_with(|input: ParseStream| { | ||
| let ident: syn::Ident = input.parse()?; | ||
|
|
||
| if ident == "C" { | ||
| is_repr_c = true; | ||
| } | ||
|
|
||
| Ok(()) | ||
| }); | ||
|
|
||
| if let Err(error) = result { | ||
| cx.error(error); | ||
| } | ||
| } | ||
|
|
||
| if attr.path().is_ident("zero_copy") { | ||
| let result = attr.parse_nested_meta(|meta: ParseNestedMeta| { | ||
| if meta.path.is_ident("bounds") { | ||
| meta.input.parse::<Token![=]>()?; | ||
| let content; | ||
| syn::braced!(content in meta.input); | ||
| generics.make_where_clause().predicates.extend(Punctuated::< | ||
| syn::WherePredicate, | ||
| Token![,], | ||
| >::parse_terminated( | ||
| &content | ||
| )?); | ||
| return Ok(()); | ||
| } | ||
|
|
||
| Ok(()) | ||
| }); | ||
|
|
||
| if let Err(error) = result { | ||
| cx.error(error); | ||
| } | ||
| } | ||
| } | ||
|
|
||
| if !is_repr_c { | ||
| cx.error(syn::Error::new_spanned( | ||
| input, | ||
| "ZeroCopy: struct must be marked with repr(C)", | ||
| )); | ||
| return Err(()); | ||
| } | ||
|
|
||
| let buf_mut: syn::Path = syn::parse_quote!(musli_zerocopy::BufMut); | ||
| let buf: syn::Path = syn::parse_quote!(musli_zerocopy::Buf); | ||
| let error: syn::Path = syn::parse_quote!(musli_zerocopy::Error); | ||
| let validator: syn::Path = syn::parse_quote!(musli_zerocopy::Validator); | ||
| let zero_copy: syn::Path = syn::parse_quote!(musli_zerocopy::ZeroCopy); | ||
|
|
||
| let mut writes = Vec::new(); | ||
| let mut validates = Vec::new(); | ||
|
|
||
| for (index, field) in st.fields.iter().enumerate() { | ||
| let member = match &field.ident { | ||
| Some(ident) => syn::Member::Named(ident.clone()), | ||
| None => syn::Member::Unnamed(syn::Index::from(index)), | ||
| }; | ||
|
|
||
| writes.push(quote! { | ||
| #buf_mut::write(buf, &self.#member)?; | ||
| }); | ||
|
|
||
| let ty = &field.ty; | ||
|
|
||
| validates.push(quote! { | ||
| #validator::field::<#ty>(&mut validator)?; | ||
| }); | ||
| } | ||
|
|
||
| let name = &input.ident; | ||
|
|
||
| let (impl_generics, ty_generics, where_clause) = generics.split_for_impl(); | ||
|
|
||
| let validates = &validates[..]; | ||
|
|
||
| Ok(quote::quote! { | ||
| unsafe impl #impl_generics #zero_copy for #name #ty_generics #where_clause { | ||
| fn write_to<__B: ?Sized>(&self, buf: &mut __B) -> Result<(), #error> | ||
| where | ||
| __B: #buf_mut | ||
| { | ||
| #(#writes)* | ||
| Ok(()) | ||
| } | ||
|
|
||
| fn read_from(buf: &#buf) -> Result<&Self, #error> { | ||
| let mut validator = #buf::validate::<Self>(buf)?; | ||
| #(#validates)* | ||
| #validator::finalize(validator)?; | ||
| Ok(unsafe { #buf::cast(buf) }) | ||
| } | ||
|
|
||
| unsafe fn validate_aligned(buf: &#buf) -> Result<(), #error> { | ||
| let mut validator = #buf::validate_aligned(buf)?; | ||
| #(#validates)* | ||
| #validator::finalize(validator)?; | ||
| Ok(()) | ||
| } | ||
| } | ||
| }) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
|
|
@@ -256,9 +256,7 @@ where | |
| { | ||
| #[inline] | ||
| fn clone(&self) -> Self { | ||
| Self { | ||
| _marker: marker::PhantomData, | ||
| } | ||
| *self | ||
| } | ||
| } | ||
|
|
||
|
|
||
Oops, something went wrong.