net/rds/tcp.h

0001 /* SPDX-License-Identifier: GPL-2.0 */
0002 #ifndef _RDS_TCP_H
0003 #define _RDS_TCP_H
0004
0005 #define RDS_TCP_PORT    16385
0006
0007 struct rds_tcp_incoming {
0008     struct rds_incoming ti_inc;
0009     struct sk_buff_head ti_skb_list;
0010 };
0011
0012 struct rds_tcp_connection {
0013
0014     struct list_head    t_tcp_node;
0015     bool            t_tcp_node_detached;
0016     struct rds_conn_path    *t_cpath;
0017     /* t_conn_path_lock synchronizes the connection establishment between
0018      * rds_tcp_accept_one and rds_tcp_conn_path_connect
0019      */
0020     struct mutex        t_conn_path_lock;
0021     struct socket       *t_sock;
0022     void            *t_orig_write_space;
0023     void            *t_orig_data_ready;
0024     void            *t_orig_state_change;
0025
0026     struct rds_tcp_incoming *t_tinc;
0027     size_t          t_tinc_hdr_rem;
0028     size_t          t_tinc_data_rem;
0029
0030     /* XXX error report? */
0031     struct work_struct  t_conn_w;
0032     struct work_struct  t_send_w;
0033     struct work_struct  t_down_w;
0034     struct work_struct  t_recv_w;
0035
0036     /* for info exporting only */
0037     struct list_head    t_list_item;
0038     u32         t_last_sent_nxt;
0039     u32         t_last_expected_una;
0040     u32         t_last_seen_una;
0041 };
0042
0043 struct rds_tcp_statistics {
0044     uint64_t    s_tcp_data_ready_calls;
0045     uint64_t    s_tcp_write_space_calls;
0046     uint64_t    s_tcp_sndbuf_full;
0047     uint64_t    s_tcp_connect_raced;
0048     uint64_t    s_tcp_listen_closed_stale;
0049 };
0050
0051 /* tcp.c */
0052 bool rds_tcp_tune(struct socket *sock);
0053 void rds_tcp_set_callbacks(struct socket *sock, struct rds_conn_path *cp);
0054 void rds_tcp_reset_callbacks(struct socket *sock, struct rds_conn_path *cp);
0055 void rds_tcp_restore_callbacks(struct socket *sock,
0056                    struct rds_tcp_connection *tc);
0057 u32 rds_tcp_write_seq(struct rds_tcp_connection *tc);
0058 u32 rds_tcp_snd_una(struct rds_tcp_connection *tc);
0059 u64 rds_tcp_map_seq(struct rds_tcp_connection *tc, u32 seq);
0060 extern struct rds_transport rds_tcp_transport;
0061 void rds_tcp_accept_work(struct sock *sk);
0062 int rds_tcp_laddr_check(struct net *net, const struct in6_addr *addr,
0063             __u32 scope_id);
0064 /* tcp_connect.c */
0065 int rds_tcp_conn_path_connect(struct rds_conn_path *cp);
0066 void rds_tcp_conn_path_shutdown(struct rds_conn_path *conn);
0067 void rds_tcp_state_change(struct sock *sk);
0068
0069 /* tcp_listen.c */
0070 struct socket *rds_tcp_listen_init(struct net *net, bool isv6);
0071 void rds_tcp_listen_stop(struct socket *sock, struct work_struct *acceptor);
0072 void rds_tcp_listen_data_ready(struct sock *sk);
0073 int rds_tcp_accept_one(struct socket *sock);
0074 void rds_tcp_keepalive(struct socket *sock);
0075 void *rds_tcp_listen_sock_def_readable(struct net *net);
0076
0077 /* tcp_recv.c */
0078 int rds_tcp_recv_init(void);
0079 void rds_tcp_recv_exit(void);
0080 void rds_tcp_data_ready(struct sock *sk);
0081 int rds_tcp_recv_path(struct rds_conn_path *cp);
0082 void rds_tcp_inc_free(struct rds_incoming *inc);
0083 int rds_tcp_inc_copy_to_user(struct rds_incoming *inc, struct iov_iter *to);
0084
0085 /* tcp_send.c */
0086 void rds_tcp_xmit_path_prepare(struct rds_conn_path *cp);
0087 void rds_tcp_xmit_path_complete(struct rds_conn_path *cp);
0088 int rds_tcp_xmit(struct rds_connection *conn, struct rds_message *rm,
0089          unsigned int hdr_off, unsigned int sg, unsigned int off);
0090 void rds_tcp_write_space(struct sock *sk);
0091
0092 /* tcp_stats.c */
0093 DECLARE_PER_CPU(struct rds_tcp_statistics, rds_tcp_stats);
0094 #define rds_tcp_stats_inc(member) rds_stats_inc_which(rds_tcp_stats, member)
0095 unsigned int rds_tcp_stats_info_copy(struct rds_info_iterator *iter,
0096                      unsigned int avail);
0097
0098 #endif