Lines Matching defs:path
74 struct rtrs_path *path = con->path;
80 list.lkey = path->dev->ib_pd->local_dma_lkey;
83 rtrs_wrn(con->path,
131 struct rtrs_path *path = con->path;
140 list.lkey = path->dev->ib_pd->local_dma_lkey;
193 struct rtrs_path *path = con->path;
197 sflags = (atomic_inc_return(&con->wr_cnt) % path->signal_interval) ?
216 rtrs_info(con->path, "QP event %s (%d) received\n",
221 rtrs_info(con->path, "Unhandled QP event %s (%d) received\n",
229 return con->cid >= con->path->irq_con_num;
245 rtrs_err(con->path, "Creating completion queue failed, errno: %ld\n",
276 rtrs_err(con->path, "Creating QP failed, err: %d\n", ret);
295 int rtrs_cq_qp_create(struct rtrs_path *path, struct rtrs_con *con,
306 err = create_qp(con, path->dev->ib_pd, max_send_wr, max_recv_wr,
312 con->path = path;
328 static void schedule_hb(struct rtrs_path *path)
330 queue_delayed_work(path->hb_wq, &path->hb_dwork,
331 msecs_to_jiffies(path->hb_interval_ms));
334 void rtrs_send_hb_ack(struct rtrs_path *path)
336 struct rtrs_con *usr_con = path->con[0];
341 err = rtrs_post_rdma_write_imm_empty(usr_con, path->hb_cqe, imm,
344 rtrs_err(path, "send HB ACK failed, errno: %d\n", err);
345 path->hb_err_handler(usr_con);
354 struct rtrs_path *path;
358 path = container_of(to_delayed_work(work), typeof(*path), hb_dwork);
359 usr_con = path->con[0];
361 if (path->hb_missed_cnt > path->hb_missed_max) {
362 rtrs_err(path, "HB missed max reached.\n");
363 path->hb_err_handler(usr_con);
366 if (path->hb_missed_cnt++) {
368 schedule_hb(path);
372 path->hb_last_sent = ktime_get();
375 err = rtrs_post_rdma_write_imm_empty(usr_con, path->hb_cqe, imm,
378 rtrs_err(path, "HB send failed, errno: %d\n", err);
379 path->hb_err_handler(usr_con);
383 schedule_hb(path);
386 void rtrs_init_hb(struct rtrs_path *path, struct ib_cqe *cqe,
391 path->hb_cqe = cqe;
392 path->hb_interval_ms = interval_ms;
393 path->hb_err_handler = err_handler;
394 path->hb_wq = wq;
395 path->hb_missed_max = missed_max;
396 path->hb_missed_cnt = 0;
397 INIT_DELAYED_WORK(&path->hb_dwork, hb_work);
401 void rtrs_start_hb(struct rtrs_path *path)
403 schedule_hb(path);
407 void rtrs_stop_hb(struct rtrs_path *path)
409 cancel_delayed_work_sync(&path->hb_dwork);
410 path->hb_missed_cnt = 0;
502 * @buf: string containing source and destination addr of a path
524 * rtrs_addr_to_sockaddr() - convert path string "src,dst" or "src@dst"
526 * @str: string containing source and destination addr of a path