Attributes

Cargo.toml

@@ -32,7 +32,7 @@ autoexamples = false
 
 
 [features]
-default = ["async-exec", "iouring"]
+default = ["async-exec", "iouring", "attributes"]
 # Devs should enable these features to use iouring on linux.
 #default = ["asyncstd", "iouring"]
 epoll = []
@@ -41,7 +41,10 @@ iouring = ["rustix-uring", "rustix"]
 async-exec = ["async-global-executor"]
 tokio = ["async-global-executor/tokio"]
 
+attributes = ["nuclei-attributes"]
+
 [dependencies]
+nuclei-attributes = { version = "0.1", optional = true }
 lever = "0.1"
 futures = { version = "0.3", default-features = false, features = ["std", "async-await"] }
 socket2 = { version = "0.3.19", features = ["pair", "unix"] }

examples/Cargo.toml

@@ -7,7 +7,7 @@ publish = false
 
 [dev-dependencies]
 #nuclei = { path = "../" }
-nuclei = { path = "../", default-features = false, features = ["tokio", "iouring"]}
+nuclei = { path = "../", default-features = false, features = ["tokio", "iouring", "attributes"]}
 futures = { version = "0.3", default-features = false, features = ["std", "async-await"] }
 futures-util = "0.3"
 anyhow = "1.0.31"

examples/fread-vect.rs

@@ -9,29 +9,28 @@ use futures::AsyncReadExt;
 
 const IOVEC_WIDTH: usize = 1 << 10;
 
