Home
last modified time | relevance | path

Searched refs:rds_conn_path (Results 1 - 25 of 38) sorted by relevance

12

/kernel/linux/linux-5.10/net/rds/
H A Dtcp.h16 struct rds_conn_path *t_cpath;
53 void rds_tcp_set_callbacks(struct socket *sock, struct rds_conn_path *cp);
54 void rds_tcp_reset_callbacks(struct socket *sock, struct rds_conn_path *cp);
65 int rds_tcp_conn_path_connect(struct rds_conn_path *cp);
66 void rds_tcp_conn_path_shutdown(struct rds_conn_path *conn);
81 int rds_tcp_recv_path(struct rds_conn_path *cp);
86 void rds_tcp_xmit_path_prepare(struct rds_conn_path *cp);
87 void rds_tcp_xmit_path_complete(struct rds_conn_path *cp);
H A Dthreads.c74 void rds_connect_path_complete(struct rds_conn_path *cp, int curr) in rds_connect_path_complete()
124 void rds_queue_reconnect(struct rds_conn_path *cp) in rds_queue_reconnect()
164 struct rds_conn_path *cp = container_of(work, in rds_connect_worker()
165 struct rds_conn_path, in rds_connect_worker()
193 struct rds_conn_path *cp = container_of(work, in rds_send_worker()
194 struct rds_conn_path, in rds_send_worker()
219 struct rds_conn_path *cp = container_of(work, in rds_recv_worker()
220 struct rds_conn_path, in rds_recv_worker()
243 struct rds_conn_path *cp = container_of(work, in rds_shutdown_worker()
244 struct rds_conn_path, in rds_shutdown_worker()
[all...]
H A Drds.h102 struct rds_conn_path { struct
166 struct rds_conn_path *c_path;
283 struct rds_conn_path *i_conn_path;
487 struct rds_conn_path *m_conn_path;
547 int (*conn_path_connect)(struct rds_conn_path *cp);
548 void (*conn_path_shutdown)(struct rds_conn_path *conn);
549 void (*xmit_path_prepare)(struct rds_conn_path *cp);
550 void (*xmit_path_complete)(struct rds_conn_path *cp);
555 int (*recv_path)(struct rds_conn_path *cp);
775 void rds_conn_shutdown(struct rds_conn_path *cpat
[all...]
H A Dconnection.c113 static void rds_conn_path_reset(struct rds_conn_path *cp) in rds_conn_path_reset()
131 struct rds_conn_path *cp, bool is_outgoing) in __rds_conn_path_init()
198 conn->c_path = kcalloc(npaths, sizeof(struct rds_conn_path), gfp); in __rds_conn_create()
317 struct rds_conn_path *cp; in __rds_conn_create()
367 void rds_conn_shutdown(struct rds_conn_path *cp) in rds_conn_shutdown()
438 /* destroy a single rds_conn_path. rds_conn_destroy() iterates over
441 static void rds_conn_path_destroy(struct rds_conn_path *cp) in rds_conn_path_destroy()
485 struct rds_conn_path *cp; in rds_conn_destroy()
558 struct rds_conn_path *cp; in rds_conn_message_info_cmn()
693 int (*visitor)(struct rds_conn_path *, voi in rds_walk_conn_path_info()
[all...]
H A Dtcp_send.c41 void rds_tcp_xmit_path_prepare(struct rds_conn_path *cp) in rds_tcp_xmit_path_prepare()
48 void rds_tcp_xmit_path_complete(struct rds_conn_path *cp) in rds_tcp_xmit_path_complete()
73 struct rds_conn_path *cp = rm->m_inc.i_conn_path; in rds_tcp_xmit()
181 struct rds_conn_path *cp; in rds_tcp_write_space()
H A Dtcp_recv.c150 struct rds_conn_path *conn_path;
158 struct rds_conn_path *cp = arg->conn_path; in rds_tcp_data_recv()
262 static int rds_tcp_read_sock(struct rds_conn_path *cp, gfp_t gfp) in rds_tcp_read_sock()
290 int rds_tcp_recv_path(struct rds_conn_path *cp) in rds_tcp_recv_path()
309 struct rds_conn_path *cp; in rds_tcp_data_ready()
H A Dtcp_connect.c43 struct rds_conn_path *cp; in rds_tcp_state_change()
89 int rds_tcp_conn_path_connect(struct rds_conn_path *cp) in rds_tcp_conn_path_connect()
200 void rds_tcp_conn_path_shutdown(struct rds_conn_path *cp) in rds_tcp_conn_path_shutdown()
H A Dloop.c119 static int rds_loop_recv_path(struct rds_conn_path *cp) in rds_loop_recv_path()
167 static int rds_loop_conn_path_connect(struct rds_conn_path *cp) in rds_loop_conn_path_connect()
173 static void rds_loop_conn_path_shutdown(struct rds_conn_path *cp) in rds_loop_conn_path_shutdown()
H A Dsend.c65 void rds_send_path_reset(struct rds_conn_path *cp) in rds_send_path_reset()
104 static int acquire_in_xmit(struct rds_conn_path *cp) in acquire_in_xmit()
109 static void release_in_xmit(struct rds_conn_path *cp) in release_in_xmit()
137 int rds_send_xmit(struct rds_conn_path *cp) in rds_send_xmit()
686 void rds_send_path_drop_acked(struct rds_conn_path *cp, u64 ack, in rds_send_path_drop_acked()
726 struct rds_conn_path *cp; in rds_send_drop_to()
819 struct rds_conn_path *cp, in rds_send_queue_rm()
1114 struct rds_conn_path *cpath; in rds_sendmsg()
1427 rds_send_probe(struct rds_conn_path *cp, __be16 sport, in rds_send_probe()
1495 rds_send_pong(struct rds_conn_path *c
[all...]
H A Dib.h370 int rds_ib_conn_path_connect(struct rds_conn_path *cp);
371 void rds_ib_conn_path_shutdown(struct rds_conn_path *cp);
397 int rds_ib_recv_path(struct rds_conn_path *conn);
427 void rds_ib_xmit_path_complete(struct rds_conn_path *cp);
H A Dtcp_listen.c85 struct rds_conn_path *cp = &conn->c_path[i]; in rds_tcp_accept_one_path()
105 struct rds_conn_path *cp; in rds_tcp_accept_one()
H A Drecv.c57 void rds_inc_path_init(struct rds_incoming *inc, struct rds_conn_path *cp, in rds_inc_path_init()
144 struct rds_conn_path *cp; in rds_conn_peer_gen_update()
255 struct rds_conn_path *cp; in rds_start_mprds()
289 struct rds_conn_path *cp; in rds_recv_incoming()
H A Dtcp.c139 struct rds_conn_path *cp) in rds_tcp_reset_callbacks()
193 void rds_tcp_set_callbacks(struct socket *sock, struct rds_conn_path *cp) in rds_tcp_set_callbacks()
388 rdsdebug("rds_conn_path [%d] tc %p\n", i, in rds_tcp_conn_alloc()
/kernel/linux/linux-6.6/net/rds/
H A Dtcp.h16 struct rds_conn_path *t_cpath;
53 void rds_tcp_set_callbacks(struct socket *sock, struct rds_conn_path *cp);
54 void rds_tcp_reset_callbacks(struct socket *sock, struct rds_conn_path *cp);
64 int rds_tcp_conn_path_connect(struct rds_conn_path *cp);
65 void rds_tcp_conn_path_shutdown(struct rds_conn_path *conn);
80 int rds_tcp_recv_path(struct rds_conn_path *cp);
85 void rds_tcp_xmit_path_prepare(struct rds_conn_path *cp);
86 void rds_tcp_xmit_path_complete(struct rds_conn_path *cp);
H A Dthreads.c74 void rds_connect_path_complete(struct rds_conn_path *cp, int curr) in rds_connect_path_complete()
124 void rds_queue_reconnect(struct rds_conn_path *cp) in rds_queue_reconnect()
164 struct rds_conn_path *cp = container_of(work, in rds_connect_worker()
165 struct rds_conn_path, in rds_connect_worker()
193 struct rds_conn_path *cp = container_of(work, in rds_send_worker()
194 struct rds_conn_path, in rds_send_worker()
220 struct rds_conn_path *cp = container_of(work, in rds_recv_worker()
221 struct rds_conn_path, in rds_recv_worker()
245 struct rds_conn_path *cp = container_of(work, in rds_shutdown_worker()
246 struct rds_conn_path, in rds_shutdown_worker()
[all...]
H A Drds.h102 struct rds_conn_path { struct
166 struct rds_conn_path *c_path;
283 struct rds_conn_path *i_conn_path;
487 struct rds_conn_path *m_conn_path;
547 int (*conn_path_connect)(struct rds_conn_path *cp);
548 void (*conn_path_shutdown)(struct rds_conn_path *conn);
549 void (*xmit_path_prepare)(struct rds_conn_path *cp);
550 void (*xmit_path_complete)(struct rds_conn_path *cp);
555 int (*recv_path)(struct rds_conn_path *cp);
775 void rds_conn_shutdown(struct rds_conn_path *cpat
[all...]
H A Dconnection.c113 static void rds_conn_path_reset(struct rds_conn_path *cp) in rds_conn_path_reset()
131 struct rds_conn_path *cp, bool is_outgoing) in __rds_conn_path_init()
198 conn->c_path = kcalloc(npaths, sizeof(struct rds_conn_path), gfp); in __rds_conn_create()
317 struct rds_conn_path *cp; in __rds_conn_create()
367 void rds_conn_shutdown(struct rds_conn_path *cp) in rds_conn_shutdown()
438 /* destroy a single rds_conn_path. rds_conn_destroy() iterates over
441 static void rds_conn_path_destroy(struct rds_conn_path *cp) in rds_conn_path_destroy()
485 struct rds_conn_path *cp; in rds_conn_destroy()
558 struct rds_conn_path *cp; in rds_conn_message_info_cmn()
693 int (*visitor)(struct rds_conn_path *, voi in rds_walk_conn_path_info()
[all...]
H A Dtcp_send.c41 void rds_tcp_xmit_path_prepare(struct rds_conn_path *cp) in rds_tcp_xmit_path_prepare()
48 void rds_tcp_xmit_path_complete(struct rds_conn_path *cp) in rds_tcp_xmit_path_complete()
73 struct rds_conn_path *cp = rm->m_inc.i_conn_path; in rds_tcp_xmit()
182 struct rds_conn_path *cp; in rds_tcp_write_space()
H A Dtcp_recv.c151 struct rds_conn_path *conn_path;
159 struct rds_conn_path *cp = arg->conn_path; in rds_tcp_data_recv()
263 static int rds_tcp_read_sock(struct rds_conn_path *cp, gfp_t gfp) in rds_tcp_read_sock()
291 int rds_tcp_recv_path(struct rds_conn_path *cp) in rds_tcp_recv_path()
310 struct rds_conn_path *cp; in rds_tcp_data_ready()
H A Dloop.c119 static int rds_loop_recv_path(struct rds_conn_path *cp) in rds_loop_recv_path()
167 static int rds_loop_conn_path_connect(struct rds_conn_path *cp) in rds_loop_conn_path_connect()
173 static void rds_loop_conn_path_shutdown(struct rds_conn_path *cp) in rds_loop_conn_path_shutdown()
H A Dtcp_connect.c43 struct rds_conn_path *cp; in rds_tcp_state_change()
90 int rds_tcp_conn_path_connect(struct rds_conn_path *cp) in rds_tcp_conn_path_connect()
204 void rds_tcp_conn_path_shutdown(struct rds_conn_path *cp) in rds_tcp_conn_path_shutdown()
H A Dsend.c65 void rds_send_path_reset(struct rds_conn_path *cp) in rds_send_path_reset()
104 static int acquire_in_xmit(struct rds_conn_path *cp) in acquire_in_xmit()
109 static void release_in_xmit(struct rds_conn_path *cp) in release_in_xmit()
136 int rds_send_xmit(struct rds_conn_path *cp) in rds_send_xmit()
685 void rds_send_path_drop_acked(struct rds_conn_path *cp, u64 ack, in rds_send_path_drop_acked()
725 struct rds_conn_path *cp; in rds_send_drop_to()
818 struct rds_conn_path *cp, in rds_send_queue_rm()
1113 struct rds_conn_path *cpath; in rds_sendmsg()
1421 rds_send_probe(struct rds_conn_path *cp, __be16 sport, in rds_send_probe()
1489 rds_send_pong(struct rds_conn_path *c
[all...]
H A Dib.h370 int rds_ib_conn_path_connect(struct rds_conn_path *cp);
371 void rds_ib_conn_path_shutdown(struct rds_conn_path *cp);
397 int rds_ib_recv_path(struct rds_conn_path *conn);
427 void rds_ib_xmit_path_complete(struct rds_conn_path *cp);
H A Dtcp_listen.c86 struct rds_conn_path *cp = &conn->c_path[i]; in rds_tcp_accept_one_path()
106 struct rds_conn_path *cp; in rds_tcp_accept_one()
H A Drecv.c58 void rds_inc_path_init(struct rds_incoming *inc, struct rds_conn_path *cp, in rds_inc_path_init()
145 struct rds_conn_path *cp; in rds_conn_peer_gen_update()
256 struct rds_conn_path *cp; in rds_start_mprds()
290 struct rds_conn_path *cp; in rds_recv_incoming()

Completed in 21 milliseconds

12