Lines Matching refs:rsocket
70 struct rsocket;
84 struct rsocket *rs;
94 struct rsocket **rss;
284 struct rsocket *rs;
296 struct rsocket { struct
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()
440 static int rs_notify_svc(struct rs_svc *svc, struct rsocket *rs, int cmd) in rs_notify_svc()
574 static int rs_insert(struct rsocket *rs, int index) in rs_insert()
582 static void rs_remove(struct rsocket *rs) in rs_remove()
590 static struct rsocket *rs_alloc(struct rsocket *inherited_rs, int type) in rs_alloc()
592 struct rsocket *rs; in rs_alloc()
636 static int rs_set_nonblocking(struct rsocket *rs, int arg) in rs_set_nonblocking()
662 static void rs_set_qp_size(struct rsocket *rs) in rs_set_qp_size()
679 static void ds_set_qp_size(struct rsocket *rs) in ds_set_qp_size()
701 static int rs_init_bufs(struct rsocket *rs) in rs_init_bufs()
781 static int rs_create_cq(struct rsocket *rs, struct rdma_cm_id *cm_id) in rs_create_cq()
811 static inline int rs_post_recv(struct rsocket *rs) in rs_post_recv()
837 static inline int ds_post_recv(struct rsocket *rs, struct ds_qp *qp, uint32_t offset) in ds_post_recv()
857 static int rs_create_ep(struct rsocket *rs) in rs_create_ep()
914 static void rs_free_iomappings(struct rsocket *rs) in rs_free_iomappings()
954 static void ds_free(struct rsocket *rs) in ds_free()
987 static void rs_free(struct rsocket *rs) in rs_free()
1035 static size_t rs_conn_data_offset(struct rsocket *rs) in rs_conn_data_offset()
1041 static void rs_format_conn_data(struct rsocket *rs, struct rs_conn_data *conn) in rs_format_conn_data()
1059 static void rs_save_conn_data(struct rsocket *rs, struct rs_conn_data *conn) in rs_save_conn_data()
1083 static int ds_init(struct rsocket *rs, int domain) in ds_init()
1096 static int ds_init_ep(struct rsocket *rs) in ds_init_ep()
1130 int rsocket(int domain, int type, int protocol) in rsocket() function
1132 struct rsocket *rs; in rsocket()
1174 struct rsocket *rs; in rbind()
1197 struct rsocket *rs; in rlisten()
1228 struct rsocket *rs, *new_rs; in raccept()
1284 static int rs_do_connect(struct rsocket *rs) in rs_do_connect()
1415 static int ds_get_src_addr(struct rsocket *rs, in ds_get_src_addr()
1486 static int ds_create_qp(struct rsocket *rs, union socket_addr *src_addr, in ds_create_qp()
1557 static int ds_get_qp(struct rsocket *rs, union socket_addr *src_addr, in ds_get_qp()
1574 static int ds_get_dest(struct rsocket *rs, const struct sockaddr *addr, in ds_get_dest()
1618 struct rsocket *rs; in rconnect()
1643 static void *rs_get_ctrl_buf(struct rsocket *rs) in rs_get_ctrl_buf()
1649 static int rs_post_msg(struct rsocket *rs, uint32_t msg) in rs_post_msg()
1675 static int rs_post_write(struct rsocket *rs, in rs_post_write()
1694 static int rs_post_write_msg(struct rsocket *rs, in rs_post_write_msg()
1734 static int ds_post_send(struct rsocket *rs, struct ibv_sge *sge, in ds_post_send()
1756 static int rs_write_data(struct rsocket *rs, in rs_write_data()
1784 static int rs_write_direct(struct rsocket *rs, struct rs_iomap *iom, uint64_t offset, in rs_write_direct()
1797 static int rs_write_iomap(struct rsocket *rs, struct rs_iomap_mr *iomr, in rs_write_iomap()
1813 static uint32_t rs_sbuf_left(struct rsocket *rs) in rs_sbuf_left()
1819 static void rs_send_credits(struct rsocket *rs) in rs_send_credits()
1870 static inline int rs_ctrl_avail(struct rsocket *rs) in rs_ctrl_avail()
1876 static inline int rs_2ctrl_avail(struct rsocket *rs) in rs_2ctrl_avail()
1881 static int rs_give_credits(struct rsocket *rs) in rs_give_credits()
1894 static void rs_update_credits(struct rsocket *rs) in rs_update_credits()
1900 static int rs_poll_cq(struct rsocket *rs) in rs_poll_cq()
1988 static int rs_get_cq_event(struct rsocket *rs) in rs_get_cq_event()
2025 static int rs_process_cq(struct rsocket *rs, int nonblock, int (*test)(struct rsocket *rs)) in rs_process_cq()
2059 static int rs_get_comp(struct rsocket *rs, int nonblock, int (*test)(struct rsocket *rs)) in rs_get_comp()
2099 static void ds_poll_cqs(struct rsocket *rs) in ds_poll_cqs()
2149 static void ds_req_notify_cqs(struct rsocket *rs) in ds_req_notify_cqs()
2165 static int ds_get_cq_event(struct rsocket *rs) in ds_get_cq_event()
2191 static int ds_process_cqs(struct rsocket *rs, int nonblock, int (*test)(struct rsocket *rs)) in ds_process_cqs()
2220 static int ds_get_comp(struct rsocket *rs, int nonblock, int (*test)(struct rsocket *rs)) in ds_get_comp()
2243 static int rs_nonblocking(struct rsocket *rs, int flags) in rs_nonblocking()
2248 static int rs_is_cq_armed(struct rsocket *rs) in rs_is_cq_armed()
2253 static int rs_poll_all(struct rsocket *rs) in rs_poll_all()
2267 static int rs_can_send(struct rsocket *rs) in rs_can_send()
2280 static int ds_can_send(struct rsocket *rs) in ds_can_send()
2285 static int ds_all_sends_done(struct rsocket *rs) in ds_all_sends_done()
2290 static int rs_conn_can_send(struct rsocket *rs) in rs_conn_can_send()
2295 static int rs_conn_can_send_ctrl(struct rsocket *rs) in rs_conn_can_send_ctrl()
2300 static int rs_have_rdata(struct rsocket *rs) in rs_have_rdata()
2305 static int rs_conn_have_rdata(struct rsocket *rs) in rs_conn_have_rdata()
2310 static int rs_conn_all_sends_done(struct rsocket *rs) in rs_conn_all_sends_done()
2342 static ssize_t ds_recvfrom(struct rsocket *rs, void *buf, size_t len, int flags, in ds_recvfrom()
2378 static ssize_t rs_peek(struct rsocket *rs, void *buf, size_t len) in rs_peek()
2417 struct rsocket *rs; in rrecv()
2487 struct rsocket *rs; in rrecvfrom()
2532 static int rs_send_iomaps(struct rsocket *rs, int flags) in rs_send_iomaps()
2599 static ssize_t ds_sendv_udp(struct rsocket *rs, const struct iovec *iov, in ds_sendv_udp()
2637 static ssize_t ds_send_udp(struct rsocket *rs, const void *buf, size_t len, in ds_send_udp()
2650 static ssize_t dsend(struct rsocket *rs, const void *buf, size_t len, int flags) in dsend()
2687 struct rsocket *rs; in rsend()
2775 struct rsocket *rs; in rsendto()
2827 struct rsocket *rs; in rsendv()
2943 static int rs_poll_rs(struct rsocket *rs, int events, in rs_poll_rs()
2944 int nonblock, int (*test)(struct rsocket *rs)) in rs_poll_rs()
3012 struct rsocket *rs; in rs_poll_check()
3030 struct rsocket *rs; in rs_poll_arm()
3060 struct rsocket *rs; in rs_poll_events()
3226 struct rsocket *rs; in rshutdown()
3280 static void ds_shutdown(struct rsocket *rs) in ds_shutdown()
3297 struct rsocket *rs; in rclose()
3331 struct rsocket *rs; in rgetpeername()
3346 struct rsocket *rs; in rgetsockname()
3359 static int rs_set_keepalive(struct rsocket *rs, int on) in rs_set_keepalive()
3389 struct rsocket *rs; in rsetsockopt()
3570 struct rsocket *rs; in rgetsockopt()
3714 struct rsocket *rs; in rfcntl()
3743 static struct rs_iomap_mr *rs_get_iomap_mr(struct rsocket *rs) in rs_get_iomap_mr()
3771 struct rsocket *rs; in riomap()
3818 struct rsocket *rs; in riounmap()
3849 static struct rs_iomap *rs_find_iomap(struct rsocket *rs, off_t offset) in rs_find_iomap()
3863 struct rsocket *rs; in riowrite()
3946 struct rsocket **rss; in rs_svc_grow_sets()
3970 static int rs_svc_add_rs(struct rs_svc *svc, struct rsocket *rs) in rs_svc_add_rs()
3984 static int rs_svc_index(struct rs_svc *svc, struct rsocket *rs) in rs_svc_index()
3995 static int rs_svc_rm_rs(struct rs_svc *svc, struct rsocket *rs) in rs_svc_rm_rs()
4064 static void udp_svc_create_ah(struct rsocket *rs, struct ds_dest *dest, uint32_t qpn) in udp_svc_create_ah()
4129 static void udp_svc_forward(struct rsocket *rs, void *buf, size_t len, in udp_svc_forward()
4157 static void udp_svc_process_rs(struct rsocket *rs) in udp_svc_process_rs()
4293 static void tcp_svc_send_keepalive(struct rsocket *rs) in tcp_svc_send_keepalive()