feat(dataplane): add single pkt-io to pipeline

Add a pkt-io instance to pipeline before egress stage. The injection
buffer is 10K packets. The punting buffer is only 100 packets large.
This is temporary: we currently mark some packets as local,
but do not handle them yet. Therefore, the first 100 of local
packets will be cached (forever) and the rest removed.

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

Author: Fredi-raspall

Cargo.lock

@@ -30,6 +30,7 @@ once_cell = { workspace = true }
 ordermap = { workspace = true, features = ["std"] }
 parking_lot = { workspace = true }
 pipeline = { workspace = true }
+pkt-io = { workspace = true }
 pkt-meta = { workspace = true }
 routing = { workspace = true }
 serde = { workspace = true, features = ["derive"] }

dataplane/Cargo.toml

@@ -12,6 +12,7 @@ use super::packet_processor::ipforward::IpForwarder;
 
 use concurrency::sync::Arc;
 
+use pkt_io::PktIo;
 use pkt_meta::dst_vpcd_lookup::{DstVpcdLookup, VpcDiscTablesWriter};
 use pkt_meta::flow_table::{ExpirationsNF, FlowTable, LookupNF};
 
@@ -61,6 +62,7 @@ pub(crate) fn start_router<Buf: PacketBufferMut>(
     let pipeline_builder = move || {
         // Build network functions
         let stage_ingress = Ingress::new("Ingress", iftr_factory.handle());
+        let pktio1 = PktIo::new(10_000usize, 100).set_name("pkt-io");
         let stage_egress = Egress::new("Egress", iftr_factory.handle(), atabler_factory.handle());
         let dst_vpcd_lookup = DstVpcdLookup::new("dst-vni-lookup", vpcdtablesr_factory.handle());
         let iprouter1 = IpForwarder::new("IP-Forward-1", fibtr_factory.handle());
@@ -83,6 +85,7 @@ pub(crate) fn start_router<Buf: PacketBufferMut>(
             .add_stage(flow_lookup_nf)
             .add_stage(stateless_nat)
             .add_stage(iprouter2)
+            .add_stage(pktio1)
             .add_stage(stage_egress)
             .add_stage(dumper2)
             .add_stage(flow_expirations_nf)