Lines Matching refs:pipe
221 static int goldfish_pipe_cmd_locked(struct goldfish_pipe *pipe, in goldfish_pipe_cmd_locked() argument
224 pipe->command_buffer->cmd = cmd; in goldfish_pipe_cmd_locked()
226 pipe->command_buffer->status = PIPE_ERROR_INVAL; in goldfish_pipe_cmd_locked()
227 writel(pipe->id, pipe->dev->base + PIPE_REG_CMD); in goldfish_pipe_cmd_locked()
228 return pipe->command_buffer->status; in goldfish_pipe_cmd_locked()
231 static int goldfish_pipe_cmd(struct goldfish_pipe *pipe, enum PipeCmdCode cmd) in goldfish_pipe_cmd() argument
235 if (mutex_lock_interruptible(&pipe->lock)) in goldfish_pipe_cmd()
237 status = goldfish_pipe_cmd_locked(pipe, cmd); in goldfish_pipe_cmd()
238 mutex_unlock(&pipe->lock); in goldfish_pipe_cmd()
340 static int transfer_max_buffers(struct goldfish_pipe *pipe, in transfer_max_buffers() argument
354 if (mutex_lock_interruptible(&pipe->lock)) in transfer_max_buffers()
359 pipe->pages, &iter_last_page_size); in transfer_max_buffers()
361 mutex_unlock(&pipe->lock); in transfer_max_buffers()
365 populate_rw_params(pipe->pages, pages_count, address, address_end, in transfer_max_buffers()
367 pipe->command_buffer); in transfer_max_buffers()
370 *status = goldfish_pipe_cmd_locked(pipe, in transfer_max_buffers()
373 *consumed_size = pipe->command_buffer->rw_params.consumed_size; in transfer_max_buffers()
375 release_user_pages(pipe->pages, pages_count, is_write, *consumed_size); in transfer_max_buffers()
377 mutex_unlock(&pipe->lock); in transfer_max_buffers()
381 static int wait_for_host_signal(struct goldfish_pipe *pipe, int is_write) in wait_for_host_signal() argument
385 set_bit(wake_bit, &pipe->flags); in wait_for_host_signal()
388 goldfish_pipe_cmd(pipe, in wait_for_host_signal()
391 while (test_bit(wake_bit, &pipe->flags)) { in wait_for_host_signal()
392 if (wait_event_interruptible(pipe->wake_queue, in wait_for_host_signal()
393 !test_bit(wake_bit, &pipe->flags))) in wait_for_host_signal()
396 if (test_bit(BIT_CLOSED_ON_HOST, &pipe->flags)) in wait_for_host_signal()
408 struct goldfish_pipe *pipe = filp->private_data; in goldfish_pipe_read_write() local
414 if (unlikely(test_bit(BIT_CLOSED_ON_HOST, &pipe->flags))) in goldfish_pipe_read_write()
432 ret = transfer_max_buffers(pipe, address, address_end, is_write, in goldfish_pipe_read_write()
460 dev_err_ratelimited(pipe->dev->pdev_dev, in goldfish_pipe_read_write()
476 status = wait_for_host_signal(pipe, is_write); in goldfish_pipe_read_write()
506 struct goldfish_pipe *pipe = filp->private_data; in goldfish_pipe_poll() local
510 poll_wait(filp, &pipe->wake_queue, wait); in goldfish_pipe_poll()
512 status = goldfish_pipe_cmd(pipe, PIPE_CMD_POLL); in goldfish_pipe_poll()
522 if (test_bit(BIT_CLOSED_ON_HOST, &pipe->flags)) in goldfish_pipe_poll()
531 struct goldfish_pipe *pipe; in signalled_pipes_add_locked() local
536 pipe = dev->pipes[id]; in signalled_pipes_add_locked()
537 if (!pipe) in signalled_pipes_add_locked()
539 pipe->signalled_flags |= flags; in signalled_pipes_add_locked()
541 if (pipe->prev_signalled || pipe->next_signalled || in signalled_pipes_add_locked()
542 dev->first_signalled_pipe == pipe) in signalled_pipes_add_locked()
544 pipe->next_signalled = dev->first_signalled_pipe; in signalled_pipes_add_locked()
546 dev->first_signalled_pipe->prev_signalled = pipe; in signalled_pipes_add_locked()
547 dev->first_signalled_pipe = pipe; in signalled_pipes_add_locked()
551 struct goldfish_pipe *pipe) in signalled_pipes_remove_locked() argument
553 if (pipe->prev_signalled) in signalled_pipes_remove_locked()
554 pipe->prev_signalled->next_signalled = pipe->next_signalled; in signalled_pipes_remove_locked()
555 if (pipe->next_signalled) in signalled_pipes_remove_locked()
556 pipe->next_signalled->prev_signalled = pipe->prev_signalled; in signalled_pipes_remove_locked()
557 if (pipe == dev->first_signalled_pipe) in signalled_pipes_remove_locked()
558 dev->first_signalled_pipe = pipe->next_signalled; in signalled_pipes_remove_locked()
559 pipe->prev_signalled = NULL; in signalled_pipes_remove_locked()
560 pipe->next_signalled = NULL; in signalled_pipes_remove_locked()
566 struct goldfish_pipe *pipe; in signalled_pipes_pop_front() local
571 pipe = dev->first_signalled_pipe; in signalled_pipes_pop_front()
572 if (pipe) { in signalled_pipes_pop_front()
573 *wakes = pipe->signalled_flags; in signalled_pipes_pop_front()
574 pipe->signalled_flags = 0; in signalled_pipes_pop_front()
581 dev->first_signalled_pipe = pipe->next_signalled; in signalled_pipes_pop_front()
584 pipe->next_signalled = NULL; in signalled_pipes_pop_front()
588 return pipe; in signalled_pipes_pop_front()
595 struct goldfish_pipe *pipe; in goldfish_interrupt_task() local
598 while ((pipe = signalled_pipes_pop_front(dev, &wakes)) != NULL) { in goldfish_interrupt_task()
600 pipe->flags = 1 << BIT_CLOSED_ON_HOST; in goldfish_interrupt_task()
603 clear_bit(BIT_WAKE_ON_READ, &pipe->flags); in goldfish_interrupt_task()
605 clear_bit(BIT_WAKE_ON_WRITE, &pipe->flags); in goldfish_interrupt_task()
611 wake_up_interruptible(&pipe->wake_queue); in goldfish_interrupt_task()
717 struct goldfish_pipe *pipe = kzalloc(sizeof(*pipe), GFP_KERNEL); in goldfish_pipe_open() local
719 if (!pipe) in goldfish_pipe_open()
722 pipe->dev = dev; in goldfish_pipe_open()
723 mutex_init(&pipe->lock); in goldfish_pipe_open()
724 init_waitqueue_head(&pipe->wake_queue); in goldfish_pipe_open()
731 pipe->command_buffer = in goldfish_pipe_open()
733 if (!pipe->command_buffer) { in goldfish_pipe_open()
746 dev->pipes[id] = pipe; in goldfish_pipe_open()
747 pipe->id = id; in goldfish_pipe_open()
748 pipe->command_buffer->id = id; in goldfish_pipe_open()
754 (u64)(unsigned long)__pa(pipe->command_buffer); in goldfish_pipe_open()
755 status = goldfish_pipe_cmd_locked(pipe, PIPE_CMD_OPEN); in goldfish_pipe_open()
760 file->private_data = pipe; in goldfish_pipe_open()
768 free_page((unsigned long)pipe->command_buffer); in goldfish_pipe_open()
770 kfree(pipe); in goldfish_pipe_open()
777 struct goldfish_pipe *pipe = filp->private_data; in goldfish_pipe_release() local
778 struct goldfish_pipe_dev *dev = pipe->dev; in goldfish_pipe_release()
781 goldfish_pipe_cmd(pipe, PIPE_CMD_CLOSE); in goldfish_pipe_release()
784 dev->pipes[pipe->id] = NULL; in goldfish_pipe_release()
785 signalled_pipes_remove_locked(dev, pipe); in goldfish_pipe_release()
789 free_page((unsigned long)pipe->command_buffer); in goldfish_pipe_release()
790 kfree(pipe); in goldfish_pipe_release()