Home
last modified time | relevance | path

Searched refs:msg_size (Results 1 – 19 of 19) sorted by relevance

/AliOS-Things-master/components/posix/src/
A Dmqueue.c30 size_t msg_size; in mq_receive() local
34 ret = krhino_buf_queue_recv(mqdes, 0, msg_ptr, &msg_size); in mq_receive()
39 return msg_size; in mq_receive()
67 size_t msg_size; in mq_timedreceive() local
76 ret = krhino_buf_queue_recv(mqdes, ticks, msg_ptr, &msg_size); in mq_timedreceive()
81 return msg_size; in mq_timedreceive()
/AliOS-Things-master/kernel/rhino/
A Dk_buf_queue.c66 void *buf, size_t msg_size, size_t msg_num) in krhino_fix_buf_queue_create() argument
68 …return buf_queue_create(queue, name, buf, msg_size * msg_num, msg_size, K_OBJ_STATIC_ALLOC, RINGBU… in krhino_fix_buf_queue_create()
161 size_t msg_size, size_t msg_num) in krhino_fix_buf_queue_dyn_create() argument
163 return buf_queue_dyn_create(queue, name, msg_size * msg_num, msg_size, RINGBUF_TYPE_FIX); in krhino_fix_buf_queue_dyn_create()
209 static kstat_t buf_queue_send(kbuf_queue_t *queue, void *msg, size_t msg_size) in buf_queue_send() argument
227 if (msg_size > queue->max_msg_size) { in buf_queue_send()
228 TRACE_BUF_QUEUE_MAX(g_active_task[cur_cpu_num], queue, msg, msg_size); in buf_queue_send()
233 if (msg_size == 0) { in buf_queue_send()
243 err = ringbuf_push(&(queue->ringbuf), msg, msg_size); in buf_queue_send()
271 memcpy(task->msg, msg, msg_size); in buf_queue_send()
[all …]
A Dk_timer.c354 size_t msg_size; in timer_task() local
359 err = krhino_buf_queue_recv(&g_timer_queue, RHINO_WAIT_FOREVER, &cb_msg, &msg_size); in timer_task()
375 err = krhino_buf_queue_recv(&g_timer_queue, (tick_t)delta, &cb_msg, &msg_size); in timer_task()
/AliOS-Things-master/hardware/chip/rtl872xd/sdk/component/common/bluetooth/realtek/sdk/board/common/os/
A Dosif_customer.c58 bool os_msg_queue_create_intern(void **pp_handle, uint32_t msg_num, uint32_t msg_size, in os_msg_queue_create_intern() argument
62 char *buf = aos_malloc(msg_size * msg_num); in os_msg_queue_create_intern()
69 desc->message_size = msg_size; in os_msg_queue_create_intern()
72 if (aos_queue_new(&desc->queue_hdl, buf, msg_size * msg_num, msg_size) != 0) { in os_msg_queue_create_intern()
/AliOS-Things-master/hardware/chip/rtl872xd/sdk/component/common/bluetooth/realtek/sdk/inc/os/
A Dos_msg.h32 bool os_msg_queue_create_intern(void **pp_handle, uint32_t msg_num, uint32_t msg_size,
103 #define os_msg_queue_create(pp_handle, msg_num, msg_size) \ argument
104 os_msg_queue_create_intern(pp_handle, msg_num, msg_size, __func__, __LINE__)
/AliOS-Things-master/components/oss/src/model/
A DModelError.cc115 int msg_size = sizeof(msg)/sizeof(msg[0]); in GetArgErrorMsg() local
116 if (code < ARG_ERROR_START || index > msg_size) { in GetArgErrorMsg()
/AliOS-Things-master/kernel/rhino/include/
A Dk_trace.h151 void trace_buf_queue_max(ktask_t *task, kbuf_queue_t *buf_queue, void *msg, size_t msg_size);
152 void trace_buf_queue_post(ktask_t *task, kbuf_queue_t *buf_queue, void *msg, size_t msg_size);
157 …ine TRACE_BUF_QUEUE_MAX(task, buf_queue, msg, msg_size) trace_buf_queue_max(task, buf_queue, msg, … argument
158 …e TRACE_BUF_QUEUE_POST(task, buf_queue, msg, msg_size) trace_buf_queue_post(task, buf_queue, msg,… argument
234 #define TRACE_BUF_QUEUE_MAX(task, buf_queue, msg, msg_size)
235 #define TRACE_BUF_QUEUE_POST(task, buf_queue, msg, msg_size)
A Dk_buf_queue.h79 void *buf, size_t msg_size, size_t msg_num);
118 size_t msg_size, size_t msg_num);
/AliOS-Things-master/hardware/board/c906/adapter/
A Dcsi_rhino.c1092 int32_t msg_size; member
1095 k_msgq_handle_t csi_kernel_msgq_new(int32_t msg_count, int32_t msg_size) in csi_kernel_msgq_new() argument
1097 if (msg_count <= 0 || msg_size <= 0) { in csi_kernel_msgq_new()
1108 … = krhino_buf_queue_dyn_create(&(handle->buf_q), "UserMsgQ", msg_size * (msg_count + 1), msg_size); in csi_kernel_msgq_new()
1112 handle->msg_size = msg_size; in csi_kernel_msgq_new()
1157 kstat_t ret = krhino_buf_queue_send(handle->buf_q, (void *)msg_ptr, handle->msg_size); in csi_kernel_msgq_put()
1165 kstat_t ret = krhino_buf_queue_send(handle->buf_q, (void *)msg_ptr, handle->msg_size); in csi_kernel_msgq_put()
A Dcsi_kernel.h535 k_msgq_handle_t csi_kernel_msgq_new(int32_t msg_count, int32_t msg_size);
/AliOS-Things-master/hardware/chip/rtl872xd/sdk/component/common/mbed/hal_ext/
A Dicc_api.h78 typedef void (*icc_user_msg_callback_t)(uint8_t *pmsg_buf, uint32_t msg_size, uint32_t cb_arg);
/AliOS-Things-master/components/trace/
A Dk_trace.c218 void trace_buf_queue_max(ktask_t *task, kbuf_queue_t *buf_queue, void *msg, size_t msg_size) in trace_buf_queue_max() argument
223 void trace_buf_queue_post(ktask_t *task, kbuf_queue_t *buf_queue, void *msg, size_t msg_size) in trace_buf_queue_post() argument
/AliOS-Things-master/components/amp_adapter/platform/linux/
A Daos_system.c230 int msg_size; member
239 q->msg_size = max_msg; in aos_queue_new()
269 int len = read(q->fds[0], msg, q->msg_size); in aos_queue_recv()
/AliOS-Things-master/hardware/chip/rtl872xd/sdk/component/common/bluetooth/realtek/sdk/board/common/inc/
A Dosif.h57 bool osif_msg_queue_create(void **pp_handle, uint32_t msg_num, uint32_t msg_size);
/AliOS-Things-master/hardware/chip/rtl872xd/sdk/component/common/bluetooth/realtek/sdk/board/common/os/freertos_v10.0.1_IAR/
A Dosif_freertos.c536 bool osif_msg_queue_create(void **pp_handle, uint32_t msg_num, uint32_t msg_size) in osif_msg_queue_create() argument
543 *pp_handle = (void *)xQueueCreate(msg_num, msg_size); in osif_msg_queue_create()
/AliOS-Things-master/hardware/chip/rtl872xd/sdk/component/common/bluetooth/realtek/sdk/board/common/os/freertos_v8.1.2/
A Dosif_freertos.c538 bool osif_msg_queue_create(void **pp_handle, uint32_t msg_num, uint32_t msg_size) in osif_msg_queue_create() argument
545 *pp_handle = (void *)xQueueCreate(msg_num, msg_size); in osif_msg_queue_create()
/AliOS-Things-master/components/uvoice/connect/
A Duvoice_ws.c453 unsigned int msg_size = 0; in nopoll_client_task() local
464 ret = os_queue_recv(&handler->queue, 30, &msg, &msg_size); in nopoll_client_task()
465 if (ret || msg_size != sizeof(nopoll_msg_t)) { in nopoll_client_task()
/AliOS-Things-master/components/csi/csi2/include/
A Dcsi_kernel.h530 k_msgq_handle_t csi_kernel_msgq_new(int32_t msg_count, int32_t msg_size);
/AliOS-Things-master/components/uvoice/internal/
A Duvoice_linux.h242 static inline int os_queue_new(os_queue_t *queue, void *buffer, unsigned int size, int msg_size) in os_queue_new() argument

Completed in 33 milliseconds