| /net/rds/ |
| D | rds.h | 84 struct rds_connection { struct
89 struct rds_connection *c_passive; argument
201 struct rds_connection *i_conn;
423 int (*conn_alloc)(struct rds_connection *conn, gfp_t gfp);
425 int (*conn_connect)(struct rds_connection *conn);
426 void (*conn_shutdown)(struct rds_connection *conn);
427 void (*xmit_prepare)(struct rds_connection *conn);
428 void (*xmit_complete)(struct rds_connection *conn);
429 int (*xmit)(struct rds_connection *conn, struct rds_message *rm,
431 int (*xmit_rdma)(struct rds_connection *conn, struct rm_rdma_op *op);
[all …]
|
| D | threads.c | 74 void rds_connect_complete(struct rds_connection *conn) in rds_connect_complete()
114 void rds_queue_reconnect(struct rds_connection *conn) in rds_queue_reconnect()
142 struct rds_connection *conn = container_of(work, struct rds_connection, c_conn_w.work); in rds_connect_worker()
162 struct rds_connection *conn = container_of(work, struct rds_connection, c_send_w.work); in rds_send_worker()
184 struct rds_connection *conn = container_of(work, struct rds_connection, c_recv_w.work); in rds_recv_worker()
206 struct rds_connection *conn = container_of(work, struct rds_connection, c_down_w); in rds_shutdown_worker()
|
| D | ib.h | 98 struct rds_connection *conn;
279 int rds_ib_conn_alloc(struct rds_connection *conn, gfp_t gfp);
281 int rds_ib_conn_connect(struct rds_connection *conn);
282 void rds_ib_conn_shutdown(struct rds_connection *conn);
286 void __rds_ib_conn_error(struct rds_connection *conn, const char *, ...);
290 void rds_ib_cm_connect_complete(struct rds_connection *conn,
299 void rds_ib_add_conn(struct rds_ib_device *rds_ibdev, struct rds_connection *conn);
300 void rds_ib_remove_conn(struct rds_ib_device *rds_ibdev, struct rds_connection *conn);
314 int rds_ib_recv(struct rds_connection *conn);
317 void rds_ib_recv_refill(struct rds_connection *conn, int prefill);
[all …]
|
| D | tcp.h | 14 struct rds_connection *conn;
48 void rds_tcp_set_callbacks(struct socket *sock, struct rds_connection *conn);
57 int rds_tcp_conn_connect(struct rds_connection *conn);
58 void rds_tcp_conn_shutdown(struct rds_connection *conn);
70 int rds_tcp_recv(struct rds_connection *conn);
76 void rds_tcp_xmit_prepare(struct rds_connection *conn);
77 void rds_tcp_xmit_complete(struct rds_connection *conn);
78 int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm,
|
| D | connection.c | 67 static struct rds_connection *rds_conn_lookup(struct hlist_head *head, in rds_conn_lookup()
71 struct rds_connection *conn, *ret = NULL; in rds_conn_lookup()
91 static void rds_conn_reset(struct rds_connection *conn) in rds_conn_reset()
114 static struct rds_connection *__rds_conn_create(__be32 laddr, __be32 faddr, in __rds_conn_create()
118 struct rds_connection *conn, *parent = NULL; in __rds_conn_create()
224 struct rds_connection *found; in __rds_conn_create()
243 struct rds_connection *rds_conn_create(__be32 laddr, __be32 faddr, in rds_conn_create()
250 struct rds_connection *rds_conn_create_outgoing(__be32 laddr, __be32 faddr, in rds_conn_create_outgoing()
257 void rds_conn_shutdown(struct rds_connection *conn) in rds_conn_shutdown()
320 void rds_conn_destroy(struct rds_connection *conn) in rds_conn_destroy()
[all …]
|
| D | iw.h | 106 struct rds_connection *conn;
281 int rds_iw_conn_alloc(struct rds_connection *conn, gfp_t gfp);
283 int rds_iw_conn_connect(struct rds_connection *conn);
284 void rds_iw_conn_shutdown(struct rds_connection *conn);
288 void __rds_iw_conn_error(struct rds_connection *conn, const char *, ...);
292 void rds_iw_cm_connect_complete(struct rds_connection *conn,
301 void rds_iw_add_conn(struct rds_iw_device *rds_iwdev, struct rds_connection *conn);
302 void rds_iw_remove_conn(struct rds_iw_device *rds_iwdev, struct rds_connection *conn);
324 int rds_iw_recv(struct rds_connection *conn);
325 int rds_iw_recv_refill(struct rds_connection *conn, gfp_t kptr_gfp,
[all …]
|
| D | loop.c | 60 static int rds_loop_xmit(struct rds_connection *conn, struct rds_message *rm, in rds_loop_xmit()
103 static int rds_loop_recv(struct rds_connection *conn) in rds_loop_recv()
110 struct rds_connection *conn;
119 static int rds_loop_conn_alloc(struct rds_connection *conn, gfp_t gfp) in rds_loop_conn_alloc()
151 static int rds_loop_conn_connect(struct rds_connection *conn) in rds_loop_conn_connect()
157 static void rds_loop_conn_shutdown(struct rds_connection *conn) in rds_loop_conn_shutdown()
|
| D | iw_cm.c | 45 static void rds_iw_set_protocol(struct rds_connection *conn, unsigned int version) in rds_iw_set_protocol()
53 static void rds_iw_set_flow_control(struct rds_connection *conn, u32 credits) in rds_iw_set_flow_control()
70 void rds_iw_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) in rds_iw_cm_connect_complete()
107 static void rds_iw_cm_fill_conn_param(struct rds_connection *conn, in rds_iw_cm_fill_conn_param()
149 struct rds_connection *conn = data; in rds_iw_qp_event_handler()
247 static int rds_iw_setup_qp(struct rds_connection *conn) in rds_iw_setup_qp()
382 struct rds_connection *conn = NULL; in rds_iw_cm_handle_connect()
478 struct rds_connection *conn = cm_id->context; in rds_iw_cm_initiate_connect()
514 int rds_iw_conn_connect(struct rds_connection *conn) in rds_iw_conn_connect()
574 void rds_iw_conn_shutdown(struct rds_connection *conn) in rds_iw_conn_shutdown()
[all …]
|
| D | ib_cm.c | 75 static void rds_ib_set_protocol(struct rds_connection *conn, unsigned int version) in rds_ib_set_protocol()
83 static void rds_ib_set_flow_control(struct rds_connection *conn, u32 credits) in rds_ib_set_flow_control()
125 void rds_ib_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) in rds_ib_cm_connect_complete()
192 static void rds_ib_cm_fill_conn_param(struct rds_connection *conn, in rds_ib_cm_fill_conn_param()
242 struct rds_connection *conn = data; in rds_ib_qp_event_handler()
266 static int rds_ib_setup_qp(struct rds_connection *conn) in rds_ib_setup_qp()
452 struct rds_connection *conn = NULL; in rds_ib_cm_handle_connect()
544 struct rds_connection *conn = cm_id->context; in rds_ib_cm_initiate_connect()
578 int rds_ib_conn_connect(struct rds_connection *conn) in rds_ib_conn_connect()
624 void rds_ib_conn_shutdown(struct rds_connection *conn) in rds_ib_conn_shutdown()
[all …]
|
| D | tcp_recv.c | 125 static void rds_tcp_cong_recv(struct rds_connection *conn, in rds_tcp_cong_recv()
170 struct rds_connection *conn;
178 struct rds_connection *conn = arg->conn; in rds_tcp_data_recv()
274 static int rds_tcp_read_sock(struct rds_connection *conn, gfp_t gfp) in rds_tcp_read_sock()
302 int rds_tcp_recv(struct rds_connection *conn) in rds_tcp_recv()
320 struct rds_connection *conn; in rds_tcp_data_ready()
|
| D | tcp_send.c | 51 void rds_tcp_xmit_prepare(struct rds_connection *conn) in rds_tcp_xmit_prepare()
58 void rds_tcp_xmit_complete(struct rds_connection *conn) in rds_tcp_xmit_complete()
80 int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm, in rds_tcp_xmit()
174 struct rds_connection *conn; in rds_tcp_write_space()
|
| D | tcp_connect.c | 43 struct rds_connection *conn; in rds_tcp_state_change()
75 int rds_tcp_conn_connect(struct rds_connection *conn) in rds_tcp_conn_connect()
130 void rds_tcp_conn_shutdown(struct rds_connection *conn) in rds_tcp_conn_shutdown()
|
| D | cong.c | 183 void rds_cong_add_conn(struct rds_connection *conn) in rds_cong_add_conn()
193 void rds_cong_remove_conn(struct rds_connection *conn) in rds_cong_remove_conn()
203 int rds_cong_get_maps(struct rds_connection *conn) in rds_cong_get_maps()
216 struct rds_connection *conn; in rds_cong_queue_updates()
396 struct rds_message *rds_cong_update_alloc(struct rds_connection *conn) in rds_cong_update_alloc()
|
| D | send.c | 64 void rds_send_reset(struct rds_connection *conn) in rds_send_reset()
102 static int acquire_in_xmit(struct rds_connection *conn) in acquire_in_xmit()
107 static void release_in_xmit(struct rds_connection *conn) in release_in_xmit()
135 int rds_send_xmit(struct rds_connection *conn) in rds_send_xmit()
524 struct rds_message *rds_send_get_message(struct rds_connection *conn, in rds_send_get_message()
645 void rds_send_drop_acked(struct rds_connection *conn, u64 ack, in rds_send_drop_acked()
676 struct rds_connection *conn; in rds_send_drop_to()
751 static int rds_send_queue_rm(struct rds_sock *rs, struct rds_connection *conn, in rds_send_queue_rm()
929 struct rds_connection *conn; in rds_sendmsg()
1089 rds_send_pong(struct rds_connection *conn, __be16 dport) in rds_send_pong()
|
| D | iw_recv.c | 137 static int rds_iw_recv_refill_one(struct rds_connection *conn, in rds_iw_recv_refill_one()
224 int rds_iw_recv_refill(struct rds_connection *conn, gfp_t kptr_gfp, in rds_iw_recv_refill()
568 static void rds_iw_cong_recv(struct rds_connection *conn, in rds_iw_cong_recv()
649 static void rds_iw_process_recv(struct rds_connection *conn, in rds_iw_process_recv()
785 struct rds_connection *conn = context; in rds_iw_recv_cq_comp_handler()
798 struct rds_connection *conn = ic->conn; in rds_poll_cq()
836 struct rds_connection *conn = ic->conn; in rds_iw_recv_tasklet_fn()
865 int rds_iw_recv(struct rds_connection *conn) in rds_iw_recv()
|
| D | ib_recv.c | 299 static int rds_ib_recv_refill_one(struct rds_connection *conn, in rds_ib_recv_refill_one()
357 void rds_ib_recv_refill(struct rds_connection *conn, int prefill) in rds_ib_recv_refill()
738 static void rds_ib_cong_recv(struct rds_connection *conn, in rds_ib_cong_recv()
819 static void rds_ib_process_recv(struct rds_connection *conn, in rds_ib_process_recv()
955 struct rds_connection *conn = context; in rds_ib_recv_cq_comp_handler()
968 struct rds_connection *conn = ic->conn; in rds_poll_cq()
1012 struct rds_connection *conn = ic->conn; in rds_ib_recv_tasklet_fn()
1038 int rds_ib_recv(struct rds_connection *conn) in rds_ib_recv()
|
| D | ib_send.c | 276 struct rds_connection *conn = context; in rds_ib_send_cq_comp_handler()
420 struct rds_connection *conn = ic->i_cm_id->context; in rds_ib_send_grab_credits()
449 void rds_ib_send_add_credits(struct rds_connection *conn, unsigned int credits) in rds_ib_send_add_credits()
470 void rds_ib_advertise_credits(struct rds_connection *conn, unsigned int posted) in rds_ib_advertise_credits()
525 int rds_ib_xmit(struct rds_connection *conn, struct rds_message *rm, in rds_ib_xmit()
787 int rds_ib_xmit_atomic(struct rds_connection *conn, struct rm_atomic_op *op) in rds_ib_xmit_atomic()
876 int rds_ib_xmit_rdma(struct rds_connection *conn, struct rm_rdma_op *op) in rds_ib_xmit_rdma()
1014 void rds_ib_xmit_complete(struct rds_connection *conn) in rds_ib_xmit_complete()
|
| D | iw_send.c | 198 struct rds_connection *conn = context; in rds_iw_send_cq_comp_handler()
372 struct rds_connection *conn = ic->i_cm_id->context; in rds_iw_send_grab_credits()
401 void rds_iw_send_add_credits(struct rds_connection *conn, unsigned int credits) in rds_iw_send_add_credits()
422 void rds_iw_advertise_credits(struct rds_connection *conn, unsigned int posted) in rds_iw_advertise_credits()
496 int rds_iw_xmit(struct rds_connection *conn, struct rds_message *rm, in rds_iw_xmit()
788 int rds_iw_xmit_rdma(struct rds_connection *conn, struct rm_rdma_op *op) in rds_iw_xmit_rdma()
967 void rds_iw_xmit_complete(struct rds_connection *conn) in rds_iw_xmit_complete()
|
| D | rdma_transport.h | 10 int rds_rdma_conn_connect(struct rds_connection *conn);
|
| D | tcp.c | 121 void rds_tcp_set_callbacks(struct socket *sock, struct rds_connection *conn) in rds_tcp_set_callbacks()
199 static int rds_tcp_conn_alloc(struct rds_connection *conn, gfp_t gfp) in rds_tcp_conn_alloc()
|
| D | rdma_transport.c | 72 struct rds_connection *conn = cm_id->context; in rds_rdma_cm_event_handler()
|
| D | recv.c | 41 void rds_inc_init(struct rds_incoming *inc, struct rds_connection *conn, in rds_inc_init()
157 void rds_recv_incoming(struct rds_connection *conn, __be32 saddr, __be32 daddr, in rds_recv_incoming()
|
| D | tcp_listen.c | 51 struct rds_connection *conn; in rds_tcp_accept_one()
|
| D | ib_rdma.c | 162 void rds_ib_add_conn(struct rds_ib_device *rds_ibdev, struct rds_connection *conn) in rds_ib_add_conn()
181 void rds_ib_remove_conn(struct rds_ib_device *rds_ibdev, struct rds_connection *conn) in rds_ib_remove_conn()
|
| D | iw.c | 167 static int rds_iw_conn_info_visitor(struct rds_connection *conn, in rds_iw_conn_info_visitor()
|