Searched refs:mqueue (Results 1 – 4 of 4) sorted by relevance
13 src += ['mqueue.c']
26 bool "Enable posix message queue <mqueue.h>"
101 struct rt_messagequeue *mqueue; /* Message queue for sending GC/WB command.*/ member
318 if (rt_mq_recv(__pcache.mqueue, &work, sizeof(work), RT_WAITING_FOREVER) == sizeof(work)) in dfs_pcache_thread()443 …__pcache.mqueue = rt_mq_create("pcache", sizeof(struct dfs_pcache_mq_obj), 1024, RT_IPC_FLAG_FIFO); in dfs_pcache_init()476 … err = rt_mq_send_wait(__pcache.mqueue, (const void *)&work, sizeof(struct dfs_pcache_mq_obj), 0); in dfs_pcache_mq_work()
Completed in 7 milliseconds