Searched refs:mq (Results 1 – 7 of 7) sorted by relevance
| /components/libc/posix/ipc/ |
| A D | mqueue.c | 60 rt_mq_t mq; in mq_getattr() local
63 mq = (rt_mq_t)mq_file->data; in mq_getattr()
195 rt_mq_t mq; in mq_receive() local
199 mq = (rt_mq_t)mq_file->data; in mq_receive()
237 rt_mq_t mq; in mq_send() local
241 mq = (rt_mq_t)mq_file->data; in mq_send()
289 rt_mq_t mq; in mq_timedreceive() local
294 mq = (rt_mq_t)mq_file->data; in mq_timedreceive()
364 rt_mq_t mq; in mq_notify() local
367 mq = (rt_mq_t)mq_file->data; in mq_notify()
[all …]
|
| /components/drivers/usb/cherryusb/osal/ |
| A D | usb_osal_rtthread.c | 132 void usb_osal_mq_delete(usb_osal_mq_t mq) in usb_osal_mq_delete() argument
134 rt_mq_delete((rt_mq_t)mq); in usb_osal_mq_delete()
137 int usb_osal_mq_send(usb_osal_mq_t mq, uintptr_t addr) in usb_osal_mq_send() argument
139 return rt_mq_send((rt_mq_t)mq, &addr, sizeof(uintptr_t)); in usb_osal_mq_send()
142 int usb_osal_mq_recv(usb_osal_mq_t mq, uintptr_t *addr, uint32_t timeout) in usb_osal_mq_recv() argument
148 result = rt_mq_recv((rt_mq_t)mq, addr, sizeof(uintptr_t), RT_WAITING_FOREVER); in usb_osal_mq_recv()
150 … result = rt_mq_recv((rt_mq_t)mq, addr, sizeof(uintptr_t), rt_tick_from_millisecond(timeout)); in usb_osal_mq_recv()
|
| /components/drivers/usb/cherryusb/common/ |
| A D | usb_osal.h | 59 void usb_osal_mq_delete(usb_osal_mq_t mq);
60 int usb_osal_mq_send(usb_osal_mq_t mq, uintptr_t addr);
61 int usb_osal_mq_recv(usb_osal_mq_t mq, uintptr_t *addr, uint32_t timeout);
|
| /components/lwp/ |
| A D | lwp_syscall.h | 86 sysret_t sys_mq_delete(rt_mq_t mq);
87 sysret_t sys_mq_send(rt_mq_t mq, void *buffer, rt_size_t size);
88 sysret_t sys_mq_urgent(rt_mq_t mq, void *buffer, rt_size_t size);
89 sysret_t sys_mq_recv(rt_mq_t mq, void *buffer, rt_size_t size, rt_int32_t timeout);
|
| A D | lwp_syscall.c | 2595 rt_mq_t mq = RT_NULL; in sys_mq_create() local
2618 mq = rt_mq_create(kname, msg_size, max_msgs, flag); in sys_mq_create()
2619 if (lwp_user_object_add(lwp_self(), (rt_object_t)mq) != 0) in sys_mq_create()
2621 rt_mq_delete(mq); in sys_mq_create()
2622 mq = NULL; in sys_mq_create()
2627 return mq; in sys_mq_create()
2651 sysret_t sys_mq_delete(rt_mq_t mq) in sys_mq_delete() argument
2704 ret = rt_mq_send(mq, kbuffer, size); in sys_mq_send()
2761 ret = rt_mq_urgent(mq, kbuffer, size); in sys_mq_urgent()
2798 sysret_t sys_mq_recv(rt_mq_t mq, in sys_mq_recv() argument
[all …]
|
| /components/dfs/dfs_v1/filesystems/mqueue/ |
| A D | dfs_mqueue.c | 77 rt_mq_t mq = rt_mq_create(file->vnode->path + 1, mq_file->msg_size, mq_file->max_msgs, in dfs_mqueue_open() local
79 mq_file->data = (void *)mq; in dfs_mqueue_open()
|
| /components/dfs/dfs_v2/filesystems/mqueue/ |
| A D | dfs_mqueue.c | 154 rt_mq_t mq = rt_mq_create(dentry->pathname + 1, mq_file->msg_size, mq_file->max_msgs, in dfs_mqueue_create_vnode() local
156 mq_file->data = (void *)mq; in dfs_mqueue_create_vnode()
|
Completed in 24 milliseconds