aboutsummaryrefslogtreecommitdiff
path: root/platform/linux-generic/pktio/tap.c
diff options
context:
space:
mode:
Diffstat (limited to 'platform/linux-generic/pktio/tap.c')
-rw-r--r--platform/linux-generic/pktio/tap.c45
1 files changed, 22 insertions, 23 deletions
diff --git a/platform/linux-generic/pktio/tap.c b/platform/linux-generic/pktio/tap.c
index 40c46b43c..c61e05575 100644
--- a/platform/linux-generic/pktio/tap.c
+++ b/platform/linux-generic/pktio/tap.c
@@ -285,31 +285,11 @@ static odp_packet_t pack_odp_pkt(pktio_entry_t *pktio_entry, const void *data,
{
odp_packet_t pkt;
odp_packet_hdr_t *pkt_hdr;
- odp_packet_hdr_t parsed_hdr;
int num;
- uint64_t l4_part_sum = 0;
uint16_t frame_offset = pktio_entry->s.pktin_frame_offset;
- const odp_proto_chksums_t chksums = pktio_entry->s.in_chksums;
const odp_proto_layer_t layer = pktio_entry->s.parse_layer;
const odp_pktin_config_opt_t opt = pktio_entry->s.config.pktin;
- if (layer) {
- packet_parse_reset(&parsed_hdr, 1);
- packet_set_len(&parsed_hdr, len);
- if (_odp_packet_parse_common(&parsed_hdr.p, data, len, len, layer,
- chksums, &l4_part_sum, opt) < 0) {
- return ODP_PACKET_INVALID;
- }
-
- if (pktio_cls_enabled(pktio_entry)) {
- if (_odp_cls_classify_packet(pktio_entry, data,
- &pkt_priv(pktio_entry)->pool,
- &parsed_hdr)) {
- return ODP_PACKET_INVALID;
- }
- }
- }
-
num = _odp_packet_alloc_multi(pkt_priv(pktio_entry)->pool,
len + frame_offset, &pkt, 1);
if (num != 1)
@@ -327,10 +307,29 @@ static odp_packet_t pack_odp_pkt(pktio_entry_t *pktio_entry, const void *data,
}
if (layer) {
- _odp_packet_copy_cls_md(pkt_hdr, &parsed_hdr);
+ if (_odp_packet_parse_common(pkt_hdr, data, len, len, layer,
+ opt) < 0) {
+ odp_packet_free(pkt);
+ return ODP_PACKET_INVALID;
+ }
+
+ if (pktio_cls_enabled(pktio_entry)) {
+ odp_pool_t new_pool;
- if (layer >= ODP_PROTO_LAYER_L4)
- _odp_packet_l4_chksum(pkt_hdr, chksums, l4_part_sum);
+ if (_odp_cls_classify_packet(pktio_entry, data,
+ &new_pool, pkt_hdr)) {
+ odp_packet_free(pkt);
+ return ODP_PACKET_INVALID;
+ }
+
+ if (odp_unlikely(_odp_pktio_packet_to_pool(
+ &pkt, &pkt_hdr, new_pool))) {
+ odp_packet_free(pkt);
+ odp_atomic_inc_u64(
+ &pktio_entry->s.stats_extra.in_discards);
+ return ODP_PACKET_INVALID;
+ }
+ }
}
packet_set_ts(pkt_hdr, ts);