Home
last modified time | relevance | path

Searched refs:rds_conn_path (Results 1 – 16 of 16) sorted by relevance

/net/rds/
Dthreads.c74 void rds_connect_path_complete(struct rds_conn_path *cp, int curr) in rds_connect_path_complete()
119 void rds_queue_reconnect(struct rds_conn_path *cp) in rds_queue_reconnect()
153 struct rds_conn_path *cp = container_of(work, in rds_connect_worker()
154 struct rds_conn_path, in rds_connect_worker()
182 struct rds_conn_path *cp = container_of(work, in rds_send_worker()
183 struct rds_conn_path, in rds_send_worker()
208 struct rds_conn_path *cp = container_of(work, in rds_recv_worker()
209 struct rds_conn_path, in rds_recv_worker()
232 struct rds_conn_path *cp = container_of(work, in rds_shutdown_worker()
233 struct rds_conn_path, in rds_shutdown_worker()
Dtcp.h15 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);
Drds.h96 struct rds_conn_path { struct
155 struct rds_conn_path c_path[RDS_MPATH_WORKERS];
257 struct rds_conn_path *i_conn_path;
481 int (*conn_path_connect)(struct rds_conn_path *cp);
482 void (*conn_path_shutdown)(struct rds_conn_path *conn);
483 void (*xmit_path_prepare)(struct rds_conn_path *cp);
484 void (*xmit_path_complete)(struct rds_conn_path *cp);
489 int (*recv_path)(struct rds_conn_path *cp);
679 void rds_conn_shutdown(struct rds_conn_path *cpath);
682 void rds_conn_path_drop(struct rds_conn_path *cpath);
[all …]
Dconnection.c98 static void rds_conn_path_reset(struct rds_conn_path *cp) in rds_conn_path_reset()
116 struct rds_conn_path *cp, bool is_outgoing) in __rds_conn_path_init()
257 struct rds_conn_path *cp; in __rds_conn_create()
299 void rds_conn_shutdown(struct rds_conn_path *cp) in rds_conn_shutdown()
365 static void rds_conn_path_destroy(struct rds_conn_path *cp) in rds_conn_path_destroy()
404 struct rds_conn_path *cp; in rds_conn_destroy()
459 struct rds_conn_path *cp; in rds_conn_message_info()
549 int (*visitor)(struct rds_conn_path *, void *), in rds_walk_conn_path_info() argument
566 struct rds_conn_path *cp; in rds_walk_conn_path_info()
592 static int rds_conn_info_visitor(struct rds_conn_path *cp, void *buffer) in rds_conn_info_visitor()
[all …]
Dtcp_send.c52 void rds_tcp_xmit_path_prepare(struct rds_conn_path *cp) in rds_tcp_xmit_path_prepare()
59 void rds_tcp_xmit_path_complete(struct rds_conn_path *cp) in rds_tcp_xmit_path_complete()
84 struct rds_conn_path *cp = rm->m_inc.i_conn_path; in rds_tcp_xmit()
189 struct rds_conn_path *cp; in rds_tcp_write_space()
Dtcp_recv.c150 struct rds_conn_path *conn_path;
158 struct rds_conn_path *cp = arg->conn_path; in rds_tcp_data_recv()
256 static int rds_tcp_read_sock(struct rds_conn_path *cp, gfp_t gfp) in rds_tcp_read_sock()
284 int rds_tcp_recv_path(struct rds_conn_path *cp) in rds_tcp_recv_path()
303 struct rds_conn_path *cp; in rds_tcp_data_ready()
Dloop.c105 static int rds_loop_recv_path(struct rds_conn_path *cp) in rds_loop_recv_path()
153 static int rds_loop_conn_path_connect(struct rds_conn_path *cp) in rds_loop_conn_path_connect()
159 static void rds_loop_conn_path_shutdown(struct rds_conn_path *cp) in rds_loop_conn_path_shutdown()
Dtcp_connect.c43 struct rds_conn_path *cp; in rds_tcp_state_change()
76 int rds_tcp_conn_path_connect(struct rds_conn_path *cp) in rds_tcp_conn_path_connect()
153 void rds_tcp_conn_path_shutdown(struct rds_conn_path *cp) in rds_tcp_conn_path_shutdown()
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()
661 void rds_send_path_drop_acked(struct rds_conn_path *cp, u64 ack, in rds_send_path_drop_acked()
701 struct rds_conn_path *cp; in rds_send_drop_to()
798 struct rds_conn_path *cp, in rds_send_queue_rm()
1037 struct rds_conn_path *cpath; in rds_sendmsg()
1222 rds_send_probe(struct rds_conn_path *cp, __be16 sport, in rds_send_probe()
1281 rds_send_pong(struct rds_conn_path *cp, __be16 dport) in rds_send_pong()
[all …]
Dtcp_listen.c89 struct rds_conn_path *cp = &conn->c_path[0]; in rds_tcp_accept_one_path()
107 struct rds_conn_path *cp = &conn->c_path[i]; in rds_tcp_accept_one_path()
127 struct rds_conn_path *cp; in rds_tcp_accept_one()
Dib.h331 int rds_ib_conn_path_connect(struct rds_conn_path *cp);
332 void rds_ib_conn_path_shutdown(struct rds_conn_path *cp);
358 int rds_ib_recv_path(struct rds_conn_path *conn);
388 void rds_ib_xmit_path_complete(struct rds_conn_path *cp);
Drecv.c56 void rds_inc_path_init(struct rds_incoming *inc, struct rds_conn_path *cp, in rds_inc_path_init()
210 struct rds_conn_path *cp; in rds_start_mprds()
242 struct rds_conn_path *cp; in rds_recv_incoming()
Dtcp.c138 struct rds_conn_path *cp) in rds_tcp_reset_callbacks()
192 void rds_tcp_set_callbacks(struct socket *sock, struct rds_conn_path *cp) in rds_tcp_set_callbacks()
501 struct rds_conn_path *cp; in rds_tcp_conn_paths_destroy()
Dib_cm.c713 int rds_ib_conn_path_connect(struct rds_conn_path *cp) in rds_ib_conn_path_connect()
760 void rds_ib_conn_path_shutdown(struct rds_conn_path *cp) in rds_ib_conn_path_shutdown()
Dib_recv.c1012 int rds_ib_recv_path(struct rds_conn_path *cp) in rds_ib_recv_path()
Dib_send.c988 void rds_ib_xmit_path_complete(struct rds_conn_path *cp) in rds_ib_xmit_path_complete()