| /linux/net/rds/ |
| H A D | rds.h | 103 struct rds_connection *cp_conn;
139 struct rds_connection { struct
151 struct rds_connection *c_passive; argument
178 struct net *rds_conn_net(struct rds_connection *conn) in rds_conn_net() argument
184 void rds_conn_net_set(struct rds_connection *conn, struct net *net) in rds_conn_net_set()
303 struct rds_connection *i_conn;
550 int (*conn_alloc)(struct rds_connection *conn, gfp_t gfp);
563 void (*conn_slots_available)(struct rds_connection *conn, bool fan_out);
595 int (*xmit)(struct rds_connection *conn, struct rds_message *rm,
597 int (*xmit_rdma)(struct rds_connection *conn, struct rm_rdma_op *op);
[all …]
|
| H A D | ib.h | 147 struct rds_connection *conn;
368 int rds_ib_conn_alloc(struct rds_connection *conn, gfp_t gfp);
373 void __rds_ib_conn_error(struct rds_connection *conn, const char *, ...);
377 void rds_ib_cm_connect_complete(struct rds_connection *conn,
387 void rds_ib_add_conn(struct rds_ib_device *rds_ibdev, struct rds_connection *conn);
388 void rds_ib_remove_conn(struct rds_ib_device *rds_ibdev, struct rds_connection *conn);
398 void rds_ib_recv_refill(struct rds_connection *conn, int prefill, gfp_t gfp);
425 int rds_ib_xmit(struct rds_connection *conn, struct rds_message *rm,
430 int rds_ib_xmit_rdma(struct rds_connection *conn, struct rm_rdma_op *op);
431 void rds_ib_send_add_credits(struct rds_connection *con
[all...] |
| H A D | connection.c | 83 static struct rds_connection *rds_conn_lookup(struct net *net, in rds_conn_lookup()
90 struct rds_connection *conn, *ret = NULL; in rds_conn_lookup()
116 struct rds_connection *conn = cp->cp_conn; in rds_conn_path_reset()
131 static void __rds_conn_path_init(struct rds_connection *conn, in __rds_conn_path_init()
161 static struct rds_connection *__rds_conn_create(struct net *net, in __rds_conn_create()
169 struct rds_connection *conn, *parent = NULL; in __rds_conn_create()
319 struct rds_connection *found; in __rds_conn_create()
361 struct rds_connection *rds_conn_create(struct net *net, in rds_conn_create()
371 struct rds_connection *rds_conn_create_outgoing(struct net *net, in rds_conn_create_outgoing()
383 struct rds_connection *con in rds_conn_shutdown()
687 rds_for_each_conn_info(struct socket * sock,unsigned int len,struct rds_info_iterator * iter,struct rds_info_lengths * lens,int (* visitor)(struct rds_connection *,void *),u64 * buffer,size_t item_len) rds_for_each_conn_info() argument
[all...] |
| H A D | loop.c | 53 static bool rds_loop_is_unloading(struct rds_connection *conn) in rds_loop_is_unloading()
75 static int rds_loop_xmit(struct rds_connection *conn, struct rds_message *rm, in rds_loop_xmit()
130 struct rds_connection *conn;
139 static int rds_loop_conn_alloc(struct rds_connection *conn, gfp_t gfp) in rds_loop_conn_alloc()
|
| H A D | ib_cm.c | 49 static void rds_ib_set_protocol(struct rds_connection *conn, unsigned int version) in rds_ib_set_protocol()
57 static void rds_ib_set_flow_control(struct rds_connection *conn, u32 credits) in rds_ib_set_flow_control()
74 void rds_ib_cm_connect_complete(struct rds_connection *conn, struct rdma_cm_event *event) in rds_ib_cm_connect_complete()
163 static void rds_ib_cm_fill_conn_param(struct rds_connection *conn, in rds_ib_cm_fill_conn_param()
249 struct rds_connection *conn = context; in rds_ib_cq_comp_handler_recv()
285 struct rds_connection *conn = ic->conn; in rds_ib_tasklet_fn_send()
325 struct rds_connection *conn = ic->conn; in rds_ib_tasklet_fn_recv()
356 struct rds_connection *conn = data; in rds_ib_qp_event_handler()
377 struct rds_connection *conn = context; in rds_ib_cq_comp_handler_send()
502 static int rds_ib_setup_qp(struct rds_connection *con
[all...] |
| H A D | cong.c | 186 void rds_cong_add_conn(struct rds_connection *conn) in rds_cong_add_conn()
196 void rds_cong_remove_conn(struct rds_connection *conn) in rds_cong_remove_conn()
206 int rds_cong_get_maps(struct rds_connection *conn) in rds_cong_get_maps()
219 struct rds_connection *conn; in rds_cong_queue_updates()
418 struct rds_message *rds_cong_update_alloc(struct rds_connection *conn) in rds_cong_update_alloc()
|
| H A D | threads.c | 100 void rds_connect_complete(struct rds_connection *conn) in rds_connect_complete()
127 struct rds_connection *conn = cp->cp_conn; in rds_queue_reconnect()
167 struct rds_connection *conn = cp->cp_conn; in rds_connect_worker()
|
| H A D | ib_send.c | 248 struct rds_connection *conn = ic->conn; in rds_ib_send_cqe_handler()
381 struct rds_connection *conn = ic->i_cm_id->context; in rds_ib_send_grab_credits()
410 void rds_ib_send_add_credits(struct rds_connection *conn, unsigned int credits) in rds_ib_send_add_credits()
431 void rds_ib_advertise_credits(struct rds_connection *conn, unsigned int posted) in rds_ib_advertise_credits()
486 int rds_ib_xmit(struct rds_connection *conn, struct rds_message *rm, in rds_ib_xmit()
794 int rds_ib_xmit_atomic(struct rds_connection *conn, struct rm_atomic_op *op) in rds_ib_xmit_atomic()
880 int rds_ib_xmit_rdma(struct rds_connection *conn, struct rm_rdma_op *op) in rds_ib_xmit_rdma()
1039 struct rds_connection *conn = cp->cp_conn;
|
| H A D | tcp_listen.c | 77 rds_tcp_accept_one_path(struct rds_connection *conn, struct socket *sock) in rds_tcp_accept_one_path()
108 void rds_tcp_conn_slots_available(struct rds_connection *conn, bool fan_out) in rds_tcp_conn_slots_available()
156 struct rds_connection *conn; in rds_tcp_accept_one()
|
| H A D | recv.c | 44 void rds_inc_init(struct rds_incoming *inc, struct rds_connection *conn, in rds_inc_init()
136 static void rds_conn_peer_gen_update(struct rds_connection *conn, in rds_conn_peer_gen_update()
203 struct rds_connection *conn) in rds_recv_hs_exthdrs()
289 static void rds_start_mprds(struct rds_connection *conn) in rds_start_mprds()
319 void rds_recv_incoming(struct rds_connection *conn, struct in6_addr *saddr, in rds_recv_incoming()
|
| H A D | send.c | 128 static bool rds_mprds_cp0_catchup(struct rds_connection *conn) in rds_mprds_cp0_catchup()
189 struct rds_connection *conn = cp->cp_conn; in rds_send_xmit()
793 void rds_send_drop_acked(struct rds_connection *conn, u64 ack, in rds_send_drop_acked()
804 struct rds_connection *conn; in rds_send_drop_to()
897 static int rds_send_queue_rm(struct rds_sock *rs, struct rds_connection *conn, in rds_send_queue_rm()
1154 struct rds_connection *conn; in rds_sendmsg()
1567 rds_send_ping(struct rds_connection *conn, int cp_index) in rds_send_ping()
|
| H A D | tcp_recv.c | 106 static void rds_tcp_cong_recv(struct rds_connection *conn, in rds_tcp_cong_recv()
238 struct rds_connection *conn = cp->cp_conn; in rds_tcp_data_recv()
|
| H A D | ib.c | 292 static int rds_ib_conn_info_visitor(struct rds_connection *conn, in rds_ib_conn_info_visitor()
331 static int rds6_ib_conn_info_visitor(struct rds_connection *conn, in rds6_ib_conn_info_visitor()
526 static bool rds_ib_is_unloading(struct rds_connection *conn) in rds_ib_is_unloading()
|
| H A D | tcp.h | 93 void rds_tcp_conn_slots_available(struct rds_connection *conn, bool fan_out);
109 int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm,
|
| H A D | ib_rdma.c | 122 void rds_ib_add_conn(struct rds_ib_device *rds_ibdev, struct rds_connection *conn) in rds_ib_add_conn()
141 void rds_ib_remove_conn(struct rds_ib_device *rds_ibdev, struct rds_connection *conn) in rds_ib_remove_conn()
546 struct rds_connection *conn, in rds_ib_get_mr()
|
| H A D | tcp.c | 395 static int rds_tcp_conn_alloc(struct rds_connection *conn, gfp_t gfp) in rds_tcp_conn_alloc()
437 static bool list_has_conn(struct list_head *list, struct rds_connection *conn) in list_has_conn()
453 static bool rds_tcp_is_unloading(struct rds_connection *conn) in rds_tcp_is_unloading()
|
| H A D | tcp_connect.c | 109 struct rds_connection *conn = cp->cp_conn; in rds_tcp_conn_path_connect()
|
| H A D | tcp_send.c | 70 int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm, in rds_tcp_xmit()
|
| H A D | rdma_transport.c | 54 struct rds_connection *conn = cm_id->context; in rds_rdma_cm_event_handler_cmn()
|