hc
2024-01-03 2f7c68cb55ecb7331f2381deb497c27155f32faf
kernel/drivers/infiniband/sw/rxe/rxe_qp.c
....@@ -192,6 +192,9 @@
192192 spin_lock_init(&qp->rq.producer_lock);
193193 spin_lock_init(&qp->rq.consumer_lock);
194194
195
+ skb_queue_head_init(&qp->req_pkts);
196
+ skb_queue_head_init(&qp->resp_pkts);
197
+
195198 atomic_set(&qp->ssn, 0);
196199 atomic_set(&qp->skb_out, 0);
197200 }
....@@ -247,12 +250,8 @@
247250 qp->req.opcode = -1;
248251 qp->comp.opcode = -1;
249252
250
- skb_queue_head_init(&qp->req_pkts);
251
-
252
- rxe_init_task(rxe, &qp->req.task, qp,
253
- rxe_requester, "req");
254
- rxe_init_task(rxe, &qp->comp.task, qp,
255
- rxe_completer, "comp");
253
+ rxe_init_task(&qp->req.task, qp, rxe_requester);
254
+ rxe_init_task(&qp->comp.task, qp, rxe_completer);
256255
257256 qp->qp_timeout_jiffies = 0; /* Can't be set for UD/UC in modify_qp */
258257 if (init->qp_type == IB_QPT_RC) {
....@@ -296,10 +295,7 @@
296295 }
297296 }
298297
299
- skb_queue_head_init(&qp->resp_pkts);
300
-
301
- rxe_init_task(rxe, &qp->resp.task, qp,
302
- rxe_responder, "resp");
298
+ rxe_init_task(&qp->resp.task, qp, rxe_responder);
303299
304300 qp->resp.opcode = OPCODE_NONE;
305301 qp->resp.msn = 0;
....@@ -812,12 +808,12 @@
812808 qp->resp.mr = NULL;
813809 }
814810
815
- if (qp_type(qp) == IB_QPT_RC)
816
- sk_dst_reset(qp->sk->sk);
817
-
818811 free_rd_atomic_resources(qp);
819812
820813 if (qp->sk) {
814
+ if (qp_type(qp) == IB_QPT_RC)
815
+ sk_dst_reset(qp->sk->sk);
816
+
821817 kernel_sock_shutdown(qp->sk, SHUT_RDWR);
822818 sock_release(qp->sk);
823819 }