72 	struct rtrs_sess *sess = con->sess;  in rtrs_iu_post_recv()  local
78 	list.lkey   = sess->dev->ib_pd->local_dma_lkey;  in rtrs_iu_post_recv()
81 		rtrs_wrn(con->sess,  in rtrs_iu_post_recv()
126 	struct rtrs_sess *sess = con->sess;  in rtrs_iu_post_send()  local
135 	list.lkey   = sess->dev->ib_pd->local_dma_lkey;  in rtrs_iu_post_send()
204 		rtrs_info(con->sess, "QP event %s (%d) received\n",  in qp_event_handler()
209 		rtrs_info(con->sess, "Unhandled QP event %s (%d) received\n",  in qp_event_handler()
224 		rtrs_err(con->sess, "Creating completion queue failed, errno: %ld\n",  in create_cq()
254 		rtrs_err(con->sess, "Creating QP failed, err: %d\n", ret);  in create_qp()
262 int rtrs_cq_qp_create(struct rtrs_sess *sess, struct rtrs_con *con,  in rtrs_cq_qp_create()  argument
273 	err = create_qp(con, sess->dev->ib_pd, max_send_wr, max_recv_wr,  in rtrs_cq_qp_create()
280 	con->sess = sess;  in rtrs_cq_qp_create()
299 static void schedule_hb(struct rtrs_sess *sess)  in schedule_hb()  argument
301 	queue_delayed_work(sess->hb_wq, &sess->hb_dwork,  in schedule_hb()
302 			   msecs_to_jiffies(sess->hb_interval_ms));  in schedule_hb()
305 void rtrs_send_hb_ack(struct rtrs_sess *sess)  in rtrs_send_hb_ack()  argument
307 	struct rtrs_con *usr_con = sess->con[0];  in rtrs_send_hb_ack()
312 	err = rtrs_post_rdma_write_imm_empty(usr_con, sess->hb_cqe, imm,  in rtrs_send_hb_ack()
315 		sess->hb_err_handler(usr_con);  in rtrs_send_hb_ack()
324 	struct rtrs_sess *sess;  in hb_work()  local
328 	sess = container_of(to_delayed_work(work), typeof(*sess), hb_dwork);  in hb_work()
329 	usr_con = sess->con[0];  in hb_work()
331 	if (sess->hb_missed_cnt > sess->hb_missed_max) {  in hb_work()
332 		sess->hb_err_handler(usr_con);  in hb_work()
335 	if (sess->hb_missed_cnt++) {  in hb_work()
337 		schedule_hb(sess);  in hb_work()
341 	err = rtrs_post_rdma_write_imm_empty(usr_con, sess->hb_cqe, imm,  in hb_work()
344 		sess->hb_err_handler(usr_con);  in hb_work()
348 	schedule_hb(sess);  in hb_work()
351 void rtrs_init_hb(struct rtrs_sess *sess, struct ib_cqe *cqe,  in rtrs_init_hb()  argument
356 	sess->hb_cqe = cqe;  in rtrs_init_hb()
357 	sess->hb_interval_ms = interval_ms;  in rtrs_init_hb()
358 	sess->hb_err_handler = err_handler;  in rtrs_init_hb()
359 	sess->hb_wq = wq;  in rtrs_init_hb()
360 	sess->hb_missed_max = missed_max;  in rtrs_init_hb()
361 	sess->hb_missed_cnt = 0;  in rtrs_init_hb()
362 	INIT_DELAYED_WORK(&sess->hb_dwork, hb_work);  in rtrs_init_hb()
366 void rtrs_start_hb(struct rtrs_sess *sess)  in rtrs_start_hb()  argument
368 	schedule_hb(sess);  in rtrs_start_hb()
372 void rtrs_stop_hb(struct rtrs_sess *sess)  in rtrs_stop_hb()  argument
374 	cancel_delayed_work_sync(&sess->hb_dwork);  in rtrs_stop_hb()
375 	sess->hb_missed_cnt = 0;  in rtrs_stop_hb()