Lines Matching refs:channel_wqs
55 } channel_wqs[RTLX_CHANNELS];
80 wake_up(&channel_wqs[i].lx_queue);
81 wake_up(&channel_wqs[i].rt_queue);
135 wake_up_interruptible(&channel_wqs[i].lx_queue);
144 wake_up_interruptible(&channel_wqs[i].lx_queue);
160 if (atomic_inc_return(&channel_wqs[index].in_open) > 1) {
170 __wait_event_interruptible(channel_wqs[index].lx_queue,
189 &channel_wqs[index].lx_queue,
201 finish_wait(&channel_wqs[index].lx_queue, &wait);
232 atomic_dec(&channel_wqs[index].in_open);
263 __wait_event_interruptible(channel_wqs[index].lx_queue,
311 mutex_lock(&channel_wqs[index].mutex);
337 mutex_unlock(&channel_wqs[index].mutex);
354 mutex_lock(&channel_wqs[index].mutex);
380 mutex_unlock(&channel_wqs[index].mutex);
403 poll_wait(file, &channel_wqs[minor].rt_queue, wait);
404 poll_wait(file, &channel_wqs[minor].lx_queue, wait);
449 __wait_event_interruptible(channel_wqs[minor].rt_queue,
497 init_waitqueue_head(&channel_wqs[i].rt_queue);
498 init_waitqueue_head(&channel_wqs[i].lx_queue);
499 atomic_set(&channel_wqs[i].in_open, 0);
500 mutex_init(&channel_wqs[i].mutex);