Allow to create Backtrace (#795)

Author: fafhrd91

Cargo.toml

@@ -56,13 +56,13 @@ ntex-util = { path = "ntex-util" }
 ntex = "3.6.0"
 ntex-bytes = "1.5.2"
 ntex-codec = "1.1.0"
-ntex-error = "1.0.0"
+ntex-error = "1.0.1"
 ntex-io = "3.9.1"
 ntex-dispatcher = "3.1.0"
-ntex-net = "3.8.0"
+ntex-net = "3.8.1"
 ntex-http = "1.0.0"
 ntex-router = "1.0.0"
-ntex-rt = "3.10.0"
+ntex-rt = "3.10.1"
 ntex-server = "3.9.0"
 ntex-service = "4.6.0"
 ntex-tls = "3.4.0"

ntex-error/CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [1.0.1] - 2026-03-08
+
+* Allow to create Backtrace
+
 ## [1.0.0] - 2026-03-07
 
 * Initial error management implementation

ntex-error/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-error"
-version = "1.0.0"
+version = "1.0.1"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "ntex error management"
 keywords = ["network", "framework"]

ntex-error/src/lib.rs

@@ -14,14 +14,21 @@ thread_local! {
     static REPRS: RefCell<HashMap<u64, Arc<str>>> = RefCell::new(HashMap::default());
 }
 static mut START: Option<(&'static str, u32)> = None;
+static mut START_ALT: Option<(&'static str, u32)> = None;
 
-#[track_caller]
 pub fn set_backtrace_start(file: &'static str, line: u32) {
     unsafe {
         START = Some((file, line));
     }
 }
 
+#[doc(hidden)]
+pub fn set_backtrace_start_alt(file: &'static str, line: u32) {
+    unsafe {
+        START_ALT = Some((file, line));
+    }
+}
+
 #[derive(Debug, Clone, Copy, PartialEq, Eq, Hash)]
 pub enum ErrorType {
     Client,
@@ -83,7 +90,7 @@ pub trait ErrorDiagnostic: error::Error + 'static {
     }
 }
 
-#[derive(Debug, Clone)]
+#[derive(Clone)]
 pub struct Error<E> {
     inner: Box<ErrorInner<E>>,
 }
@@ -358,7 +365,8 @@ where
 pub struct Backtrace(Arc<str>);
 
 impl Backtrace {
-    fn new(loc: &Location<'_>) -> Self {
+    /// Create new backtrace
+    pub fn new(loc: &Location<'_>) -> Self {
         let repr = FRAMES.with(|c| {
             let mut cache = c.borrow_mut();
             let mut idx = 0;
@@ -396,8 +404,13 @@ impl Backtrace {
                     find_loc(loc, &mut frames);
 
                     #[allow(static_mut_refs)]
-                    if let Some(start) = unsafe { START } {
-                        find_loc_start(start, &mut frames);
+                    {
+                        if let Some(start) = unsafe { START } {
+                            find_loc_start(start, &mut frames);
+                        }
+                        if let Some(start) = unsafe { START_ALT } {
+                            find_loc_start(start, &mut frames);
+                        }
                     }
 
                     let bt = Bt(&frames[..]);
@@ -441,26 +454,27 @@ fn find_loc(loc: &Location<'_>, frames: &mut [Option<&BacktraceFrame>]) {
 }
 
 fn find_loc_start(loc: (&str, u32), frames: &mut [Option<&BacktraceFrame>]) {
-    let mut idx = frames.len();
-    while idx > 0 {
-        idx -= 1;
+    let mut idx = 0;
+    while idx < frames.len() {
         if let Some(frm) = &frames[idx] {
             for sym in frm.symbols() {
                 if let Some(fname) = sym.filename()
                     && let Some(lineno) = sym.lineno()
                     && fname.ends_with(loc.0)
-                    && lineno == loc.1
+                    && (loc.1 == 0 || lineno == loc.1)
                 {
-                    for f in frames.iter_mut().skip(idx + 1) {
+                    for f in frames.iter_mut().skip(idx) {
                         if f.is_some() {
                             *f = None;
                         } else {
                             return;
                         }
                     }
+                    break;
                 }
             }
         }
+        idx += 1;
     }
 }
 
@@ -502,6 +516,19 @@ impl fmt::Display for Backtrace {
     }
 }
 
+impl<E> fmt::Debug for Error<E>
+where
+    E: ErrorDiagnostic,
+{
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        f.debug_struct("Error")
+            .field("error", &self.inner.error)
+            .field("service", &self.inner.service)
+            .field("backtrace", &self.inner.backtrace)
+            .finish()
+    }
+}
+
 impl<E> fmt::Display for Error<E>
 where
     E: ErrorDiagnostic,

ntex-net/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-net"
-version = "3.8.0"
+version = "3.8.1"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "ntexwork utils for ntex framework"
 keywords = ["network", "framework", "async", "futures"]

ntex-net/src/compio/mod.rs

@@ -23,6 +23,7 @@ pub(crate) fn block_on<F: Future<Output = ()>>(fut: F) {
         compio_runtime::Runtime::try_with_current(Runtime::driver_type)
             .unwrap_or(compio_driver::DriverType::Poll)
     );
+    ntex_error::set_backtrace_start_alt("src/future/future/catch_unwind.rs", 0);
     let rt = Runtime::new().unwrap();
     rt.block_on(fut);
 }

ntex-net/src/tokio/mod.rs

@@ -33,6 +33,8 @@ pub(crate) fn block_on<F: Future<Output = ()>>(fut: F) {
             .enable_all()
             .build()
             .unwrap();
+
+        ntex_error::set_backtrace_start_alt("src/runtime/task/core.rs", 0);
         tok_io::task::LocalSet::new().block_on(&rt, fut);
     }
 }

ntex-rt/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "ntex-rt"
-version = "3.10.0"
+version = "3.10.1"
 authors = ["ntex contributors <team@ntex.rs>"]
 description = "ntex runtime"
 keywords = ["network", "framework", "async", "futures"]

ntex-rt/src/builder.rs

@@ -228,7 +228,7 @@ impl SystemRunner {
 }
 
 #[track_caller]
-fn current_location() -> &'static panic::Location<'static> {
+pub(crate) fn current_location() -> &'static panic::Location<'static> {
     panic::Location::caller()
 }
 

ntex-rt/src/rt.rs

@@ -118,6 +118,7 @@ impl Runtime {
                 });
             }
 
+            ntex_error::set_backtrace_start_alt("src/raw.rs", 0);
             driver.run(self).expect("Driver failed");
             result.expect("Driver failed to poll")
         })