79 u32 rds_tcp_snd_nxt(struct rds_tcp_connection *tc)  in rds_tcp_snd_nxt()  argument
81 	return tcp_sk(tc->t_sock->sk)->snd_nxt;  in rds_tcp_snd_nxt()
84 u32 rds_tcp_snd_una(struct rds_tcp_connection *tc)  in rds_tcp_snd_una()  argument
86 	return tcp_sk(tc->t_sock->sk)->snd_una;  in rds_tcp_snd_una()
90 			       struct rds_tcp_connection *tc)  in rds_tcp_restore_callbacks()  argument
92 	rdsdebug("restoring sock %p callbacks from tc %p\n", sock, tc);  in rds_tcp_restore_callbacks()
97 	list_del_init(&tc->t_list_item);  in rds_tcp_restore_callbacks()
101 	tc->t_sock = NULL;  in rds_tcp_restore_callbacks()
103 	sock->sk->sk_write_space = tc->t_orig_write_space;  in rds_tcp_restore_callbacks()
104 	sock->sk->sk_data_ready = tc->t_orig_data_ready;  in rds_tcp_restore_callbacks()
105 	sock->sk->sk_state_change = tc->t_orig_state_change;  in rds_tcp_restore_callbacks()
118 	struct rds_tcp_connection *tc = conn->c_transport_data;  in rds_tcp_set_callbacks()  local
120 	rdsdebug("setting sock %p callbacks to tc %p\n", sock, tc);  in rds_tcp_set_callbacks()
125 	list_add_tail(&tc->t_list_item, &rds_tcp_tc_list);  in rds_tcp_set_callbacks()
133 	tc->t_sock = sock;  in rds_tcp_set_callbacks()
134 	tc->conn = conn;  in rds_tcp_set_callbacks()
135 	tc->t_orig_data_ready = sock->sk->sk_data_ready;  in rds_tcp_set_callbacks()
136 	tc->t_orig_write_space = sock->sk->sk_write_space;  in rds_tcp_set_callbacks()
137 	tc->t_orig_state_change = sock->sk->sk_state_change;  in rds_tcp_set_callbacks()
152 	struct rds_tcp_connection *tc;  in rds_tcp_tc_info()  local
162 	list_for_each_entry(tc, &rds_tcp_tc_list, t_list_item) {  in rds_tcp_tc_info()
171 		tsinfo.hdr_rem = tc->t_tinc_hdr_rem;  in rds_tcp_tc_info()
172 		tsinfo.data_rem = tc->t_tinc_data_rem;  in rds_tcp_tc_info()
173 		tsinfo.last_sent_nxt = tc->t_last_sent_nxt;  in rds_tcp_tc_info()
174 		tsinfo.last_expected_una = tc->t_last_expected_una;  in rds_tcp_tc_info()
175 		tsinfo.last_seen_una = tc->t_last_seen_una;  in rds_tcp_tc_info()
196 	struct rds_tcp_connection *tc;  in rds_tcp_conn_alloc()  local
198 	tc = kmem_cache_alloc(rds_tcp_conn_slab, gfp);  in rds_tcp_conn_alloc()
199 	if (!tc)  in rds_tcp_conn_alloc()
202 	tc->t_sock = NULL;  in rds_tcp_conn_alloc()
203 	tc->t_tinc = NULL;  in rds_tcp_conn_alloc()
204 	tc->t_tinc_hdr_rem = sizeof(struct rds_header);  in rds_tcp_conn_alloc()
205 	tc->t_tinc_data_rem = 0;  in rds_tcp_conn_alloc()
207 	conn->c_transport_data = tc;  in rds_tcp_conn_alloc()
210 	list_add_tail(&tc->t_tcp_node, &rds_tcp_conn_list);  in rds_tcp_conn_alloc()
219 	struct rds_tcp_connection *tc = arg;  in rds_tcp_conn_free()  local
221 	rdsdebug("freeing tc %p\n", tc);  in rds_tcp_conn_free()
224 	list_del(&tc->t_tcp_node);  in rds_tcp_conn_free()
227 	kmem_cache_free(rds_tcp_conn_slab, tc);  in rds_tcp_conn_free()
232 	struct rds_tcp_connection *tc, *_tc;  in rds_tcp_destroy_conns()  local
241 	list_for_each_entry_safe(tc, _tc, &tmp_list, t_tcp_node) {  in rds_tcp_destroy_conns()
242 		if (tc->conn->c_passive)  in rds_tcp_destroy_conns()
243 			rds_conn_destroy(tc->conn->c_passive);  in rds_tcp_destroy_conns()
244 		rds_conn_destroy(tc->conn);  in rds_tcp_destroy_conns()
337 	struct rds_tcp_connection *tc, *_tc;  in rds_tcp_kill_sock()  local
346 	list_for_each_entry_safe(tc, _tc, &rds_tcp_conn_list, t_tcp_node) {  in rds_tcp_kill_sock()
347 		struct net *c_net = read_pnet(&tc->conn->c_net);  in rds_tcp_kill_sock()
349 		if (net != c_net || !tc->t_sock)  in rds_tcp_kill_sock()
351 		list_move_tail(&tc->t_tcp_node, &tmp_list);  in rds_tcp_kill_sock()
354 	list_for_each_entry_safe(tc, _tc, &tmp_list, t_tcp_node) {  in rds_tcp_kill_sock()
355 		sk = tc->t_sock->sk;  in rds_tcp_kill_sock()
358 		if (tc->conn->c_passive)  in rds_tcp_kill_sock()
359 			rds_conn_destroy(tc->conn->c_passive);  in rds_tcp_kill_sock()
360 		rds_conn_destroy(tc->conn);  in rds_tcp_kill_sock()