X-Git-Url: https://gerrit.fd.io/r/gitweb?p=vpp.git;a=blobdiff_plain;f=src%2Fvcl%2Fvppcom.h;h=d2a5a103f8dfa441b2feb0e310f23d6d1471752b;hp=49cff413ec8191d1fcdf04efcd720673fffbe7c6;hb=07063b8ea;hpb=5e06257cb892b7dc784025fe7d84c50882425831 diff --git a/src/vcl/vppcom.h b/src/vcl/vppcom.h index 49cff413ec8..d2a5a103f8d 100644 --- a/src/vcl/vppcom.h +++ b/src/vcl/vppcom.h @@ -18,6 +18,7 @@ #include #include +#include #include #include @@ -48,10 +49,10 @@ typedef enum { VPPCOM_PROTO_TCP = 0, VPPCOM_PROTO_UDP, - VPPCOM_PROTO_SCTP, VPPCOM_PROTO_NONE, VPPCOM_PROTO_TLS, - VPPCOM_PROTO_UDPC + VPPCOM_PROTO_UDPC, + VPPCOM_PROTO_QUIC, } vppcom_proto_t; static inline char * @@ -67,15 +68,15 @@ vppcom_proto_str (vppcom_proto_t proto) case VPPCOM_PROTO_UDP: proto_str = "UDP"; break; - case VPPCOM_PROTO_SCTP: - proto_str = "SCTP"; - break; case VPPCOM_PROTO_TLS: proto_str = "TLS"; break; case VPPCOM_PROTO_UDPC: proto_str = "UDPC"; break; + case VPPCOM_PROTO_QUIC: + proto_str = "QUIC"; + break; default: proto_str = "UNKNOWN"; break; @@ -83,6 +84,12 @@ vppcom_proto_str (vppcom_proto_t proto) return proto_str; } +static inline int +vcl_proto_is_dgram (uint8_t proto) +{ + return proto == VPPCOM_PROTO_UDP || proto == VPPCOM_PROTO_UDPC; +} + typedef enum { VPPCOM_IS_IP6 = 0, @@ -95,6 +102,7 @@ typedef struct vppcom_endpt_t_ uint8_t is_ip4; uint8_t *ip; uint16_t port; + uint64_t parent_handle; } vppcom_endpt_t; typedef uint32_t vcl_session_handle_t; @@ -104,6 +112,7 @@ typedef enum VPPCOM_OK = 0, VPPCOM_EAGAIN = -EAGAIN, VPPCOM_EWOULDBLOCK = -EWOULDBLOCK, + VPPCOM_EINPROGRESS = -EINPROGRESS, VPPCOM_EFAULT = -EFAULT, VPPCOM_ENOMEM = -ENOMEM, VPPCOM_EINVAL = -EINVAL, @@ -124,6 +133,7 @@ typedef enum VPPCOM_ATTR_GET_FLAGS, VPPCOM_ATTR_SET_FLAGS, VPPCOM_ATTR_GET_LCL_ADDR, + VPPCOM_ATTR_SET_LCL_ADDR, VPPCOM_ATTR_GET_PEER_ADDR, VPPCOM_ATTR_GET_LIBC_EPFD, VPPCOM_ATTR_SET_LIBC_EPFD, @@ -254,6 +264,8 @@ extern int vppcom_session_accept (uint32_t session_handle, extern int vppcom_session_connect (uint32_t session_handle, vppcom_endpt_t * server_ep); +extern int vppcom_session_stream_connect (uint32_t session_handle, + uint32_t parent_session_handle); extern int vppcom_session_read (uint32_t session_handle, void *buf, size_t n); extern int vppcom_session_write (uint32_t session_handle, void *buf, size_t n); @@ -294,6 +306,10 @@ extern int vppcom_session_tls_add_key (uint32_t session_handle, char *key, uint32_t key_len); extern int vppcom_data_segment_copy (void *buf, vppcom_data_segments_t ds, uint32_t max_bytes); +extern int vppcom_unformat_proto (uint8_t * proto, char *proto_str); +extern int vppcom_session_is_connectable_listener (uint32_t session_handle); +extern int vppcom_session_listener (uint32_t session_handle); +extern int vppcom_session_n_accepted (uint32_t session_handle); /** * Request from application to register a new worker @@ -303,6 +319,11 @@ extern int vppcom_data_segment_copy (void *buf, vppcom_data_segments_t ds, */ extern int vppcom_worker_register (void); +/** + * Unregister current worker + */ +extern void vppcom_worker_unregister (void); + /** * Retrieve current worker index */