X-Git-Url: https://gerrit.fd.io/r/gitweb?a=blobdiff_plain;f=src%2Fvlibmemory%2Fapi.h;h=8d2b191fb8114a8377757bb4d7f8cc1a253da98f;hb=b384b543313b6b47a277c903e9d4fcd4343054fa;hp=4f869a64be3b8310ac94f6e5beb0470abf3cfacb;hpb=e86a8edd3c14fb41ace2a12efd17bc7772bf623f;p=vpp.git diff --git a/src/vlibmemory/api.h b/src/vlibmemory/api.h index 4f869a64be3..8d2b191fb81 100644 --- a/src/vlibmemory/api.h +++ b/src/vlibmemory/api.h @@ -43,6 +43,15 @@ vl_api_send_msg (vl_api_registration_t * rp, u8 * elem) } } +always_inline int +vl_api_can_send_msg (vl_api_registration_t * rp) +{ + if (PREDICT_FALSE (rp->registration_type > REGISTRATION_TYPE_SHMEM)) + return 1; + else + return vl_mem_api_can_send (rp->vl_input_queue); +} + always_inline vl_api_registration_t * vl_api_client_index_to_registration (u32 index) { @@ -52,6 +61,44 @@ vl_api_client_index_to_registration (u32 index) return (vl_mem_api_client_index_to_registration (index)); } +always_inline u32 +vl_api_registration_file_index (vl_api_registration_t * reg) +{ + return reg->clib_file_index; +} + +always_inline clib_file_t * +vl_api_registration_file (vl_api_registration_t * reg) +{ + return clib_file_get (&file_main, vl_api_registration_file_index (reg)); +} + +always_inline void +vl_api_registration_del_file (vl_api_registration_t * reg) +{ + clib_file_t *cf = vl_api_registration_file (reg); + if (cf) + clib_file_del (&file_main, cf); +} + +always_inline clib_error_t * +vl_api_send_fd_msg (vl_api_registration_t * reg, int fd_to_send) +{ + clib_file_t *cf = vl_api_registration_file (reg); + if (cf) + return vl_sock_api_send_fd_msg (cf->file_descriptor, fd_to_send); + return 0; +} + +always_inline clib_error_t * +vl_api_recv_fd_msg (vl_api_registration_t * reg, int *fd_to_recv, u32 wait) +{ + clib_file_t *cf = vl_api_registration_file (reg); + if (cf) + return vl_sock_api_recv_fd_msg (cf->file_descriptor, fd_to_recv, wait); + return 0; +} + /* * vl_api_clnt process data used by transports (socket api in particular) */