X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=src%2Fvcl%2Fvcl_private.h;h=3df8b4bb47370d4310d5b61fd9e564b29ab7996d;hb=0db15758ed63db434621fef0777e0dd2062ed326;hp=fdc4ff8cdbd6a09520cf8da5ebe1b1966e9b06c1;hpb=fa3884f8a1cf5493dd7733404811b63ee9c1e4d9;p=vpp.git diff --git a/src/vcl/vcl_private.h b/src/vcl/vcl_private.h index fdc4ff8cdbd..3df8b4bb473 100644 --- a/src/vcl/vcl_private.h +++ b/src/vcl/vcl_private.h @@ -139,6 +139,8 @@ typedef enum vcl_session_flags_ VCL_SESSION_F_HAS_RX_EVT = 1 << 3, VCL_SESSION_F_RD_SHUTDOWN = 1 << 4, VCL_SESSION_F_WR_SHUTDOWN = 1 << 5, + VCL_SESSION_F_PENDING_DISCONNECT = 1 << 6, + VCL_SESSION_F_PENDING_FREE = 1 << 7, } __clib_packed vcl_session_flags_t; typedef struct vcl_session_ @@ -168,6 +170,9 @@ typedef struct vcl_session_ u32 rcvbuf_size; // VPP-TBD: Hack until support setsockopt(SO_RCVBUF) transport_endpt_ext_cfg_t *ext_config; + u8 dscp; + + i32 vpp_error; #if VCL_ELOG elog_track_t elog_track; @@ -185,7 +190,6 @@ typedef struct vppcom_cfg_t_ u32 rx_fifo_size; u32 tx_fifo_size; u32 event_queue_size; - u32 listen_queue_size; u8 app_proxy_transport_tcp; u8 app_proxy_transport_udp; u8 app_scope_local; @@ -195,13 +199,12 @@ typedef struct vppcom_cfg_t_ u8 use_mq_eventfd; f64 app_timeout; f64 session_timeout; - f64 accept_timeout; - u32 event_ring_size; char *event_log_path; u8 *vpp_app_socket_api; /**< app socket api socket file name */ u8 *vpp_bapi_socket_name; /**< bapi socket transport socket name */ u32 tls_engine; u8 mt_wrk_supported; + u8 huge_page; } vppcom_cfg_t; void vppcom_cfg (vppcom_cfg_t * vcl_cfg); @@ -338,6 +341,10 @@ typedef struct vppcom_main_t_ /** Lock to protect worker registrations */ clib_spinlock_t workers_lock; + /** Counter to determine order of execution of `vcl_api_retry_attach` + * function by multiple workers */ + int reattach_count; + /** Lock to protect segment hash table */ clib_rwlock_t segment_table_lock; @@ -543,8 +550,6 @@ vcl_session_table_lookup_listener (vcl_worker_t * wrk, u64 handle) return s; } -const char *vppcom_session_state_str (vcl_session_state_t state); - static inline u8 vcl_session_is_ct (vcl_session_t * s) { @@ -718,11 +723,12 @@ int vcl_send_worker_rpc (u32 dst_wrk_index, void *data, u32 data_len); int vcl_segment_attach (u64 segment_handle, char *name, ssvm_segment_type_t type, int fd); void vcl_segment_detach (u64 segment_handle); +void vcl_segment_detach_segments (u32 *seg_indices); void vcl_send_session_unlisten (vcl_worker_t * wrk, vcl_session_t * s); int vcl_segment_attach_session (uword segment_handle, uword rxf_offset, - uword txf_offset, uword mq_offset, u8 is_ct, - vcl_session_t *s); + uword txf_offset, uword mq_offset, + u32 mq_index, u8 is_ct, vcl_session_t *s); int vcl_segment_attach_mq (uword segment_handle, uword mq_offset, u32 mq_index, svm_msg_q_t **mq); int vcl_segment_discover_mqs (uword segment_handle, int *fds, u32 n_fds); @@ -731,6 +737,7 @@ svm_fifo_chunk_t *vcl_segment_alloc_chunk (uword segment_handle, uword *offset); int vcl_session_share_fifos (vcl_session_t *s, svm_fifo_t *rxf, svm_fifo_t *txf); +void vcl_worker_detach_sessions (vcl_worker_t *wrk); /* * VCL Binary API @@ -753,6 +760,16 @@ int vcl_sapi_app_worker_add (void); void vcl_sapi_app_worker_del (vcl_worker_t * wrk); void vcl_sapi_detach (vcl_worker_t * wrk); int vcl_sapi_recv_fds (vcl_worker_t * wrk, int *fds, int n_fds); +int vcl_sapi_add_cert_key_pair (vppcom_cert_key_pair_t *ckpair); +int vcl_sapi_del_cert_key_pair (u32 ckpair_index); + +/* + * Utility functions + */ +const char *vcl_session_state_str (vcl_session_state_t state); +u8 *vcl_format_ip4_address (u8 *s, va_list *args); +u8 *vcl_format_ip6_address (u8 *s, va_list *args); +u8 *vcl_format_ip46_address (u8 *s, va_list *args); #endif /* SRC_VCL_VCL_PRIVATE_H_ */