Add Rust Bindings for Fabrics API

.github/workflows/build.yml

@@ -317,7 +317,7 @@ jobs:
             -i mxl_build_container_with_source \
             bash -c "
               cd /workspace/mxl/rust && \
-              cargo build --release --all-targets --locked
+              cargo build --release --features mxl-fabrics-ofi --all-targets --locked
             "
 
       - name: Test the Rust bindings
@@ -336,7 +336,7 @@ jobs:
             -i mxl_build_container_with_source \
             bash -c "
               cd /workspace/mxl/rust && \
-              cargo test --release --all-targets --locked -- --test-threads=1 --show-output
+              cargo test --release --all-targets --features mxl-fabrics-ofi --locked -- --test-threads=1 --show-output
             " 2>&1 | tee test.log
           status=${PIPESTATUS[0]}
           set -e
@@ -354,3 +354,4 @@ jobs:
             } >> "$GITHUB_STEP_SUMMARY"
           fi
           exit "${status}"
+

rust/.gitignore

@@ -4,4 +4,4 @@
 .DS_Store
 .idea
 .vscode
-target
+/target

rust/mxl-sys/Cargo.toml

@@ -17,3 +17,4 @@ cmake = "0.1.54"
 
 [features]
 mxl-not-built = []
+mxl-fabrics-ofi = []

rust/mxl-sys/build.rs

@@ -63,6 +63,61 @@ fn get_bindgen_specs() -> BindgenSpecs {
     }
 }
 
+fn get_bindgen_specs_fabrics() -> BindgenSpecs {
+    let header = "wrapper-fabrics.h".to_string();
+
+    let manifest_dir =
+        PathBuf::from(env::var("CARGO_MANIFEST_DIR").expect("failed to get current directory"));
+    let repo_root = manifest_dir.parent().unwrap().parent().unwrap();
+    let mut includes_dirs = vec![
+        repo_root
+            .join("lib")
+            .join("include")
+            .to_string_lossy()
+            .to_string(),
+        repo_root
+            .join("lib")
+            .join("fabrics")
+            .join("include")
+            .to_string_lossy()
+            .to_string(),
+    ];
+    if cfg!(not(feature = "mxl-not-built")) {
+        let out_dir = PathBuf::from(std::env::var("OUT_DIR").unwrap());
+        let build_version_dir = out_dir.join("include").to_string_lossy().to_string();
+
+        includes_dirs.push(build_version_dir);
+
+        // Rebuild if any file in lib/ changes
+        let lib_root = repo_root.join("lib");
+        println!("cargo:rerun-if-changed={}", lib_root.display());
+
+        let dst = cmake::Config::new(repo_root)
+            .generator("Ninja")
+            .configure_arg("--preset")
+            .configure_arg(BUILD_VARIANT)
+            .configure_arg("-B")
+            .configure_arg(out_dir.join("build"))
+            .define("MXL_ENABLE_FABRICS_OFI", "ON")
+            .define("BUILD_DOCS", "OFF")
+            .define("BUILD_TESTS", "OFF")
+            .define("BUILD_TOOLS", "OFF")
+            .build();
+
+        println!(
+            "cargo:rustc-link-search={}",
+            dst.join("lib/fabrics/ofi").display()
+        );
+        println!("cargo:rustc-link-lib=mxl");
+        println!("cargo:rustc-link-lib=mxl-fabrics");
+    }
+
+    BindgenSpecs {
+        header,
+        includes_dirs,
+    }
+}
+
 fn main() {
     let bindgen_specs = get_bindgen_specs();
     for include_dir in &bindgen_specs.includes_dirs {
@@ -90,6 +145,28 @@ fn main() {
     bindings
         .write_to_file(out_path.join("bindings.rs"))
         .expect("Could not write bindings");
+
+    if cfg!(feature = "mxl-fabrics-ofi") {
+        let fabrics_bindings = bindgen::builder()
+            .clang_args(
+                get_bindgen_specs_fabrics()
+                    .includes_dirs
+                    .iter()
+                    .map(|dir| format!("-I{dir}")),
+            )
+            .header("wrapper-fabrics.h")
+            .derive_default(true)
+            .derive_debug(true)
+            .prepend_enum_name(false)
+            .dynamic_library_name("libmxlfabrics")
+            .dynamic_link_require_all(false)
+            .parse_callbacks(Box::new(CB))
+            .generate()
+            .unwrap();
+        fabrics_bindings
+            .write_to_file(out_path.join("fabrics_bindings.rs"))
+            .expect("Could not write fabrics bindings");
+    }
 }
 
 #[derive(Debug)]

rust/mxl-sys/src/lib.rs

@@ -17,3 +17,8 @@
 extern crate libloading;
 
 include!(concat!(env!("OUT_DIR"), "/bindings.rs"));
+
+#[cfg(feature = "mxl-fabrics-ofi")]
+pub mod fabrics {
+    include!(concat!(env!("OUT_DIR"), "/fabrics_bindings.rs"));
+}

rust/mxl-sys/wrapper-fabrics.h

@@ -0,0 +1,4 @@
+// SPDX-FileCopyrightText: 2026 Contributors to the Media eXchange Layer project.
+// SPDX-License-Identifier: Apache-2.0
+
+#include "mxl/fabrics.h"

rust/mxl/Cargo.toml

@@ -21,6 +21,13 @@ serde.workspace = true
 clap.workspace = true
 serde_json.workspace = true
 tracing-subscriber.workspace = true
+ctrlc = "3"
+base64 = "0.22"
 
 [features]
 mxl-not-built = ["mxl-sys/mxl-not-built"]
+mxl-fabrics-ofi = ["mxl-sys/mxl-fabrics-ofi"]
+
+[[example]]
+name = "fabrics-demo"
+required-features = ["mxl-fabrics-ofi"]