cnet_chnl.h

Go to the documentation of this file.

/* SPDX-License-Identifier: BSD-3-Clause
 * Copyright (c) 2016-2022 Intel Corporation
 */
 
#ifndef __CNET_CHNL_H
#define __CNET_CHNL_H
 
#include <stdio.h>             // for snprintf, size_t, NULL
#include <sys/socket.h>        // for socklen_t, PF_INET, PF_INET6, PF_LOCAL
#include <sys/queue.h>         // for TAILQ_ENTRY
#include <netinet/in.h>        // for IPPROTO_ICMP, IPPROTO_ICMPV6, IPPROTO_IGMP
#include <bsd/bitstring.h>
#include <pktmbuf.h>
#include <cnet_const.h>        // for _SELREAD, is_set, _SELWRITE
#include <cne_vec.h>
#include <cnet_protosw.h>        // for protosw_entry
#include <cne_graph_worker.h>
#include <pthread.h>          // for pthread_mutex_t, pthread_cond_t
#include <stdint.h>           // for uint16_t, int32_t, uint32_t, uintptr_t
#include <sys/types.h>        // for ssize_t
 
#include "cne_log.h"         // for CNE_LOG, CNE_LOG_DEBUG, CNE_LOG_ERR
#include "cnet_tcp.h"        // for TCP_NORMAL_MSS
#include "cnet_udp.h"        // for _IPPORT_RESERVED
 
struct in_caddr;
struct netif;
struct stk_s;
 
#ifdef __cplusplus
extern "C" {
#endif
 
#ifndef __CHNL_PRIV_H
typedef int (*chnl_cb_t)(int chnl_type, int cd);
#endif
 
#define CHNL_ENABLE_UDP_CHECKSUM (1 << 0) 
#define SO_CHANNEL    1
#define SO_UDP_CHKSUM 1024
#define IP_DONTFRAG   1025
 
enum {
    SHUT_BIT_RD   = 0x01, 
    SHUT_BIT_WR   = 0x02, 
    SHUT_BIT_RDWR = 0x03, 
};
 
typedef enum {
    CHNL_UDP_RECV_TYPE,   
    CHNL_UDP_CLOSE_TYPE,  
    CHNL_TCP_ACCEPT_TYPE, 
    CHNL_TCP_RECV_TYPE,   
    CHNL_TCP_CLOSE_TYPE,  
    CHNL_CALLBACK_TYPES   
} chnl_type_t;
 
CNDP_API void chnl_dump(const char *msg, struct chnl *ch);
 
CNDP_API int chnl_connect_common(struct chnl *ch, struct in_caddr *to, int32_t tolen);
 
CNDP_API int chnl_bind_common(struct chnl *ch, struct in_caddr *pAddr, int32_t len,
                              struct pcb_hd *pHd);
 
CNDP_API int channel(int domain, int type, int proto, chnl_cb_t cb);
 
CNDP_API int chnl_bind(int cd, struct sockaddr *addr, int addrlen);
 
CNDP_API int chnl_listen(int cd, int backlog);
 
CNDP_API int chnl_accept(int cd, struct sockaddr *sa, socklen_t *addrlen);
 
CNDP_API int chnl_connect(int cd, struct sockaddr *sa, int addrlen);
 
CNDP_API int chnl_recv(int cd, pktmbuf_t **mbufs, size_t len);
 
CNDP_API int chnl_send(int cd, pktmbuf_t **mbufs, uint16_t nb_mbufs);
 
CNDP_API int chnl_sendto(int cd, struct sockaddr *sa, pktmbuf_t **mbufs, uint16_t nb_mbufs);
 
CNDP_API int chnl_getchnlname(int cd, struct sockaddr *name, socklen_t *namelen);
 
CNDP_API int chnl_getpeername(int cd, struct sockaddr *sa, socklen_t *salen);
 
CNDP_API int chnl_close(int cd);
 
CNDP_API int chnl_shutdown(int cd, int how);
 
CNDP_API int chnl_open(const char *str, int flags, chnl_cb_t fn);
 
#ifdef __cplusplus
}
#endif
 
#endif /* __CNET_CHNL_H */