Lines Matching defs:sess
74 struct rtrs_sess *sess = con->sess;
80 list.lkey = sess->dev->ib_pd->local_dma_lkey;
83 rtrs_wrn(con->sess,
128 struct rtrs_sess *sess = con->sess;
137 list.lkey = sess->dev->ib_pd->local_dma_lkey;
206 rtrs_info(con->sess, "QP event %s (%d) received\n",
211 rtrs_info(con->sess, "Unhandled QP event %s (%d) received\n",
226 rtrs_err(con->sess, "Creating completion queue failed, errno: %ld\n",
256 rtrs_err(con->sess, "Creating QP failed, err: %d\n", ret);
264 int rtrs_cq_qp_create(struct rtrs_sess *sess, struct rtrs_con *con,
275 err = create_qp(con, sess->dev->ib_pd, max_send_wr, max_recv_wr,
282 con->sess = sess;
301 static void schedule_hb(struct rtrs_sess *sess)
303 queue_delayed_work(sess->hb_wq, &sess->hb_dwork,
304 msecs_to_jiffies(sess->hb_interval_ms));
307 void rtrs_send_hb_ack(struct rtrs_sess *sess)
309 struct rtrs_con *usr_con = sess->con[0];
314 err = rtrs_post_rdma_write_imm_empty(usr_con, sess->hb_cqe, imm,
317 sess->hb_err_handler(usr_con);
326 struct rtrs_sess *sess;
330 sess = container_of(to_delayed_work(work), typeof(*sess), hb_dwork);
331 usr_con = sess->con[0];
333 if (sess->hb_missed_cnt > sess->hb_missed_max) {
334 sess->hb_err_handler(usr_con);
337 if (sess->hb_missed_cnt++) {
339 schedule_hb(sess);
343 err = rtrs_post_rdma_write_imm_empty(usr_con, sess->hb_cqe, imm,
346 sess->hb_err_handler(usr_con);
350 schedule_hb(sess);
353 void rtrs_init_hb(struct rtrs_sess *sess, struct ib_cqe *cqe,
358 sess->hb_cqe = cqe;
359 sess->hb_interval_ms = interval_ms;
360 sess->hb_err_handler = err_handler;
361 sess->hb_wq = wq;
362 sess->hb_missed_max = missed_max;
363 sess->hb_missed_cnt = 0;
364 INIT_DELAYED_WORK(&sess->hb_dwork, hb_work);
368 void rtrs_start_hb(struct rtrs_sess *sess)
370 schedule_hb(sess);
374 void rtrs_stop_hb(struct rtrs_sess *sess)
376 cancel_delayed_work_sync(&sess->hb_dwork);
377 sess->hb_missed_cnt = 0;