xdp.rs 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100
  1. use std::borrow::Cow;
  2. use proc_macro2::TokenStream;
  3. use quote::quote;
  4. use syn::{ItemFn, Result};
  5. use crate::args::{err_on_unknown_args, pop_bool_arg, Args};
  6. pub(crate) struct Xdp {
  7. item: ItemFn,
  8. frags: bool,
  9. }
  10. impl Xdp {
  11. pub(crate) fn parse(attrs: TokenStream, item: TokenStream) -> Result<Xdp> {
  12. let item = syn::parse2(item)?;
  13. let mut args: Args = syn::parse2(attrs)?;
  14. let frags = pop_bool_arg(&mut args, "frags");
  15. err_on_unknown_args(&args)?;
  16. Ok(Xdp { item, frags })
  17. }
  18. pub(crate) fn expand(&self) -> Result<TokenStream> {
  19. let section_name: Cow<'_, _> = if self.frags {
  20. "xdp.frags".into()
  21. } else {
  22. "xdp".into()
  23. };
  24. let fn_vis = &self.item.vis;
  25. let fn_name = self.item.sig.ident.clone();
  26. let item = &self.item;
  27. Ok(quote! {
  28. #[no_mangle]
  29. #[link_section = #section_name]
  30. #fn_vis fn #fn_name(ctx: *mut ::aya_bpf::bindings::xdp_md) -> u32 {
  31. return #fn_name(::aya_bpf::programs::XdpContext::new(ctx));
  32. #item
  33. }
  34. })
  35. }
  36. }
  37. #[cfg(test)]
  38. mod tests {
  39. use super::*;
  40. use syn::parse_quote;
  41. #[test]
  42. fn test_xdp() {
  43. let prog = Xdp::parse(
  44. parse_quote! {},
  45. parse_quote! {
  46. fn prog(ctx: &mut ::aya_bpf::programs::XdpContext) -> i32 {
  47. 0
  48. }
  49. },
  50. )
  51. .unwrap();
  52. let expanded = prog.expand().unwrap();
  53. let expected = quote! {
  54. #[no_mangle]
  55. #[link_section = "xdp"]
  56. fn prog(ctx: *mut ::aya_bpf::bindings::xdp_md) -> u32 {
  57. return prog(::aya_bpf::programs::XdpContext::new(ctx));
  58. fn prog(ctx: &mut ::aya_bpf::programs::XdpContext) -> i32 {
  59. 0
  60. }
  61. }
  62. };
  63. assert_eq!(expected.to_string(), expanded.to_string());
  64. }
  65. #[test]
  66. fn test_xdp_frags() {
  67. let prog = Xdp::parse(
  68. parse_quote! { frags },
  69. parse_quote! {
  70. fn prog(ctx: &mut ::aya_bpf::programs::XdpContext) -> i32 {
  71. 0
  72. }
  73. },
  74. )
  75. .unwrap();
  76. let expanded = prog.expand().unwrap();
  77. let expected = quote! {
  78. #[no_mangle]
  79. #[link_section = "xdp.frags"]
  80. fn prog(ctx: *mut ::aya_bpf::bindings::xdp_md) -> u32 {
  81. return prog(::aya_bpf::programs::XdpContext::new(ctx));
  82. fn prog(ctx: &mut ::aya_bpf::programs::XdpContext) -> i32 {
  83. 0
  84. }
  85. }
  86. };
  87. assert_eq!(expected.to_string(), expanded.to_string());
  88. }
  89. }