Stage 0 and Stage 1

codetracer-python-recorder/src/ffi.rs: 
codetracer-python-recorder/src/runtime/frame_inspector.rs: 
codetracer-python-recorder/src/runtime/mod.rs: 
codetracer-python-recorder/src/runtime/thread_snapshots.rs: 
codetracer-python-recorder/src/runtime/trace_writer_host.rs: 
codetracer-python-recorder/src/session.rs: 
design-docs/capture-output-implementation-plan.status.md: 

Signed-off-by: Tzanko Matev <[email protected]>

Author: tzanko-matev

codetracer-python-recorder/Cargo.lock

@@ -31,7 +31,22 @@ serde = { version = "1.0", features = ["derive"] }
 serde_json = "1.0"
 uuid = { version = "1.10", features = ["v4"] }
 recorder-errors = { version = "0.1.0", path = "crates/recorder-errors" }
+crossbeam-channel = "0.5"
+libc = "0.2"
 
 [dev-dependencies]
 pyo3 = { version = "0.25.1", features = ["auto-initialize"] }
 tempfile = "3.10"
+
+[target.'cfg(unix)'.dev-dependencies]
+os_pipe = "1.2"
+
+[target.'cfg(windows)'.dependencies]
+windows-sys = { version = "0.59", features = [
+    "Win32_Foundation",
+    "Win32_System_IO",
+    "Win32_System_Pipes",
+    "Win32_System_Threading",
+    "Win32_System_WindowsProgramming",
+    "Win32_Storage_FileSystem",
+] }

codetracer-python-recorder/Cargo.toml

@@ -145,12 +145,9 @@ mod tests {
     #[test]
     fn map_recorder_error_sets_python_attributes() {
         Python::with_gil(|py| {
-            let err = usage!(
-                ErrorCode::UnsupportedFormat,
-                "invalid trace format"
-            )
-            .with_context("format", "yaml")
-            .with_source(std::io::Error::new(std::io::ErrorKind::Other, "boom"));
+            let err = usage!(ErrorCode::UnsupportedFormat, "invalid trace format")
+                .with_context("format", "yaml")
+                .with_source(std::io::Error::new(std::io::ErrorKind::Other, "boom"));
             let pyerr = map_recorder_error(err);
             let ty = pyerr.get_type(py);
             assert!(ty.is(py.get_type::<PyUsageError>()));
@@ -191,9 +188,8 @@ mod tests {
     #[test]
     fn dispatch_converts_recorder_error_to_pyerr() {
         Python::with_gil(|py| {
-            let result: PyResult<()> = dispatch("dispatch_env", || {
-                Err(enverr!(ErrorCode::Io, "disk full"))
-            });
+            let result: PyResult<()> =
+                dispatch("dispatch_env", || Err(enverr!(ErrorCode::Io, "disk full")));
             let err = result.expect_err("expected PyErr");
             let ty = err.get_type(py);
             assert!(ty.is(py.get_type::<PyEnvironmentError>()));

codetracer-python-recorder/src/ffi.rs

@@ -40,6 +40,11 @@ impl<'py> FrameSnapshot<'py> {
     pub fn locals_is_globals(&self) -> bool {
         self.locals_is_globals
     }
+
+    /// Return a stable identifier for the captured frame.
+    pub fn frame_id(&self) -> usize {
+        self.frame_ptr as usize
+    }
 }
 
 impl<'py> Drop for FrameSnapshot<'py> {