Lines Matching refs:lock
70 rt_mutex_take(&pipe->lock, RT_WAITING_FOREVER); in pipe_fops_open()
94 rc = rt_condvar_timedwait(&pipe->waitfor_parter, &pipe->lock, in pipe_fops_open()
107 rt_mutex_release(&pipe->lock); in pipe_fops_open()
133 rt_mutex_take(&pipe->lock, RT_WAITING_FOREVER); in pipe_fops_close()
158 rt_mutex_release(&pipe->lock); in pipe_fops_close()
234 rt_mutex_take(&pipe->lock, RT_WAITING_FOREVER); in pipe_fops_read()
252 rt_mutex_release(&pipe->lock); in pipe_fops_read()
256 rt_mutex_take(&pipe->lock, RT_WAITING_FOREVER); in pipe_fops_read()
264 rt_mutex_release(&pipe->lock); in pipe_fops_read()
301 rt_mutex_take(&pipe->lock, -1); in pipe_fops_write()
327 rt_mutex_release(&pipe->lock); in pipe_fops_write()
332 rt_mutex_take(&pipe->lock, -1); in pipe_fops_write()
334 rt_mutex_release(&pipe->lock); in pipe_fops_write()
437 rt_mutex_take(&pipe->lock, RT_WAITING_FOREVER); in rt_pipe_open()
448 rt_mutex_release(&pipe->lock); in rt_pipe_open()
471 rt_mutex_take(&pipe->lock, RT_WAITING_FOREVER); in rt_pipe_close()
476 rt_mutex_release(&pipe->lock); in rt_pipe_close()
512 rt_mutex_take(&pipe->lock, RT_WAITING_FOREVER); in rt_pipe_read()
524 rt_mutex_release(&pipe->lock); in rt_pipe_read()
560 rt_mutex_take(&pipe->lock, RT_WAITING_FOREVER); in rt_pipe_write()
572 rt_mutex_release(&pipe->lock); in rt_pipe_write()
638 rt_mutex_init(&pipe->lock, name, RT_IPC_FLAG_FIFO); in rt_pipe_create()
699 rt_mutex_detach(&pipe->lock); in rt_pipe_delete()