| 703 | ****************************************************************************/ |
| 704 | |
| 705 | FAR struct rpmsg_port_header_s * |
| 706 | rpmsg_port_queue_get_buffer(FAR struct rpmsg_port_queue_s *queue, bool wait) |
| 707 | { |
| 708 | FAR struct list_node *node; |
| 709 | |
| 710 | for (; ; ) |
| 711 | { |
| 712 | node = rpmsg_port_remove_node(&queue->ready); |
| 713 | if (node) |
| 714 | { |
| 715 | return RPMSG_PORT_NODE_TO_BUF(queue, node); |
| 716 | } |
| 717 | else if (!wait) |
| 718 | { |
| 719 | return NULL; |
| 720 | } |
| 721 | |
| 722 | nxsem_wait_uninterruptible(&queue->ready.sem); |
| 723 | } |
| 724 | } |
| 725 | |
| 726 | /**************************************************************************** |
| 727 | * Name: rpmsg_port_queue_add_buffer |
no test coverage detected