Lines Matching refs:ds_qp
168 struct ds_qp;
171 struct ds_qp *qp;
277 struct ds_qp *qp;
282 struct ds_qp { struct
343 struct ds_qp *qp_list;
405 #define ds_next_qp(qp) container_of((qp)->list.next, struct ds_qp, list)
421 static void ds_insert_qp(struct rsocket *rs, struct ds_qp *qp) in ds_insert_qp()
430 static void ds_remove_qp(struct rsocket *rs, struct ds_qp *qp) in ds_remove_qp()
638 struct ds_qp *qp; in rs_set_nonblocking()
758 static int ds_init_bufs(struct ds_qp *qp) in ds_init_bufs()
837 static inline int ds_post_recv(struct rsocket *rs, struct ds_qp *qp, uint32_t offset) in ds_post_recv()
930 static void ds_free_qp(struct ds_qp *qp) in ds_free_qp()
956 struct ds_qp *qp; in ds_free()
1460 static int ds_add_qp_dest(struct ds_qp *qp, union socket_addr *addr, in ds_add_qp_dest()
1487 socklen_t addrlen, struct ds_qp **new_qp) in ds_create_qp()
1489 struct ds_qp *qp; in ds_create_qp()
1558 socklen_t addrlen, struct ds_qp **qp) in ds_get_qp()
1579 struct ds_qp *qp; in ds_get_dest()
2082 static int ds_valid_recv(struct ds_qp *qp, struct ibv_wc *wc) in ds_valid_recv()
2101 struct ds_qp *qp; in ds_poll_cqs()
2151 struct ds_qp *qp; in ds_req_notify_cqs()
2168 struct ds_qp *qp; in ds_get_cq_event()