18 #include <sys/types.h> 19 #include <sys/socket.h> 22 #include <netinet/in.h> 84 __attribute__((constructor))
93 __attribute__((destructor))
154 clib_warning(
"Message ID %d has wrong length: %d\n",
id, l);
167 vl_api_memclnt_keepalive_reply_t *rmp;
181 case VL_API_RX_THREAD_EXIT:
185 rx_thread_done =
true;
192 case VL_API_MEMCLNT_RX_THREAD_SUSPEND:
202 case VL_API_MEMCLNT_READ_TIMEOUT:
203 clib_warning(
"Received read timeout in async thread\n");
207 case VL_API_MEMCLNT_KEEPALIVE:
211 rmp->_vl_msg_id =
ntohs(VL_API_MEMCLNT_KEEPALIVE_REPLY);
238 while (!timeout_in_progress)
242 gettimeofday(&tv, NULL);
246 if (!timeout_cancelled) {
249 if (rv == ETIMEDOUT && !timeout_thread_cancelled) {
251 ep->_vl_msg_id =
ntohs(VL_API_MEMCLNT_READ_TIMEOUT);
273 ep->_vl_msg_id =
ntohs(VL_API_MEMCLNT_RX_THREAD_SUSPEND);
277 rx_is_running =
false;
288 if (rx_is_running)
goto unlock;
290 rx_is_running =
true;
313 rx_thread_done =
false;
318 if (chroot_prefix != NULL)
340 rx_is_running =
true;
361 read_timeout = timeout;
362 timeout_in_progress =
true;
363 timeout_cancelled =
false;
373 timeout_in_progress =
false;
374 timeout_cancelled =
true;
392 ep->_vl_msg_id =
ntohs(VL_API_RX_THREAD_EXIT);
398 gettimeofday(&tv, NULL);
399 ts.tv_sec = tv.tv_sec + 5;
403 if (rx_thread_done ==
false)
416 timeout_thread_cancelled =
true;
437 vl_api_memclnt_keepalive_reply_t *rmp;
449 if (am->
our_pid == 0)
return (-4);
464 case VL_API_RX_THREAD_EXIT:
467 case VL_API_MEMCLNT_RX_THREAD_SUSPEND:
469 case VL_API_MEMCLNT_READ_TIMEOUT:
471 case VL_API_MEMCLNT_KEEPALIVE:
476 rmp->_vl_msg_id =
ntohs(VL_API_MEMCLNT_KEEPALIVE_REPLY);
491 fprintf(stderr,
"Unregistered API message: %d\n", msg_id);
499 fprintf(stderr,
"Read failed with %d\n", rv);
525 vac_client_index (
void)
540 if (!mp)
return (-1);
543 mp->client_index = vac_client_index();
547 fprintf(stderr,
"vpe_api_write fails: %d\n", rv);
568 if (hp->
value[0] > max)
bool timeout_thread_cancelled
int vac_get_msg_index(unsigned char *name)
int svm_queue_add(svm_queue_t *q, u8 *elem, int nowait)
pthread_t timeout_thread_handle
clib_memset(h->entries, 0, sizeof(h->entries[0]) *entries)
static void set_timeout(unsigned short timeout)
pthread_t rx_thread_handle
int vac_msg_table_max_index(void)
void vlib_cli_output(struct vlib_main_t *vm, char *fmt,...)
int vac_write(char *p, int l)
void clib_error_register_handler(clib_error_handler_func_t func, void *arg)
svm_queue_t * vl_input_queue
Peer input queue pointer.
void * vl_msg_api_alloc(int nbytes)
void vl_client_api_unmap(void)
int our_pid
Current process PID.
pthread_cond_t timeout_cancel_cv
int svm_queue_sub(svm_queue_t *q, u8 *elem, svm_q_conditional_wait_t cond, u32 time)
pthread_mutex_t queue_lock
static void vac_client_constructor(void)
vlib_main_t ** vlib_mains
struct vl_shmem_hdr_ * shmem_hdr
Binary API shared-memory segment header pointer.
void vac_rx_suspend(void)
void vl_msg_api_send_shmem(svm_queue_t *q, u8 *elem)
vac_callback_t vac_callback
static void unset_timeout(void)
vlib_main_t vlib_global_main
u8 * format_mheap(u8 *s, va_list *va)
int vac_connect(char *name, char *chroot_prefix, vac_callback_t cb, int rx_qlen)
void vl_set_memory_root_path(const char *name)
void(* vac_error_callback_t)(void *, unsigned char *, int)
int vl_client_connect(const char *name, int ctx_quota, int input_queue_size)
static void vac_client_destructor(void)
static void cleanup(void)
static void * vac_timeout_thread_fn(void *arg)
API main structure, used by both vpp and binary API clients.
void * clib_mem_init(void *heap, uword size)
#define clib_warning(format, args...)
u32 vl_msg_api_get_msg_index(u8 *name_and_crc)
int vl_client_api_map(const char *region_name)
pthread_cond_t suspend_cv
static uword * vac_msg_table_get_hash(void)
blocking call - best used in combination with condvars, for eventfds we don't yield the cpu ...
svm_queue_t * vl_input_queue
static void * clib_mem_get_heap(void)
static uword hash_elts(void *v)
u32 data_len
message length not including header
Message header structure.
int vac_read(char **p, int *l, u16 timeout)
pthread_cond_t terminate_cv
void vl_msg_api_free(void *)
pthread_cond_t timeout_cv
#define hash_foreach_pair(p, v, body)
Iterate over hash pairs.
int vl_client_disconnect(void)
void vac_set_error_handler(vac_error_callback_t cb)
int vac_msg_table_size(void)
struct _svm_queue svm_queue_t
void(* vac_callback_t)(unsigned char *data, int len)
pthread_mutex_t timeout_lock
static api_main_t * vlibapi_get_main(void)
static void vac_api_handler(void *msg)
void clib_mem_trace(int enable)
uword * msg_index_by_name_and_crc
client message index hash table
typedef VL_API_PACKED(struct _vl_api_header { u16 _vl_msg_id;u32 client_index;})
static CLIB_NOSANITIZE_ADDR void VL_MSG_API_UNPOISON(const void *a)
static void * vac_rx_thread_fn(void *arg)