diff options
Diffstat (limited to 'platform/linux-generic/pktio/tap.c')
-rw-r--r-- | platform/linux-generic/pktio/tap.c | 45 |
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); |