diff options
Diffstat (limited to 'patches/dpdk_custom_patch/rte_pipeline.patch')
| -rw-r--r-- | patches/dpdk_custom_patch/rte_pipeline.patch | 88 |
1 files changed, 88 insertions, 0 deletions
diff --git a/patches/dpdk_custom_patch/rte_pipeline.patch b/patches/dpdk_custom_patch/rte_pipeline.patch new file mode 100644 index 00000000..3f52d326 --- /dev/null +++ b/patches/dpdk_custom_patch/rte_pipeline.patch @@ -0,0 +1,88 @@ +--- lib/librte_pipeline/rte_pipeline.c 2016-08-10 21:50:46.625571187 +0530 ++++ lib/librte_pipeline/rte_pipeline.c 2016-08-10 21:51:02.333571628 +0530 +@@ -1241,6 +1241,85 @@ + } + } + ++void ++rte_pipeline_action_handler_port_ext(struct rte_pipeline *p, ++ uint64_t pkts_mask, ++ struct rte_pipeline_table_entry **entries); ++ ++void ++rte_pipeline_action_handler_port_ext(struct rte_pipeline *p, ++ uint64_t pkts_mask, ++ struct rte_pipeline_table_entry **entries) ++{ ++ p->pkts_mask = pkts_mask; ++ ++ if ((pkts_mask & (pkts_mask + 1)) == 0) { ++ uint64_t n_pkts = __builtin_popcountll(pkts_mask); ++ uint32_t i; ++ ++ for (i = 0; i < n_pkts; i++) { ++ struct rte_mbuf *pkt = p->pkts[i]; ++ uint32_t port_out_id = entries[i]->port_id; ++ struct rte_port_out *port_out = ++ &p->ports_out[port_out_id]; ++ ++ /* Output port user actions */ ++ if (port_out->f_action == NULL) /* Output port TX */ ++ port_out->ops.f_tx(port_out->h_port, pkt); ++ else { ++ uint64_t pkt_mask = 1LLU << i; ++ ++ port_out->f_action(p, ++ p->pkts, ++ pkt_mask, ++ port_out->arg_ah); ++ ++ RTE_PIPELINE_STATS_AH_DROP_READ(p, ++ port_out->n_pkts_dropped_by_ah); ++ ++ /* Output port TX */ ++ if (pkt_mask & p->pkts_mask) ++ port_out->ops.f_tx(port_out->h_port, ++ pkt); ++ } ++ } ++ } else { ++ uint32_t i; ++ ++ for (i = 0; i < RTE_PORT_IN_BURST_SIZE_MAX; i++) { ++ uint64_t pkt_mask = 1LLU << i; ++ struct rte_mbuf *pkt; ++ struct rte_port_out *port_out; ++ uint32_t port_out_id; ++ ++ if ((pkt_mask & pkts_mask) == 0) ++ continue; ++ ++ pkt = p->pkts[i]; ++ port_out_id = entries[i]->port_id; ++ port_out = &p->ports_out[port_out_id]; ++ ++ /* Output port user actions */ ++ if (port_out->f_action == NULL) /* Output port TX */ ++ port_out->ops.f_tx(port_out->h_port, pkt); ++ else { ++ port_out->f_action(p, ++ p->pkts, ++ pkt_mask, ++ port_out->arg_ah); ++ ++ RTE_PIPELINE_STATS_AH_DROP_READ(p, ++ port_out->n_pkts_dropped_by_ah); ++ ++ /* Output port TX */ ++ if (pkt_mask & p->pkts_mask) ++ port_out->ops.f_tx(port_out->h_port, ++ pkt); ++ } ++ } ++ } ++} ++ + static inline void + rte_pipeline_action_handler_port_meta(struct rte_pipeline *p, + uint64_t pkts_mask) |