Home
last modified time | relevance | path

Searched refs:recv_queue (Results 1 – 7 of 7) sorted by relevance

/linux/drivers/isdn/capi/
H A Dkcapi.c281 while ((skb = skb_dequeue(&ap->recv_queue))) { in recv_handler()
369 skb_queue_tail(&ap->recv_queue, skb); in capi_ctr_handle_message()
566 skb_queue_head_init(&ap->recv_queue); in capi20_register()
633 skb_queue_purge(&ap->recv_queue); in capi20_release()
H A Dkcapi.h53 struct sk_buff_head recv_queue; member
/linux/drivers/infiniband/core/
H A Dmad.c2678 struct ib_mad_queue *recv_queue = &qp_info->recv_queue; in ib_mad_post_receive_mads() local
2713 mad_priv->header.mad_list.mad_queue = recv_queue; in ib_mad_post_receive_mads()
2718 spin_lock_irqsave(&recv_queue->lock, flags); in ib_mad_post_receive_mads()
2719 post = (++recv_queue->count < recv_queue->max_active); in ib_mad_post_receive_mads()
2720 list_add_tail(&mad_priv->header.mad_list.list, &recv_queue->list); in ib_mad_post_receive_mads()
2721 spin_unlock_irqrestore(&recv_queue->lock, flags); in ib_mad_post_receive_mads()
2724 spin_lock_irqsave(&recv_queue->lock, flags); in ib_mad_post_receive_mads()
2726 recv_queue->count--; in ib_mad_post_receive_mads()
2727 spin_unlock_irqrestore(&recv_queue->lock, flags); in ib_mad_post_receive_mads()
2754 while (!list_empty(&qp_info->recv_queue.list)) { in cleanup_recv_queue()
[all …]
H A Dmad_priv.h190 struct ib_mad_queue recv_queue; member
H A Dmad_rmpp.c396 return max(agent->qp_info->recv_queue.max_active >> 3, 1); in window_size()
/linux/net/sunrpc/
H A Dxprt.c850 if (RB_EMPTY_ROOT(&xprt->recv_queue) && xprt_has_timer(xprt)) in xprt_schedule_autodisconnect()
859 if (!RB_EMPTY_ROOT(&xprt->recv_queue)) in xprt_init_autodisconnect()
1008 struct rb_node *n = xprt->recv_queue.rb_node; in xprt_request_rb_find()
1030 struct rb_node **p = &xprt->recv_queue.rb_node; in xprt_request_rb_insert()
1050 rb_insert_color(&new->rq_recv, &xprt->recv_queue); in xprt_request_rb_insert()
1056 rb_erase(&req->rq_recv, &xprt->recv_queue); in xprt_request_rb_remove()
2031 xprt->recv_queue = RB_ROOT; in xprt_init()
/linux/include/linux/sunrpc/
H A Dxprt.h280 struct rb_root recv_queue; /* Receive queue */ member