cnet_pcb.h

Go to the documentation of this file.

/* SPDX-License-Identifier: BSD-3-Clause
 * Copyright (c) 2016-2022 Intel Corporation
 */
 
#ifndef __CNET_PCB_H
#define __CNET_PCB_H
 
#include <cne_inet.h>        // for in_caddr
#include <stdint.h>          // for uint16_t, uint8_t, int32_t
#include <string.h>          // for NULL, memset
 
#include "cne_common.h"        // for __cne_aligned, __cne_cache_aligned
#include "cne_log.h"           // for CNE_LOG, CNE_LOG_DEBUG
#include "cne_vec.h"           // for cne_vec (ptr only), vec_add_ptr, vec_alloc_ptr, vec...
#include "cnet_const.h"        // for BEST_MATCH
#include "cnet_stk.h"          // for per_thread_stk, stk_entry, this_stk
#include "mempool.h"           // for mempool_put, mempool_get
 
#ifdef __cplusplus
extern "C" {
#endif
 
struct pcb_key {
    struct in_caddr faddr; 
    struct in_caddr laddr; 
} __cne_aligned(sizeof(void *));
 
struct netif;
struct chnl;
struct tcb_entry;
 
struct pcb_entry {
    TAILQ_ENTRY(pcb_entry) next; 
    struct pcb_key key;          
    struct netif *netif;         
    struct chnl *ch;             
    struct tcb_entry *tcb;       
    uint16_t opt_flag;           
    uint8_t ttl;                 
    uint8_t tos;                 
    uint8_t closed;              
    uint8_t ip_proto;            
} __cne_cache_aligned;
 
struct pcb_hd {
    struct pcb_entry **vec; 
    uint16_t local_port;    
};
 
static inline void
cnet_pcb_free(struct pcb_entry *pcb)
{
    if (pcb) {
        memset(pcb, 0, sizeof(struct pcb_entry));
        pcb->closed   = 1;
        pcb->ip_proto = -1;
        mempool_put(this_stk->pcb_objs, (void *)pcb);
    }
}
 
static inline struct pcb_entry *
cnet_pcb_alloc(struct pcb_hd *hd, uint16_t proto)
{
    struct pcb_entry *pcb;
 
    if (mempool_get(this_stk->pcb_objs, (void *)&pcb) < 0)
        return NULL;
 
    pcb->closed   = 0;
    pcb->ip_proto = proto;
 
    vec_add(hd->vec, pcb);
 
    return pcb;
}
 
static inline void
cnet_pcb_delete(struct pcb_hd *hd, struct pcb_entry *pcb)
{
    struct pcb_entry *p;
 
    vec_foreach_ptr (p, hd->vec) {
        if (p == pcb) {
            cnet_pcb_free(pcb);
            break;
        }
    }
}
 
CNDP_API struct pcb_entry *cnet_pcb_lookup(struct pcb_hd *hd, struct pcb_key *key, int32_t flags);
 
CNDP_API void cnet_pcb_dump(stk_t *stk);
 
CNDP_API void cnet_pcb_show(struct pcb_entry *pcb);
 
static inline struct pcb_entry *
cnet_pcb_locate(struct pcb_hd *hd, struct in_caddr *faddr, struct in_caddr *laddr)
{
    struct pcb_key key;
 
    *(struct in_caddr *)&key.faddr = *faddr;
    *(struct in_caddr *)&key.laddr = *laddr;
 
    return cnet_pcb_lookup(hd, &key, BEST_MATCH);
}
 
#ifdef __cplusplus
}
#endif
 
#endif /* __CNET_PCB_H */