4 #define RDS_TCP_PORT 16385
6 struct rds_tcp_incoming
{
7 struct rds_incoming ti_inc
;
8 struct sk_buff_head ti_skb_list
;
11 struct rds_tcp_connection
{
13 struct list_head t_tcp_node
;
14 struct rds_connection
*conn
;
15 /* t_conn_lock synchronizes the connection establishment between
16 * rds_tcp_accept_one and rds_tcp_conn_connect
18 struct mutex t_conn_lock
;
19 struct socket
*t_sock
;
20 void *t_orig_write_space
;
21 void *t_orig_data_ready
;
22 void *t_orig_state_change
;
24 struct rds_tcp_incoming
*t_tinc
;
25 size_t t_tinc_hdr_rem
;
26 size_t t_tinc_data_rem
;
28 /* XXX error report? */
29 struct work_struct t_conn_w
;
30 struct work_struct t_send_w
;
31 struct work_struct t_down_w
;
32 struct work_struct t_recv_w
;
34 /* for info exporting only */
35 struct list_head t_list_item
;
37 u32 t_last_expected_una
;
41 struct rds_tcp_statistics
{
42 uint64_t s_tcp_data_ready_calls
;
43 uint64_t s_tcp_write_space_calls
;
44 uint64_t s_tcp_sndbuf_full
;
45 uint64_t s_tcp_connect_raced
;
46 uint64_t s_tcp_listen_closed_stale
;
50 void rds_tcp_tune(struct socket
*sock
);
51 void rds_tcp_nonagle(struct socket
*sock
);
52 void rds_tcp_set_callbacks(struct socket
*sock
, struct rds_connection
*conn
);
53 void rds_tcp_restore_callbacks(struct socket
*sock
,
54 struct rds_tcp_connection
*tc
);
55 u32
rds_tcp_snd_nxt(struct rds_tcp_connection
*tc
);
56 u32
rds_tcp_snd_una(struct rds_tcp_connection
*tc
);
57 u64
rds_tcp_map_seq(struct rds_tcp_connection
*tc
, u32 seq
);
58 extern struct rds_transport rds_tcp_transport
;
59 void rds_tcp_accept_work(struct sock
*sk
);
62 int rds_tcp_conn_connect(struct rds_connection
*conn
);
63 void rds_tcp_conn_shutdown(struct rds_connection
*conn
);
64 void rds_tcp_state_change(struct sock
*sk
);
67 struct socket
*rds_tcp_listen_init(struct net
*);
68 void rds_tcp_listen_stop(struct socket
*);
69 void rds_tcp_listen_data_ready(struct sock
*sk
);
70 int rds_tcp_accept_one(struct socket
*sock
);
71 int rds_tcp_keepalive(struct socket
*sock
);
74 int rds_tcp_recv_init(void);
75 void rds_tcp_recv_exit(void);
76 void rds_tcp_data_ready(struct sock
*sk
);
77 int rds_tcp_recv(struct rds_connection
*conn
);
78 void rds_tcp_inc_free(struct rds_incoming
*inc
);
79 int rds_tcp_inc_copy_to_user(struct rds_incoming
*inc
, struct iov_iter
*to
);
82 void rds_tcp_xmit_prepare(struct rds_connection
*conn
);
83 void rds_tcp_xmit_complete(struct rds_connection
*conn
);
84 int rds_tcp_xmit(struct rds_connection
*conn
, struct rds_message
*rm
,
85 unsigned int hdr_off
, unsigned int sg
, unsigned int off
);
86 void rds_tcp_write_space(struct sock
*sk
);
89 DECLARE_PER_CPU(struct rds_tcp_statistics
, rds_tcp_stats
);
90 #define rds_tcp_stats_inc(member) rds_stats_inc_which(rds_tcp_stats, member)
91 unsigned int rds_tcp_stats_info_copy(struct rds_info_iterator
*iter
,