-fn main() -> io::Result<()> {
-    let x = drive(async {
-        let mut path = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
-        path.push("data");
-        path.push("quark-gluon-plasma");
-
-        let mut buf1 = [0; IOVEC_WIDTH];
-        let mut buf2 = [0; IOVEC_WIDTH];
-        let mut buf3 = [0; IOVEC_WIDTH];
-        let mut bufs = [
-            IoSliceMut::new(&mut buf1),
-            IoSliceMut::new(&mut buf2),
-            IoSliceMut::new(&mut buf3),
-        ];
-
-        let fo = File::open(&path).unwrap();
-        let mut file = Handle::<File>::new(fo).unwrap();
-        file.read_vectored(&mut bufs[..]).await.unwrap();
-
-        vec![buf1, buf2, buf3]
-    });
-
-    x.iter().enumerate().for_each(|(idx, e)| {
+#[nuclei::main]
+async fn main() -> io::Result<()> {
+    let mut path = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
+    path.push("data");
+    path.push("quark-gluon-plasma");
+
+    let mut buf1 = [0; IOVEC_WIDTH];
+    let mut buf2 = [0; IOVEC_WIDTH];
+    let mut buf3 = [0; IOVEC_WIDTH];
+    let mut bufs = [
+        IoSliceMut::new(&mut buf1),
+        IoSliceMut::new(&mut buf2),
+        IoSliceMut::new(&mut buf3),
+    ];
+
+    let fo = File::open(&path).unwrap();
+    let mut file = Handle::<File>::new(fo).unwrap();
+    file.read_vectored(&mut bufs[..]).await.unwrap();
+
+    let bufs = vec![buf1, buf2, buf3];
+
+    bufs.iter().enumerate().for_each(|(idx, e)| {
         println!(
             "::: iovec ::: {}, data ::: \n\n{}\n\n",
             idx,

examples/fread.rs

@@ -6,23 +6,19 @@ use std::path::PathBuf;
 
 use futures::AsyncReadExt;
 
-fn main() -> io::Result<()> {
-    let x: io::Result<String> = drive(async {
-        let mut path = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
-        path.push("data");
-        path.push("quark-gluon-plasma");
-        dbg!(&path);
+#[nuclei::main]
+async fn main() -> io::Result<()> {
+    let mut path = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
+    path.push("data");
+    path.push("quark-gluon-plasma");
 
-        let fo = File::open(&path).unwrap();
-        let mut file = Handle::<File>::new(fo).unwrap();
-        let mut buffer = String::new();
-        file.read_to_string(&mut buffer).await?;
-        Ok(buffer)
-    });
-    let x = x?;
+    let fo = File::open(&path).unwrap();
+    let mut file = Handle::<File>::new(fo).unwrap();
+    let mut buffer = String::new();
+    file.read_to_string(&mut buffer).await?;
 
-    println!("Content: {}", x);
-    println!("Length of file is {}", x.len());
+    println!("Content: {}", buffer);
+    println!("Length of file is {}", buffer.len());
 
     Ok(())
 }

examples/fwrite-vect.rs

@@ -12,40 +12,39 @@ use std::io::{IoSlice, SeekFrom};
 
 const IOVEC_WIDTH: usize = 1 << 10;
 
-fn main() -> io::Result<()> {
-    let x = drive(async {
-        let mut path = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
-        path.push("data");
-        path.push("dark-matter-vect");
-
-        let buf1 = [0x41; IOVEC_WIDTH];
-        let buf2 = [0x42; IOVEC_WIDTH];
-        let buf3 = [0x43; IOVEC_WIDTH];
-        let bufs = [
-            IoSlice::new(&buf1),
-            IoSlice::new(&buf2),
-            IoSlice::new(&buf3),
-        ];
-
-        let fo = OpenOptions::new()
-            .read(true)
-            .write(true)
-            .open(&path)
-            .unwrap();
-        let mut file = Handle::<File>::new(fo).unwrap();
-        file.write_vectored(&bufs[..]).await.unwrap();
-
-        let mut bufv = String::new();
-        assert!(file.seek(SeekFrom::Start(0)).await.is_ok());
-        file.read_to_string(&mut bufv).await.unwrap();
-        bufv
-    });
-
-    assert_eq!(x.matches('A').count(), IOVEC_WIDTH);
-    assert_eq!(x.matches('B').count(), IOVEC_WIDTH);
-    assert_eq!(x.matches('C').count(), IOVEC_WIDTH);
-
-    println!("SG write was: {}", x);
+#[nuclei::main]
+async fn main() -> io::Result<()> {
+    let mut path = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
+    path.push("data");
+    path.push("dark-matter-vect");
+
+    let buf1 = [0x41; IOVEC_WIDTH];
+    let buf2 = [0x42; IOVEC_WIDTH];
+    let buf3 = [0x43; IOVEC_WIDTH];
+    let bufs = [
+        IoSlice::new(&buf1),
+        IoSlice::new(&buf2),
+        IoSlice::new(&buf3),
+    ];
+
+    let fo = OpenOptions::new()
+        .read(true)
+        .write(true)
+        .open(&path)
+        .unwrap();
+    let mut file = Handle::<File>::new(fo).unwrap();
+    file.write_vectored(&bufs[..]).await.unwrap();
+
+    let mut bufv = String::new();
+    assert!(file.seek(SeekFrom::Start(0)).await.is_ok());
+    file.read_to_string(&mut bufv).await.unwrap();
+
+
+    assert_eq!(bufv.matches('A').count(), IOVEC_WIDTH);
+    assert_eq!(bufv.matches('B').count(), IOVEC_WIDTH);
+    assert_eq!(bufv.matches('C').count(), IOVEC_WIDTH);
+
+    println!("SG write was: {}", bufv);
 
     Ok(())
 }

examples/fwrite.rs

@@ -22,31 +22,30 @@ to detect.[1]\
 \
 ";
 
-fn main() -> io::Result<()> {
+#[nuclei::main]
+async fn main() -> io::Result<()> {
     // Approximately ~75,9 MB
     let dark_matter = vec![DARK_MATTER_TEXT; 100_000].join("\n");
 
-    let x = drive(async {
-        let mut path = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
-        path.push("data");
-        path.push("dark-matter");
-
-        let fo = OpenOptions::new()
-            .read(true)
-            .write(true)
-            .open(&path)
-            .unwrap();
-        let mut file = Handle::<File>::new(fo).unwrap();
-        file.write_all(dark_matter.as_bytes()).await.unwrap();
-
-        let mut buf = vec![];
-        assert!(file.seek(SeekFrom::Start(0)).await.is_ok());
-        assert_eq!(file.read_to_end(&mut buf).await.unwrap(), dark_matter.len());
-        assert_eq!(&buf[0..dark_matter.len()], dark_matter.as_bytes());
-        buf
-    });
-
-    println!("Length of file is {}", x.len());
+    let mut path = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
+    path.push("data");
+    path.push("dark-matter");
+
+    let fo = OpenOptions::new()
+        .read(true)
+        .write(true)
+        .open(&path)
+        .unwrap();
+    let mut file = Handle::<File>::new(fo).unwrap();
+    file.write_all(dark_matter.as_bytes()).await.unwrap();
+
+    let mut buf = vec![];
+    assert!(file.seek(SeekFrom::Start(0)).await.is_ok());
+    assert_eq!(file.read_to_end(&mut buf).await.unwrap(), dark_matter.len());
+    assert_eq!(&buf[0..dark_matter.len()], dark_matter.as_bytes());
+
+
+    println!("Length of file is {}", buf.len());
 
     Ok(())
 }

examples/h1-server-multishot.rs

@@ -1,5 +1,6 @@
 #[cfg(target_os = "linux")]
-fn main() -> anyhow::Result<()>  {
+#[nuclei::main]
+async fn main() -> anyhow::Result<()>  {
     use nuclei::*;
     use std::net::TcpListener;
 
@@ -51,14 +52,10 @@ fn main() -> anyhow::Result<()>  {
         Ok(())
     }
 
-    spawn_blocking(|| drive(future::pending::<()>())).detach();
+    let http = listen(Handle::<TcpListener>::bind("0.0.0.0:8000")?);
 
-    block_on(async {
-        let http = listen(Handle::<TcpListener>::bind("0.0.0.0:8000")?);
-
-        http.await?;
-        Ok(())
-    })
+    http.await?;
+    Ok(())
 }
 
 #[cfg(target_os = "macos")]

examples/h1-server.rs

@@ -40,13 +40,10 @@ async fn listen(listener: Handle<TcpListener>) -> Result<()> {
     }
 }
 
-fn main() -> Result<()> {
-    spawn_blocking(|| drive(future::pending::<()>())).detach();
+#[nuclei::main]
+async fn main() -> Result<()> {
+    let http = listen(Handle::<TcpListener>::bind("0.0.0.0:8000")?);
 
-    block_on(async {
-        let http = listen(Handle::<TcpListener>::bind("0.0.0.0:8000")?);
-
-        http.await?;
-        Ok(())
-    })
+    http.await?;
+    Ok(())
 }

examples/tcp-client.rs

@@ -3,15 +3,14 @@ use nuclei::*;
 use std::io;
 use std::net::TcpStream;
 
-fn main() -> io::Result<()> {
-    drive(async {
-        println!("Connecting to server");
-        let mut stream = Handle::<TcpStream>::connect("127.0.0.1:7000").await?;
-        println!("Connected to {}", stream.get_ref().peer_addr()?);
+#[nuclei::main]
+async fn main() -> io::Result<()> {
+    println!("Connecting to server");
+    let mut stream = Handle::<TcpStream>::connect("127.0.0.1:7000").await?;
+    println!("Connected to {}", stream.get_ref().peer_addr()?);
 
-        let result = stream.write(b"hello world\n").await;
-        println!("Wrote, success={:?}", result.is_ok());
+    let result = stream.write(b"hello world\n").await;
+    println!("Wrote, success={:?}", result.is_ok());
 
-        Ok(())
-    })
+    Ok(())
 }

examples/tcp-server.rs

@@ -7,20 +7,19 @@ async fn echo(stream: Handle<TcpStream>) -> io::Result<()> {
     Ok(())
 }
 
-fn main() -> io::Result<()> {
-    drive(async {
-        // Create a listener.
-        let listener = Handle::<TcpListener>::bind("0.0.0.0:7000")?;
-        println!("Listening on {}", listener.get_ref().local_addr()?);
-        println!("Now start a TCP client.");
+#[nuclei::main]
+async fn main() -> io::Result<()> {
+    // Create a listener.
+    let listener = Handle::<TcpListener>::bind("0.0.0.0:7000")?;
+    println!("Listening on {}", listener.get_ref().local_addr()?);
+    println!("Now start a TCP client.");
 
-        // Accept clients in a loop.
-        loop {
-            let (stream, peer_addr) = listener.accept().await?;
-            println!("Accepted client: {:?}", peer_addr);
+    // Accept clients in a loop.
+    loop {
+        let (stream, peer_addr) = listener.accept().await?;
+        println!("Accepted client: {:?}", peer_addr);
 
-            // Spawn a task that echoes messages from the client back to it.
-            spawn(echo(stream)).detach();
-        }
-    })
+        // Spawn a task that echoes messages from the client back to it.
+        spawn(echo(stream)).detach();
+    }
 }

examples/unix-signal.rs

@@ -1,19 +1,18 @@
 #[cfg(unix)]
-fn main() -> std::io::Result<()> {
+#[nuclei::main]
+async fn main() -> std::io::Result<()> {
     use futures::prelude::*;
     use nuclei::*;
     use std::os::unix::net::UnixStream;
 
-    drive(async {
-        // Create a Unix stream that receives a byte on each signal occurrence.
-        let (a, mut b) = Handle::<UnixStream>::pair()?;
-        signal_hook::pipe::register(signal_hook::SIGINT, a)?;
-        println!("Waiting for Ctrl-C...");
+    // Create a Unix stream that receives a byte on each signal occurrence.
+    let (a, mut b) = Handle::<UnixStream>::pair()?;
+    signal_hook::pipe::register(signal_hook::SIGINT, a)?;
+    println!("Waiting for Ctrl-C...");
 
-        // Receive a byte that indicates the Ctrl-C signal occurred.
-        b.read_exact(&mut [0]).await?;
+    // Receive a byte that indicates the Ctrl-C signal occurred.
+    b.read_exact(&mut [0]).await?;
 
-        println!("Done!");
-        Ok(())
-    })
+    println!("Done!");
+    Ok(())
 }

src/lib.rs

@@ -82,3 +82,6 @@ mod syscore {
 
 pub use async_global_executor::*;
 pub use proactor::*;
+
+#[cfg(feature = "attributes")]
+pub use nuclei_attributes::*;

src/proactor.rs

@@ -1,9 +1,9 @@
 use std::task::{Context, Poll};
 use std::time::Duration;
 use std::{future::Future, io};
 use std::ops::DerefMut;
 
 use once_cell::sync::{Lazy, OnceCell};
 use crate::config::NucleiConfig;
 
 use super::syscore::*;
@@ -34,7 +34,7 @@
     /// Builds a proactor instance with given config and returns a reference to it.
     pub fn with_config(config: NucleiConfig) -> &'static Proactor {
         unsafe {
             let mut proactor = Proactor(SysProactor::new(config.clone()).expect("cannot initialize IO backend"));
             PROACTOR.set(proactor).map_err(|e| "Proactor instance not being able to set.").unwrap();
             let proactor = Proactor(SysProactor::new(config).expect("cannot initialize IO backend"));
             &PROACTOR.get_or_init(|| proactor)
@@ -99,7 +99,7 @@
 }
 
 #[cfg(test)]
-#[cfg(feature = "iouring")]
+#[cfg(target_os = "linux")]
 mod proactor_tests {
     use crate::config::{IoUringConfiguration, NucleiConfig};
     use crate::Proactor;

testdata/dark-matter

@@ -1 +0,0 @@
-

testdata/dark-matter-vect

@@ -1 +0,0 @@
-