feat(pkt-io): add initial tap creation routines

Signed-off-by: Fredi Raspall <[email protected]>

Author: Fredi-raspall

Cargo.lock

@@ -7,6 +7,7 @@ license = "Apache-2.0"
 
 [dependencies]
 # internal
+args = { workspace = true }
 interface-manager = { workspace = true }
 net = { workspace = true }
 pipeline = { workspace = true }

pkt-io/Cargo.toml

@@ -8,12 +8,13 @@
 
 mod ctl;
 mod io;
-
 mod nf;
+mod tapinit;
 mod tests;
 
 // re-exports
 pub use ctl::IoManagerCtl;
 pub use io::{IoManagerError, start_io};
 pub use nf::PktIo;
 pub use nf::PktQueue;
+pub use tapinit::{tap_init, tap_init_async};

pkt-io/src/lib.rs

@@ -0,0 +1,39 @@
+// SPDX-License-Identifier: Apache-2.0
+// Copyright Open Network Fabric Authors
+
+//! Tap initialization
+
+use args::InterfaceArg;
+use interface_manager::interface::TapDevice;
+use tokio::runtime::Runtime;
+use tracing::{error, info};
+
+/// Creates a tap device for each of the [`InterfaceArg`]s provided.
+///
+/// # Errors
+///
+/// This function fails if any of the taps cannot be created.
+pub async fn tap_init_async(ifargs: &[InterfaceArg]) -> std::io::Result<()> {
+    info!("Creating tap devices");
+    for ifarg in ifargs.iter() {
+        if let Err(e) = TapDevice::open(&ifarg.interface).await {
+            error!("Failed to create tap '{}':{e}", ifarg.interface);
+            return Err(e);
+        } else {
+            info!("Created tap device '{}'", ifarg.interface);
+        }
+    }
+    Ok(())
+}
+
+/// Creates a tap device for each of the [`InterfaceArg`]s provided.
+/// This is a sync wrapper to `tap_init_async`.
+///
+/// # Errors
+///
+/// This function fails if any of the taps cannot be created.
+pub fn tap_init(port_specs: &[InterfaceArg]) -> std::io::Result<()> {
+    Runtime::new()
+        .expect("Tokio runtime creation failed!")
+        .block_on(tap_init_async(port_specs))
+}