recv_queue 2933 drivers/infiniband/core/mad.c struct ib_mad_queue *recv_queue = &qp_info->recv_queue; recv_queue 2967 drivers/infiniband/core/mad.c mad_priv->header.mad_list.mad_queue = recv_queue; recv_queue 2972 drivers/infiniband/core/mad.c spin_lock_irqsave(&recv_queue->lock, flags); recv_queue 2973 drivers/infiniband/core/mad.c post = (++recv_queue->count < recv_queue->max_active); recv_queue 2974 drivers/infiniband/core/mad.c list_add_tail(&mad_priv->header.mad_list.list, &recv_queue->list); recv_queue 2975 drivers/infiniband/core/mad.c spin_unlock_irqrestore(&recv_queue->lock, flags); recv_queue 2978 drivers/infiniband/core/mad.c spin_lock_irqsave(&recv_queue->lock, flags); recv_queue 2980 drivers/infiniband/core/mad.c recv_queue->count--; recv_queue 2981 drivers/infiniband/core/mad.c spin_unlock_irqrestore(&recv_queue->lock, flags); recv_queue 3008 drivers/infiniband/core/mad.c while (!list_empty(&qp_info->recv_queue.list)) { recv_queue 3010 drivers/infiniband/core/mad.c mad_list = list_entry(qp_info->recv_queue.list.next, recv_queue 3028 drivers/infiniband/core/mad.c qp_info->recv_queue.count = 0; recv_queue 3139 drivers/infiniband/core/mad.c init_mad_queue(qp_info, &qp_info->recv_queue); recv_queue 3175 drivers/infiniband/core/mad.c qp_info->recv_queue.max_active = mad_recvq_size; recv_queue 191 drivers/infiniband/core/mad_priv.h struct ib_mad_queue recv_queue; recv_queue 405 drivers/infiniband/core/mad_rmpp.c return max(agent->qp_info->recv_queue.max_active >> 3, 1); recv_queue 323 drivers/isdn/capi/kcapi.c while ((skb = skb_dequeue(&ap->recv_queue))) { recv_queue 411 drivers/isdn/capi/kcapi.c skb_queue_tail(&ap->recv_queue, skb); recv_queue 680 drivers/isdn/capi/kcapi.c skb_queue_head_init(&ap->recv_queue); recv_queue 749 drivers/isdn/capi/kcapi.c skb_queue_purge(&ap->recv_queue); recv_queue 32 include/linux/kernelcapi.h struct sk_buff_head recv_queue; recv_queue 264 include/linux/sunrpc/xprt.h struct rb_root recv_queue; /* Receive queue */ recv_queue 761 net/sunrpc/xprt.c if (RB_EMPTY_ROOT(&xprt->recv_queue) && xprt_has_timer(xprt)) recv_queue 770 net/sunrpc/xprt.c if (!RB_EMPTY_ROOT(&xprt->recv_queue)) recv_queue 906 net/sunrpc/xprt.c struct rb_node *n = xprt->recv_queue.rb_node; recv_queue 928 net/sunrpc/xprt.c struct rb_node **p = &xprt->recv_queue.rb_node; recv_queue 948 net/sunrpc/xprt.c rb_insert_color(&new->rq_recv, &xprt->recv_queue); recv_queue 954 net/sunrpc/xprt.c rb_erase(&req->rq_recv, &xprt->recv_queue); recv_queue 1858 net/sunrpc/xprt.c xprt->recv_queue = RB_ROOT;