Searched refs:recv_queue (Results 1 – 4 of 4) sorted by relevance
2963 struct ib_mad_queue *recv_queue = &qp_info->recv_queue; in ib_mad_post_receive_mads() local2996 mad_priv->header.mad_list.mad_queue = recv_queue; in ib_mad_post_receive_mads()2999 spin_lock_irqsave(&recv_queue->lock, flags); in ib_mad_post_receive_mads()3000 if (recv_queue->count >= recv_queue->max_active) { in ib_mad_post_receive_mads()3002 spin_unlock_irqrestore(&recv_queue->lock, flags); in ib_mad_post_receive_mads()3005 recv_queue->count++; in ib_mad_post_receive_mads()3007 &recv_queue->list); in ib_mad_post_receive_mads()3008 spin_unlock_irqrestore(&recv_queue->lock, flags); in ib_mad_post_receive_mads()3012 spin_lock_irqsave(&recv_queue->lock, flags); in ib_mad_post_receive_mads()3014 recv_queue->count--; in ib_mad_post_receive_mads()[all …]
396 return max(agent->qp_info->recv_queue.max_active >> 3, 1); in window_size()
850 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()2048 xprt->recv_queue = RB_ROOT; in xprt_init()
295 struct rb_root recv_queue; /* Receive queue */ member