Lines Matching refs:agent
47 struct ib_mad_agent_private *agent; member
87 void ib_cancel_rmpp_recvs(struct ib_mad_agent_private *agent) in ib_cancel_rmpp_recvs() argument
92 spin_lock_irqsave(&agent->lock, flags); in ib_cancel_rmpp_recvs()
93 list_for_each_entry(rmpp_recv, &agent->rmpp_list, list) { in ib_cancel_rmpp_recvs()
97 spin_unlock_irqrestore(&agent->lock, flags); in ib_cancel_rmpp_recvs()
99 flush_workqueue(agent->qp_info->port_priv->wq); in ib_cancel_rmpp_recvs()
102 &agent->rmpp_list, list) { in ib_cancel_rmpp_recvs()
137 msg = ib_create_send_mad(&rmpp_recv->agent->agent, recv_wc->wc->src_qp, in ack_recv()
151 static struct ib_mad_send_buf *alloc_response_msg(struct ib_mad_agent *agent, in alloc_response_msg() argument
158 ah = ib_create_ah_from_wc(agent->qp->pd, recv_wc->wc, in alloc_response_msg()
159 recv_wc->recv_buf.grh, agent->port_num); in alloc_response_msg()
164 msg = ib_create_send_mad(agent, recv_wc->wc->src_qp, in alloc_response_msg()
178 static void ack_ds_ack(struct ib_mad_agent_private *agent, in ack_ds_ack() argument
185 msg = alloc_response_msg(&agent->agent, recv_wc); in ack_ds_ack()
212 static void nack_recv(struct ib_mad_agent_private *agent, in nack_recv() argument
219 msg = alloc_response_msg(&agent->agent, recv_wc); in nack_recv()
248 spin_lock_irqsave(&rmpp_recv->agent->lock, flags); in recv_timeout_handler()
250 spin_unlock_irqrestore(&rmpp_recv->agent->lock, flags); in recv_timeout_handler()
255 spin_unlock_irqrestore(&rmpp_recv->agent->lock, flags); in recv_timeout_handler()
258 nack_recv(rmpp_recv->agent, rmpp_wc, IB_MGMT_RMPP_STATUS_T2L); in recv_timeout_handler()
269 spin_lock_irqsave(&rmpp_recv->agent->lock, flags); in recv_cleanup_handler()
271 spin_unlock_irqrestore(&rmpp_recv->agent->lock, flags); in recv_cleanup_handler()
276 create_rmpp_recv(struct ib_mad_agent_private *agent, in create_rmpp_recv() argument
286 rmpp_recv->ah = ib_create_ah_from_wc(agent->agent.qp->pd, in create_rmpp_recv()
289 agent->agent.port_num); in create_rmpp_recv()
293 rmpp_recv->agent = agent; in create_rmpp_recv()
323 find_rmpp_recv(struct ib_mad_agent_private *agent, in find_rmpp_recv() argument
329 list_for_each_entry(rmpp_recv, &agent->rmpp_list, list) { in find_rmpp_recv()
342 acquire_rmpp_recv(struct ib_mad_agent_private *agent, in acquire_rmpp_recv() argument
348 spin_lock_irqsave(&agent->lock, flags); in acquire_rmpp_recv()
349 rmpp_recv = find_rmpp_recv(agent, mad_recv_wc); in acquire_rmpp_recv()
352 spin_unlock_irqrestore(&agent->lock, flags); in acquire_rmpp_recv()
357 insert_rmpp_recv(struct ib_mad_agent_private *agent, in insert_rmpp_recv() argument
362 cur_rmpp_recv = find_rmpp_recv(agent, rmpp_recv->rmpp_wc); in insert_rmpp_recv()
364 list_add_tail(&rmpp_recv->list, &agent->rmpp_list); in insert_rmpp_recv()
394 static inline int window_size(struct ib_mad_agent_private *agent) in window_size() argument
396 return max(agent->qp_info->recv_queue.max_active >> 3, 1); in window_size()
431 bool opa = rdma_cap_opa_mad(rmpp_recv->agent->qp_info->port_priv->device, in get_mad_len()
432 rmpp_recv->agent->qp_info->port_priv->port_num); in get_mad_len()
463 queue_delayed_work(rmpp_recv->agent->qp_info->port_priv->wq, in complete_rmpp()
469 continue_rmpp(struct ib_mad_agent_private *agent, in continue_rmpp() argument
478 rmpp_recv = acquire_rmpp_recv(agent, mad_recv_wc); in continue_rmpp()
510 rmpp_recv->newwin += window_size(agent); in continue_rmpp()
528 start_rmpp(struct ib_mad_agent_private *agent, in start_rmpp() argument
534 rmpp_recv = create_rmpp_recv(agent, mad_recv_wc); in start_rmpp()
540 spin_lock_irqsave(&agent->lock, flags); in start_rmpp()
541 if (insert_rmpp_recv(agent, rmpp_recv)) { in start_rmpp()
542 spin_unlock_irqrestore(&agent->lock, flags); in start_rmpp()
545 return continue_rmpp(agent, mad_recv_wc); in start_rmpp()
551 spin_unlock_irqrestore(&agent->lock, flags); in start_rmpp()
554 spin_unlock_irqrestore(&agent->lock, flags); in start_rmpp()
556 queue_delayed_work(agent->qp_info->port_priv->wq, in start_rmpp()
559 rmpp_recv->newwin += window_size(agent); in start_rmpp()
598 static void abort_send(struct ib_mad_agent_private *agent, in abort_send() argument
605 spin_lock_irqsave(&agent->lock, flags); in abort_send()
606 mad_send_wr = ib_find_send_mad(agent, mad_recv_wc); in abort_send()
617 spin_unlock_irqrestore(&agent->lock, flags); in abort_send()
624 spin_unlock_irqrestore(&agent->lock, flags); in abort_send()
627 spin_unlock_irqrestore(&agent->lock, flags); in abort_send()
642 static void process_ds_ack(struct ib_mad_agent_private *agent, in process_ds_ack() argument
647 rmpp_recv = find_rmpp_recv(agent, mad_recv_wc); in process_ds_ack()
652 static void process_rmpp_ack(struct ib_mad_agent_private *agent, in process_rmpp_ack() argument
662 abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS); in process_rmpp_ack()
663 nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS); in process_rmpp_ack()
670 abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_W2S); in process_rmpp_ack()
671 nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_W2S); in process_rmpp_ack()
675 spin_lock_irqsave(&agent->lock, flags); in process_rmpp_ack()
676 mad_send_wr = ib_find_send_mad(agent, mad_recv_wc); in process_rmpp_ack()
679 process_ds_ack(agent, mad_recv_wc, newwin); in process_rmpp_ack()
685 spin_unlock_irqrestore(&agent->lock, flags); in process_rmpp_ack()
686 ack_ds_ack(agent, mad_recv_wc); in process_rmpp_ack()
697 spin_unlock_irqrestore(&agent->lock, flags); in process_rmpp_ack()
698 abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_S2B); in process_rmpp_ack()
699 nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_S2B); in process_rmpp_ack()
718 spin_unlock_irqrestore(&agent->lock, flags); in process_rmpp_ack()
725 spin_unlock_irqrestore(&agent->lock, flags); in process_rmpp_ack()
731 spin_unlock_irqrestore(&agent->lock, flags); in process_rmpp_ack()
732 ack_ds_ack(agent, mad_recv_wc); in process_rmpp_ack()
747 spin_unlock_irqrestore(&agent->lock, flags); in process_rmpp_ack()
751 process_rmpp_data(struct ib_mad_agent_private *agent, in process_rmpp_data() argument
769 return start_rmpp(agent, mad_recv_wc); in process_rmpp_data()
775 return continue_rmpp(agent, mad_recv_wc); in process_rmpp_data()
778 nack_recv(agent, mad_recv_wc, rmpp_status); in process_rmpp_data()
783 static void process_rmpp_stop(struct ib_mad_agent_private *agent, in process_rmpp_stop() argument
791 abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS); in process_rmpp_stop()
792 nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS); in process_rmpp_stop()
794 abort_send(agent, mad_recv_wc, rmpp_mad->rmpp_hdr.rmpp_status); in process_rmpp_stop()
797 static void process_rmpp_abort(struct ib_mad_agent_private *agent, in process_rmpp_abort() argument
806 abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS); in process_rmpp_abort()
807 nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BAD_STATUS); in process_rmpp_abort()
809 abort_send(agent, mad_recv_wc, rmpp_mad->rmpp_hdr.rmpp_status); in process_rmpp_abort()
813 ib_process_rmpp_recv_wc(struct ib_mad_agent_private *agent, in ib_process_rmpp_recv_wc() argument
823 abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_UNV); in ib_process_rmpp_recv_wc()
824 nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_UNV); in ib_process_rmpp_recv_wc()
830 return process_rmpp_data(agent, mad_recv_wc); in ib_process_rmpp_recv_wc()
832 process_rmpp_ack(agent, mad_recv_wc); in ib_process_rmpp_recv_wc()
835 process_rmpp_stop(agent, mad_recv_wc); in ib_process_rmpp_recv_wc()
838 process_rmpp_abort(agent, mad_recv_wc); in ib_process_rmpp_recv_wc()
841 abort_send(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BADT); in ib_process_rmpp_recv_wc()
842 nack_recv(agent, mad_recv_wc, IB_MGMT_RMPP_STATUS_BADT); in ib_process_rmpp_recv_wc()
852 struct ib_mad_agent_private *agent = mad_send_wr->mad_agent_priv; in init_newwin() local
862 spin_lock_irqsave(&agent->lock, flags); in init_newwin()
863 list_for_each_entry(rmpp_recv, &agent->rmpp_list, list) { in init_newwin()
878 spin_unlock_irqrestore(&agent->lock, flags); in init_newwin()