X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=src%2Fvlibapi%2Fapi_common.h;h=735921b30f7baf2534b0e24fc033312a88b2edf8;hb=413f4a5b2123c1625d615315db293a080078482b;hp=56b036d7f0738d28c73a89224dabee05092cf312;hpb=0d056e5ede136cd0111dc3f9f41ef7b36a938027;p=vpp.git diff --git a/src/vlibapi/api_common.h b/src/vlibapi/api_common.h index 56b036d7f07..735921b30f7 100644 --- a/src/vlibapi/api_common.h +++ b/src/vlibapi/api_common.h @@ -25,8 +25,9 @@ */ #include +#include #include -#include +#include /** API registration types */ @@ -56,7 +57,7 @@ typedef struct vl_api_registration_ int unanswered_pings; /** shared memory only: pointer to client input queue */ - unix_shared_memory_queue_t *vl_input_queue; + svm_queue_t *vl_input_queue; svm_region_t *vlib_rp; void *shmem_hdr; @@ -64,7 +65,7 @@ typedef struct vl_api_registration_ u32 clib_file_index; /**< Socket only: file index */ i8 *unprocessed_input; /**< Socket only: pending input */ u32 unprocessed_msg_length; /**< Socket only: unprocssed length */ - u8 *output_vector; /**< Socket only: output vecto */ + u8 *output_vector; /**< Socket only: output vector */ int *additional_fds_to_close; /* socket client only */ @@ -72,6 +73,7 @@ typedef struct vl_api_registration_ u32 server_index; /**< Socket client only: server index */ } vl_api_registration_t; +#define VL_API_INVALID_FI ((u32)~0) /** Trace configuration for a single message */ typedef struct @@ -133,7 +135,7 @@ typedef struct /** Message header structure */ typedef struct msgbuf_ { - unix_shared_memory_queue_t *q; /**< message allocated in this shmem ring */ + svm_queue_t *q; /**< message allocated in this shmem ring */ u32 data_len; /**< message length not including header */ u32 gc_mark_timestamp; /**< message garbage collector mark TS */ u8 data[0]; /**< actual message begins here */ @@ -155,7 +157,7 @@ void vl_msg_api_set_handlers (int msg_id, char *msg_name, void vl_msg_api_clean_handlers (int msg_id); void vl_msg_api_config (vl_msg_api_msg_config_t *); void vl_msg_api_set_cleanup_handler (int msg_id, void *fp); -void vl_msg_api_queue_handler (unix_shared_memory_queue_t * q); +void vl_msg_api_queue_handler (svm_queue_t * q); void vl_msg_api_barrier_sync (void) __attribute__ ((weak)); void vl_msg_api_barrier_release (void) __attribute__ ((weak)); @@ -176,7 +178,9 @@ int vl_msg_api_pd_handler (void *mp, int rv); void vl_msg_api_set_first_available_msg_id (u16 first_avail); u16 vl_msg_api_get_msg_ids (const char *name, int n); -u32 vl_api_get_msg_index (u8 * name_and_crc); +u32 vl_msg_api_get_msg_index (u8 * name_and_crc); +void *vl_msg_push_heap (void); +void vl_msg_pop_heap (void *oldheap); typedef clib_error_t *(vl_msg_api_init_function_t) (u32 client_index); @@ -297,7 +301,7 @@ typedef struct u64 api_pvt_heap_size; /** Peer input queue pointer */ - unix_shared_memory_queue_t *vl_input_queue; + svm_queue_t *vl_input_queue; /** * All VLIB-side message handlers use my_client_index to identify @@ -311,9 +315,6 @@ typedef struct */ vl_api_registration_t *my_registration; - /** (Historical) signal-based queue non-empty signal, to be removed */ - i32 vlib_signal; - /** vpp/vlib input queue length */ u32 vlib_input_queue_length;