mbuf: remove the rte_pktmbuf structure

[dpdk.git] / lib / librte_ip_frag / ip_frag_common.h

diff --git a/lib/librte_ip_frag/ip_frag_common.h b/lib/librte_ip_frag/ip_frag_common.h
index c9741c0..81ca23a 100644 (file)
--- a/lib/librte_ip_frag/ip_frag_common.h
+++ b/lib/librte_ip_frag/ip_frag_common.h
@@ -34,19 +34,160 @@
 #ifndef _IP_FRAG_COMMON_H_
 #define _IP_FRAG_COMMON_H_
 
-/* Debug on/off */
-#ifdef RTE_IP_FRAG_DEBUG
+#include "rte_ip_frag.h"
 
-#define        RTE_IP_FRAG_ASSERT(exp)                                 \
+/* logging macros. */
+#ifdef RTE_LIBRTE_IP_FRAG_DEBUG
+
+#define        IP_FRAG_LOG(lvl, fmt, args...)  RTE_LOG(lvl, USER1, fmt, ##args)
+
+#define        IP_FRAG_ASSERT(exp)                                     \
 if (!(exp))    {                                                       \
        rte_panic("function %s, line%d\tassert \"" #exp "\" failed\n",  \
                __func__, __LINE__);                                    \
 }
+#else
+#define        IP_FRAG_LOG(lvl, fmt, args...)  do {} while(0)
+#define IP_FRAG_ASSERT(exp)    do {} while (0)
+#endif /* IP_FRAG_DEBUG */
+
+#define IPV4_KEYLEN 1
+#define IPV6_KEYLEN 4
+
+/* helper macros */
+#define        IP_FRAG_MBUF2DR(dr, mb) ((dr)->row[(dr)->cnt++] = (mb))
+
+#define IPv6_KEY_BYTES(key) \
+       (key)[0], (key)[1], (key)[2], (key)[3]
+#define IPv6_KEY_BYTES_FMT \
+       "%08" PRIx64 "%08" PRIx64 "%08" PRIx64 "%08" PRIx64
+
+/* internal functions declarations */
+struct rte_mbuf * ip_frag_process(struct ip_frag_pkt *fp,
+               struct rte_ip_frag_death_row *dr, struct rte_mbuf *mb,
+               uint16_t ofs, uint16_t len, uint16_t more_frags);
+
+struct ip_frag_pkt * ip_frag_find(struct rte_ip_frag_tbl *tbl,
+               struct rte_ip_frag_death_row *dr,
+               const struct ip_frag_key *key, uint64_t tms);
+
+struct ip_frag_pkt * ip_frag_lookup(struct rte_ip_frag_tbl *tbl,
+       const struct ip_frag_key *key, uint64_t tms,
+       struct ip_frag_pkt **free, struct ip_frag_pkt **stale);
+
+/* these functions need to be declared here as ip_frag_process relies on them */
+struct rte_mbuf * ipv4_frag_reassemble(const struct ip_frag_pkt *fp);
+struct rte_mbuf * ipv6_frag_reassemble(const struct ip_frag_pkt *fp);
+
+
+
+/*
+ * misc frag key functions
+ */
+
+/* check if key is empty */
+static inline int
+ip_frag_key_is_empty(const struct ip_frag_key * key)
+{
+       uint32_t i;
+       for (i = 0; i < key->key_len; i++)
+               if (key->src_dst[i] != 0)
+                       return 0;
+       return 1;
+}
+
+/* empty the key */
+static inline void
+ip_frag_key_invalidate(struct ip_frag_key * key)
+{
+       uint32_t i;
+       for (i = 0; i < key->key_len; i++)
+               key->src_dst[i] = 0;
+}
 
-#else /*RTE_IP_FRAG_DEBUG*/
+/* compare two keys */
+static inline int
+ip_frag_key_cmp(const struct ip_frag_key * k1, const struct ip_frag_key * k2)
+{
+       uint32_t i, val;
+       val = k1->id ^ k2->id;
+       for (i = 0; i < k1->key_len; i++)
+               val |= k1->src_dst[i] ^ k2->src_dst[i];
+       return val;
+}
+
+/*
+ * misc fragment functions
+ */
+
+/* put fragment on death row */
+static inline void
+ip_frag_free(struct ip_frag_pkt *fp, struct rte_ip_frag_death_row *dr)
+{
+       uint32_t i, k;
+
+       k = dr->cnt;
+       for (i = 0; i != fp->last_idx; i++) {
+               if (fp->frags[i].mb != NULL) {
+                       dr->row[k++] = fp->frags[i].mb;
+                       fp->frags[i].mb = NULL;
+               }
+       }
+
+       fp->last_idx = 0;
+       dr->cnt = k;
+}
+
+/* if key is empty, mark key as in use */
+static inline void
+ip_frag_inuse(struct rte_ip_frag_tbl *tbl, const struct  ip_frag_pkt *fp)
+{
+       if (ip_frag_key_is_empty(&fp->key)) {
+               TAILQ_REMOVE(&tbl->lru, fp, lru);
+               tbl->use_entries--;
+       }
+}
 
-#define RTE_IP_FRAG_ASSERT(exp)        do { } while (0)
+/* reset the fragment */
+static inline void
+ip_frag_reset(struct ip_frag_pkt *fp, uint64_t tms)
+{
+       static const struct ip_frag zero_frag = {
+               .ofs = 0,
+               .len = 0,
+               .mb = NULL,
+       };
+
+       fp->start = tms;
+       fp->total_size = UINT32_MAX;
+       fp->frag_size = 0;
+       fp->last_idx = IP_MIN_FRAG_NUM;
+       fp->frags[IP_LAST_FRAG_IDX] = zero_frag;
+       fp->frags[IP_FIRST_FRAG_IDX] = zero_frag;
+}
+
+/* chain two mbufs */
+static inline void
+ip_frag_chain(struct rte_mbuf *mn, struct rte_mbuf *mp)
+{
+       struct rte_mbuf *ms;
+
+       /* adjust start of the last fragment data. */
+       rte_pktmbuf_adj(mp, (uint16_t)(mp->vlan_macip.f.l2_len +
+               mp->vlan_macip.f.l3_len));
+
+       /* chain two fragments. */
+       ms = rte_pktmbuf_lastseg(mn);
+       ms->next = mp;
+
+       /* accumulate number of segments and total length. */
+       mn->nb_segs = (uint8_t)(mn->nb_segs + mp->nb_segs);
+       mn->pkt_len += mp->pkt_len;
+
+       /* reset pkt_len and nb_segs for chained fragment. */
+       mp->pkt_len = mp->data_len;
+       mp->nb_segs = 1;
+}
 
-#endif /*RTE_IP_FRAG_DEBUG*/
 
-#endif
+#endif /* _IP_FRAG_COMMON_H_ */