ofed/librdmacm/rsocket.c

55 #include <rdma/rsocket.h>
70 struct rsocket;
84 	struct rsocket *rs;
94 	struct rsocket **rss;
225  * rsocket states are ordered as passive, connecting, connected, disconnected.
248  * transfer rsocket messages as inline sends.
284 	struct rsocket	  *rs;
296 struct rsocket {
421 static void ds_insert_qp(struct rsocket *rs, struct ds_qp *qp)
430 static void ds_remove_qp(struct rsocket *rs, struct ds_qp *qp)
440 static int rs_notify_svc(struct rs_svc *svc, struct rsocket *rs, int cmd)
574 static int rs_insert(struct rsocket *rs, int index)
582 static void rs_remove(struct rsocket *rs)
590 static struct rsocket *rs_alloc(struct rsocket *inherited_rs, int type)
592 	struct rsocket *rs;
636 static int rs_set_nonblocking(struct rsocket *rs, int arg)
662 static void rs_set_qp_size(struct rsocket *rs)
679 static void ds_set_qp_size(struct rsocket *rs)
701 static int rs_init_bufs(struct rsocket *rs)
777  * If a user is waiting on a datagram rsocket through poll or select, then
781 static int rs_create_cq(struct rsocket *rs, struct rdma_cm_id *cm_id)
811 static inline int rs_post_recv(struct rsocket *rs)
837 static inline int ds_post_recv(struct rsocket *rs, struct ds_qp *qp, uint32_t offset)
857 static int rs_create_ep(struct rsocket *rs)
914 static void rs_free_iomappings(struct rsocket *rs)
954 static void ds_free(struct rsocket *rs)
987 static void rs_free(struct rsocket *rs)
1035 static size_t rs_conn_data_offset(struct rsocket *rs)
1041 static void rs_format_conn_data(struct rsocket *rs, struct rs_conn_data *conn)
1059 static void rs_save_conn_data(struct rsocket *rs, struct rs_conn_data *conn)
1083 static int ds_init(struct rsocket *rs, int domain)
1096 static int ds_init_ep(struct rsocket *rs)
1130 int rsocket(int domain, int type, int protocol)
1132 	struct rsocket *rs;
1174 	struct rsocket *rs;
1197 	struct rsocket *rs;
1228 	struct rsocket *rs, *new_rs;
1284 static int rs_do_connect(struct rsocket *rs)
1415 static int ds_get_src_addr(struct rsocket *rs,
1486 static int ds_create_qp(struct rsocket *rs, union socket_addr *src_addr,
1557 static int ds_get_qp(struct rsocket *rs, union socket_addr *src_addr,
1574 static int ds_get_dest(struct rsocket *rs, const struct sockaddr *addr,
1618 	struct rsocket *rs;
1643 static void *rs_get_ctrl_buf(struct rsocket *rs)
1649 static int rs_post_msg(struct rsocket *rs, uint32_t msg)
1675 static int rs_post_write(struct rsocket *rs,
1694 static int rs_post_write_msg(struct rsocket *rs,
1734 static int ds_post_send(struct rsocket *rs, struct ibv_sge *sge,
1756 static int rs_write_data(struct rsocket *rs,
1784 static int rs_write_direct(struct rsocket *rs, struct rs_iomap *iom, uint64_t offset,
1797 static int rs_write_iomap(struct rsocket *rs, struct rs_iomap_mr *iomr,
1813 static uint32_t rs_sbuf_left(struct rsocket *rs)
1819 static void rs_send_credits(struct rsocket *rs)
1870 static inline int rs_ctrl_avail(struct rsocket *rs)
1876 static inline int rs_2ctrl_avail(struct rsocket *rs)
1881 static int rs_give_credits(struct rsocket *rs)
1894 static void rs_update_credits(struct rsocket *rs)
1900 static int rs_poll_cq(struct rsocket *rs)
1988 static int rs_get_cq_event(struct rsocket *rs)
2025 static int rs_process_cq(struct rsocket *rs, int nonblock, int (*test)(struct rsocket *rs))
2059 static int rs_get_comp(struct rsocket *rs, int nonblock, int (*test)(struct rsocket *rs))
2093  * Poll all CQs associated with a datagram rsocket.  We need to drop any
2099 static void ds_poll_cqs(struct rsocket *rs)
2149 static void ds_req_notify_cqs(struct rsocket *rs)
2165 static int ds_get_cq_event(struct rsocket *rs)
2191 static int ds_process_cqs(struct rsocket *rs, int nonblock, int (*test)(struct rsocket *rs))
2220 static int ds_get_comp(struct rsocket *rs, int nonblock, int (*test)(struct rsocket *rs))
2243 static int rs_nonblocking(struct rsocket *rs, int flags)
2248 static int rs_is_cq_armed(struct rsocket *rs)
2253 static int rs_poll_all(struct rsocket *rs)
2267 static int rs_can_send(struct rsocket *rs)
2280 static int ds_can_send(struct rsocket *rs)
2285 static int ds_all_sends_done(struct rsocket *rs)
2290 static int rs_conn_can_send(struct rsocket *rs)
2295 static int rs_conn_can_send_ctrl(struct rsocket *rs)
2300 static int rs_have_rdata(struct rsocket *rs)
2305 static int rs_conn_have_rdata(struct rsocket *rs)
2310 static int rs_conn_all_sends_done(struct rsocket *rs)
2342 static ssize_t ds_recvfrom(struct rsocket *rs, void *buf, size_t len, int flags,
2378 static ssize_t rs_peek(struct rsocket *rs, void *buf, size_t len)
2417 	struct rsocket *rs;
2487 	struct rsocket *rs;
2532 static int rs_send_iomaps(struct rsocket *rs, int flags)
2599 static ssize_t ds_sendv_udp(struct rsocket *rs, const struct iovec *iov,
2637 static ssize_t ds_send_udp(struct rsocket *rs, const void *buf, size_t len,
2650 static ssize_t dsend(struct rsocket *rs, const void *buf, size_t len, int flags)
2687 	struct rsocket *rs;
2775 	struct rsocket *rs;
2827 	struct rsocket *rs;
2943 static int rs_poll_rs(struct rsocket *rs, int events,
2944 		      int nonblock, int (*test)(struct rsocket *rs))
3012 	struct rsocket *rs;
3030 	struct rsocket *rs;
3060 	struct rsocket *rs;
3087  * Note that we may receive events on an rsocket that may not be reported
3226 	struct rsocket *rs;
3280 static void ds_shutdown(struct rsocket *rs)
3297 	struct rsocket *rs;
3331 	struct rsocket *rs;
3346 	struct rsocket *rs;
3359 static int rs_set_keepalive(struct rsocket *rs, int on)
3389 	struct rsocket *rs;
3570 	struct rsocket *rs;
3714 	struct rsocket *rs;
3743 static struct rs_iomap_mr *rs_get_iomap_mr(struct rsocket *rs)
3771 	struct rsocket *rs;
3818 	struct rsocket *rs;
3849 static struct rs_iomap *rs_find_iomap(struct rsocket *rs, off_t offset)
3863 	struct rsocket *rs;
3946 	struct rsocket **rss;
3970 static int rs_svc_add_rs(struct rs_svc *svc, struct rsocket *rs)
3984 static int rs_svc_index(struct rs_svc *svc, struct rsocket *rs)
3995 static int rs_svc_rm_rs(struct rs_svc *svc, struct rsocket *rs)
4064 static void udp_svc_create_ah(struct rsocket *rs, struct ds_dest *dest, uint32_t qpn)
4129 static void udp_svc_forward(struct rsocket *rs, void *buf, size_t len,
4157 static void udp_svc_process_rs(struct rsocket *rs)
4293 static void tcp_svc_send_keepalive(struct rsocket *rs)