odp_ipfragreass_reassemble.h

/* SPDX-License-Identifier: BSD-3-Clause
 * Copyright (c) 2017-2018 Linaro Limited
 */
 
#ifndef ODP_FRAGREASS_PP_REASSEMBLE_H_
#define ODP_FRAGREASS_PP_REASSEMBLE_H_
 
#include <odp_api.h>
#include <odp/helper/ip.h>
 
#include "odp_ipfragreass_ip.h"
#include "odp_ipfragreass_helpers.h"
 
ODP_STATIC_ASSERT(__SIZEOF_POINTER__ <= 8, "ODP_REASS_PTR__SIZE_ERROR");
 
#define FLOW_TIMEOUT_NS 15000000000ULL
 
#define TS_RES_NS ((uint64_t)1000000)    
#define EARLIEST_MAX UINT32_MAX
 
#define TS_NOW_TOLERANCE 5000
 
struct flts {
    uint32_t t;
};
 
struct packet {
    odp_packet_t handle; 
    struct packet *prev; 
    struct flts arrival; 
};
 
union fraglist {
    struct {
        uint32_t earliest;
 
        uint32_t part_len:14;
 
        uint32_t whole_len:14;
 
        struct packet *tail;
    };
 
    odp_u128_t raw;
};
 
static inline void init_fraglist(union fraglist *fl)
{
    fl->earliest  = EARLIEST_MAX;
    fl->part_len  = 0;
    fl->whole_len = IP_OCTET_MAX;
    fl->tail      = NULL;
}
 
static inline struct packet *prev_packet(struct packet packet)
{
    return packet.prev;
}
 
static inline struct packet **prev_packet_ptr(struct packet *packet)
{
    return &packet->prev;
}
 
static inline void set_prev_packet(struct packet *packet, struct packet *prev)
{
    packet->prev = prev;
}
 
int reassemble_ipv4_packets(odp_atomic_u128_t *fraglists, int num_fraglists,
                struct packet *fragments, int num_fragments,
                odp_queue_t out);
 
void garbage_collect_fraglists(odp_atomic_u128_t *fraglists, int num_fraglists,
                   odp_queue_t out, odp_bool_t destroy_all);
 
#endif