rte_ip_frag.h

Go to the documentation of this file.

/* SPDX-License-Identifier: BSD-3-Clause
 * Copyright(c) 2010-2014 Intel Corporation
 */

#ifndef _RTE_IP_FRAG_H_
#define _RTE_IP_FRAG_H_

#ifdef __cplusplus
extern "C" {
#endif

#include <stdint.h>
#include <stdio.h>

#include <rte_config.h>
#include <rte_malloc.h>
#include <rte_memory.h>
#include <rte_ip.h>
#include <rte_byteorder.h>

struct rte_mbuf;

#define RTE_IP_FRAG_DEATH_ROW_LEN 32

#define RTE_IP_FRAG_DEATH_ROW_MBUF_LEN \
    (RTE_IP_FRAG_DEATH_ROW_LEN * (RTE_LIBRTE_IP_FRAG_MAX_FRAG + 1))

struct rte_ip_frag_death_row {
    uint32_t cnt;          
    struct rte_mbuf *row[RTE_IP_FRAG_DEATH_ROW_MBUF_LEN];
};

struct rte_ip_frag_tbl * rte_ip_frag_table_create(uint32_t bucket_num,
        uint32_t bucket_entries,  uint32_t max_entries,
        uint64_t max_cycles, int socket_id);

void
rte_ip_frag_table_destroy(struct rte_ip_frag_tbl *tbl);

int32_t
rte_ipv6_fragment_packet(struct rte_mbuf *pkt_in,
        struct rte_mbuf **pkts_out,
        uint16_t nb_pkts_out,
        uint16_t mtu_size,
        struct rte_mempool *pool_direct,
        struct rte_mempool *pool_indirect);

struct rte_mbuf *rte_ipv6_frag_reassemble_packet(struct rte_ip_frag_tbl *tbl,
        struct rte_ip_frag_death_row *dr,
        struct rte_mbuf *mb, uint64_t tms, struct rte_ipv6_hdr *ip_hdr,
        struct rte_ipv6_fragment_ext *frag_hdr);

static inline struct rte_ipv6_fragment_ext *
rte_ipv6_frag_get_ipv6_fragment_header(struct rte_ipv6_hdr *hdr)
{
    if (hdr->proto == IPPROTO_FRAGMENT) {
        return (struct rte_ipv6_fragment_ext *) ++hdr;
    }
    else
        return NULL;
}

int32_t rte_ipv4_fragment_packet(struct rte_mbuf *pkt_in,
            struct rte_mbuf **pkts_out,
            uint16_t nb_pkts_out, uint16_t mtu_size,
            struct rte_mempool *pool_direct,
            struct rte_mempool *pool_indirect);

struct rte_mbuf * rte_ipv4_frag_reassemble_packet(struct rte_ip_frag_tbl *tbl,
        struct rte_ip_frag_death_row *dr,
        struct rte_mbuf *mb, uint64_t tms, struct rte_ipv4_hdr *ip_hdr);

static inline int
rte_ipv4_frag_pkt_is_fragmented(const struct rte_ipv4_hdr *hdr)
{
    uint16_t flag_offset, ip_flag, ip_ofs;

    flag_offset = rte_be_to_cpu_16(hdr->fragment_offset);
    ip_ofs = (uint16_t)(flag_offset & RTE_IPV4_HDR_OFFSET_MASK);
    ip_flag = (uint16_t)(flag_offset & RTE_IPV4_HDR_MF_FLAG);

    return ip_flag != 0 || ip_ofs  != 0;
}

void rte_ip_frag_free_death_row(struct rte_ip_frag_death_row *dr,
        uint32_t prefetch);


void
rte_ip_frag_table_statistics_dump(FILE * f, const struct rte_ip_frag_tbl *tbl);

__rte_experimental
void
rte_ip_frag_table_del_expired_entries(struct rte_ip_frag_tbl *tbl,
    struct rte_ip_frag_death_row *dr, uint64_t tms);

#define IP_FRAG_DEATH_ROW_LEN       RTE_IP_FRAG_DEATH_ROW_LEN

#define IP_FRAG_DEATH_ROW_MBUF_LEN  RTE_IP_FRAG_DEATH_ROW_MBUF_LEN

#define ipv6_extension_fragment     rte_ipv6_fragment_ext

#ifdef __cplusplus
}
#endif

#endif /* _RTE_IP_FRAG_H_ */