Management config processing logic

Cargo.toml

@@ -40,11 +40,11 @@ dpdk-sys = { path = "./dpdk-sys", package = "dataplane-dpdk-sys" }
 dpdk-sysroot-helper = { path = "./dpdk-sysroot-helper", package = "dataplane-dpdk-sysroot-helper" }
 dplane-rpc = { git = "https://github.com/githedgehog/dplane-rpc.git", version = "1.0.0" }
 errno = { path = "./errno", package = "dataplane-errno" }
-gateway_config = { git = "https://github.com/githedgehog/gateway-proto", tag = "v0.2.0", version = "0.1.0" }
+gateway_config = { git = "https://github.com/githedgehog/gateway-proto", version = "0.2.0" }
 id = { path = "./id", package = "dataplane-id" }
 interface-manager = { path = "./interface-manager", package = "dataplane-interface-manager" }
-net = { path = "./net", package = "dataplane-net", features = ["test_buffer"] }
 mgmt = { path = "./mgmt", package = "dataplane-mgmt"}
+net = { path = "./net", package = "dataplane-net", features = ["test_buffer"] }
 pipeline = { path = "./pipeline", package = "dataplane-pipeline" }
 rekon = { path = "./rekon", package = "dataplane-rekon" }
 routing = { path = "./routing", package = "dataplane-routing" }
@@ -62,6 +62,7 @@ bolero = { version = "0.13.3", default-features = false, features = [] }
 bytes = { version = "1.10.1", default-features = false, features = [] }
 clap = { version = "4.5.38", default-features = true, features = [] }
 ctrlc = { version = "3.4.7", default-features = false, features = [] }
+chrono = { version = "0.4.41", default-features = false, features = ["clock"] }
 derive_builder = { version = "0.20.2", default-features = false, features = ["default"] }
 doxygen-bindgen = { version = "0.1.3", default-features = false, features = [] }
 dyn-iter = { version = "1.0.1", default-features = false, features = [] }
@@ -73,7 +74,7 @@ iptrie = { version = "0.10.3", default-features = false, features = [] }
 mio = { version = "1.0.3", default-features = false, features = [] }
 multi_index_map = { version = "0.13.0", default-features = false, features = [] }
 netdev = { version = "0.34.0", default-features = false, features = [] }
-nix = { version = "0.30.1", default-features = false, features = [] }
+nix = { version = "0.30.1", default-features = false, features = ["socket"] }
 ordermap = { version = "0.5.7", default-features = false, features = [] }
 rtnetlink = { version = "0.16.0", default-features = false, features = [] }
 serde = { version = "1.0.219", default-features = false, features = [] }

dataplane/Cargo.toml

@@ -13,6 +13,7 @@ dpdk = { workspace = true }
 dyn-iter = { workspace = true }
 id = { workspace = true }
 iptrie = { workspace = true }
+mgmt = { workspace = true }
 mio = { workspace = true, features = ["os-ext", "net"] }
 net = { workspace = true, features = ["test_buffer"] }
 netdev = { workspace = true }

dataplane/src/args.rs

@@ -4,6 +4,7 @@
 #![allow(unused)]
 
 pub(crate) use clap::Parser;
+use std::net::SocketAddr;
 use tracing::debug;
 
 #[derive(Parser)]
@@ -30,7 +31,16 @@ pub(crate) struct CmdArgs {
     driver: Option<String>,
     #[arg(long, value_name = "name of kernel interface")]
     interface: Vec<String>,
+
+    // gRPC server address
+    #[arg(
+        long,
+        value_name = "gRPC server address",
+        default_value = "[::1]:50051"
+    )]
+    grpc_address: String,
 }
+
 impl CmdArgs {
     pub fn get_driver_name(&self) -> &str {
         match &self.driver {
@@ -92,4 +102,15 @@ impl CmdArgs {
 
         out
     }
+
+    /// Get the gRPC server address
+    pub fn get_grpc_address(&self) -> SocketAddr {
+        match self.grpc_address.parse() {
+            Ok(addr) => addr,
+            Err(e) => {
+                eprintln!("Error: Invalid gRPC address '{}': {}", self.grpc_address, e);
+                panic!("Process receives unexpected gRPC address. Aborting...");
+            }
+        }
+    }
 }

dataplane/src/drivers/kernel.rs

@@ -217,7 +217,9 @@ impl DriverKernel {
                     pkts.push(incoming);
                 }
                 Err(e) => {
-                    error!("Failed to parse packet!!:\n{e}");
+                    if interface.name != "lo" {
+                        error!("Failed to parse packet!!:\n{e}");
+                    }
                 }
             }
         }