26 	struct rxrpc_connection *conn =  in rxrpc_connection_timer()  local
29 	rxrpc_queue_conn(conn);  in rxrpc_connection_timer()
37 	struct rxrpc_connection *conn;  in rxrpc_alloc_connection()  local
41 	conn = kzalloc(sizeof(struct rxrpc_connection), gfp);  in rxrpc_alloc_connection()
42 	if (conn) {  in rxrpc_alloc_connection()
43 		INIT_LIST_HEAD(&conn->cache_link);  in rxrpc_alloc_connection()
44 		spin_lock_init(&conn->channel_lock);  in rxrpc_alloc_connection()
45 		INIT_LIST_HEAD(&conn->waiting_calls);  in rxrpc_alloc_connection()
46 		timer_setup(&conn->timer, &rxrpc_connection_timer, 0);  in rxrpc_alloc_connection()
47 		INIT_WORK(&conn->processor, &rxrpc_process_connection);  in rxrpc_alloc_connection()
48 		INIT_LIST_HEAD(&conn->proc_link);  in rxrpc_alloc_connection()
49 		INIT_LIST_HEAD(&conn->link);  in rxrpc_alloc_connection()
50 		skb_queue_head_init(&conn->rx_queue);  in rxrpc_alloc_connection()
51 		conn->security = &rxrpc_no_security;  in rxrpc_alloc_connection()
52 		spin_lock_init(&conn->state_lock);  in rxrpc_alloc_connection()
53 		conn->debug_id = atomic_inc_return(&rxrpc_debug_id);  in rxrpc_alloc_connection()
54 		conn->size_align = 4;  in rxrpc_alloc_connection()
55 		conn->idle_timestamp = jiffies;  in rxrpc_alloc_connection()
58 	_leave(" = %p{%d}", conn, conn ? conn->debug_id : 0);  in rxrpc_alloc_connection()
59 	return conn;  in rxrpc_alloc_connection()
77 	struct rxrpc_connection *conn;  in rxrpc_find_connection_rcu()  local
109 		conn = rxrpc_find_service_conn_rcu(peer, skb);  in rxrpc_find_connection_rcu()
110 		if (!conn || atomic_read(&conn->usage) == 0)  in rxrpc_find_connection_rcu()
112 		_leave(" = %p", conn);  in rxrpc_find_connection_rcu()
113 		return conn;  in rxrpc_find_connection_rcu()
118 		conn = idr_find(&rxrpc_client_conn_ids,  in rxrpc_find_connection_rcu()
120 		if (!conn || atomic_read(&conn->usage) == 0) {  in rxrpc_find_connection_rcu()
125 		if (conn->proto.epoch != k.epoch ||  in rxrpc_find_connection_rcu()
126 		    conn->params.local != local)  in rxrpc_find_connection_rcu()
129 		peer = conn->params.peer;  in rxrpc_find_connection_rcu()
152 		_leave(" = %p", conn);  in rxrpc_find_connection_rcu()
153 		return conn;  in rxrpc_find_connection_rcu()
166 void __rxrpc_disconnect_call(struct rxrpc_connection *conn,  in __rxrpc_disconnect_call()  argument
170 		&conn->channels[call->cid & RXRPC_CHANNELMASK];  in __rxrpc_disconnect_call()
172 	_enter("%d,%x", conn->debug_id, call->cid);  in __rxrpc_disconnect_call()
211 	struct rxrpc_connection *conn = call->conn;  in rxrpc_disconnect_call()  local
215 	spin_lock_bh(&conn->params.peer->lock);  in rxrpc_disconnect_call()
217 	spin_unlock_bh(&conn->params.peer->lock);  in rxrpc_disconnect_call()
222 	spin_lock(&conn->channel_lock);  in rxrpc_disconnect_call()
223 	__rxrpc_disconnect_call(conn, call);  in rxrpc_disconnect_call()
224 	spin_unlock(&conn->channel_lock);  in rxrpc_disconnect_call()
226 	call->conn = NULL;  in rxrpc_disconnect_call()
227 	conn->idle_timestamp = jiffies;  in rxrpc_disconnect_call()
228 	rxrpc_put_connection(conn);  in rxrpc_disconnect_call()
234 void rxrpc_kill_connection(struct rxrpc_connection *conn)  in rxrpc_kill_connection()  argument
236 	struct rxrpc_net *rxnet = conn->params.local->rxnet;  in rxrpc_kill_connection()
238 	ASSERT(!rcu_access_pointer(conn->channels[0].call) &&  in rxrpc_kill_connection()
239 	       !rcu_access_pointer(conn->channels[1].call) &&  in rxrpc_kill_connection()
240 	       !rcu_access_pointer(conn->channels[2].call) &&  in rxrpc_kill_connection()
241 	       !rcu_access_pointer(conn->channels[3].call));  in rxrpc_kill_connection()
242 	ASSERT(list_empty(&conn->cache_link));  in rxrpc_kill_connection()
245 	list_del_init(&conn->proc_link);  in rxrpc_kill_connection()
252 	rxrpc_purge_queue(&conn->rx_queue);  in rxrpc_kill_connection()
258 	call_rcu(&conn->rcu, rxrpc_destroy_connection);  in rxrpc_kill_connection()
265 bool rxrpc_queue_conn(struct rxrpc_connection *conn)  in rxrpc_queue_conn()  argument
268 	int n = atomic_fetch_add_unless(&conn->usage, 1, 0);  in rxrpc_queue_conn()
271 	if (rxrpc_queue_work(&conn->processor))  in rxrpc_queue_conn()
272 		trace_rxrpc_conn(conn->debug_id, rxrpc_conn_queued, n + 1, here);  in rxrpc_queue_conn()
274 		rxrpc_put_connection(conn);  in rxrpc_queue_conn()
281 void rxrpc_see_connection(struct rxrpc_connection *conn)  in rxrpc_see_connection()  argument
284 	if (conn) {  in rxrpc_see_connection()
285 		int n = atomic_read(&conn->usage);  in rxrpc_see_connection()
287 		trace_rxrpc_conn(conn->debug_id, rxrpc_conn_seen, n, here);  in rxrpc_see_connection()
294 void rxrpc_get_connection(struct rxrpc_connection *conn)  in rxrpc_get_connection()  argument
297 	int n = atomic_inc_return(&conn->usage);  in rxrpc_get_connection()
299 	trace_rxrpc_conn(conn->debug_id, rxrpc_conn_got, n, here);  in rxrpc_get_connection()
306 rxrpc_get_connection_maybe(struct rxrpc_connection *conn)  in rxrpc_get_connection_maybe()  argument
310 	if (conn) {  in rxrpc_get_connection_maybe()
311 		int n = atomic_fetch_add_unless(&conn->usage, 1, 0);  in rxrpc_get_connection_maybe()
313 			trace_rxrpc_conn(conn->debug_id, rxrpc_conn_got, n + 1, here);  in rxrpc_get_connection_maybe()
315 			conn = NULL;  in rxrpc_get_connection_maybe()
317 	return conn;  in rxrpc_get_connection_maybe()
333 void rxrpc_put_service_conn(struct rxrpc_connection *conn)  in rxrpc_put_service_conn()  argument
336 	unsigned int debug_id = conn->debug_id;  in rxrpc_put_service_conn()
339 	n = atomic_dec_return(&conn->usage);  in rxrpc_put_service_conn()
343 		rxrpc_set_service_reap_timer(conn->params.local->rxnet,  in rxrpc_put_service_conn()
352 	struct rxrpc_connection *conn =  in rxrpc_destroy_connection()  local
355 	_enter("{%d,u=%d}", conn->debug_id, atomic_read(&conn->usage));  in rxrpc_destroy_connection()
357 	ASSERTCMP(atomic_read(&conn->usage), ==, 0);  in rxrpc_destroy_connection()
359 	_net("DESTROY CONN %d", conn->debug_id);  in rxrpc_destroy_connection()
361 	del_timer_sync(&conn->timer);  in rxrpc_destroy_connection()
362 	rxrpc_purge_queue(&conn->rx_queue);  in rxrpc_destroy_connection()
364 	conn->security->clear(conn);  in rxrpc_destroy_connection()
365 	key_put(conn->params.key);  in rxrpc_destroy_connection()
366 	key_put(conn->server_key);  in rxrpc_destroy_connection()
367 	rxrpc_put_peer(conn->params.peer);  in rxrpc_destroy_connection()
369 	if (atomic_dec_and_test(&conn->params.local->rxnet->nr_conns))  in rxrpc_destroy_connection()
370 		wake_up_var(&conn->params.local->rxnet->nr_conns);  in rxrpc_destroy_connection()
371 	rxrpc_put_local(conn->params.local);  in rxrpc_destroy_connection()
373 	kfree(conn);  in rxrpc_destroy_connection()
382 	struct rxrpc_connection *conn, *_p;  in rxrpc_service_connection_reaper()  local
395 	list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) {  in rxrpc_service_connection_reaper()
396 		ASSERTCMP(atomic_read(&conn->usage), >, 0);  in rxrpc_service_connection_reaper()
397 		if (likely(atomic_read(&conn->usage) > 1))  in rxrpc_service_connection_reaper()
399 		if (conn->state == RXRPC_CONN_SERVICE_PREALLOC)  in rxrpc_service_connection_reaper()
402 		if (rxnet->live && !conn->params.local->dead) {  in rxrpc_service_connection_reaper()
403 			idle_timestamp = READ_ONCE(conn->idle_timestamp);  in rxrpc_service_connection_reaper()
405 			if (conn->params.local->service_closed)  in rxrpc_service_connection_reaper()
409 			       conn->debug_id, atomic_read(&conn->usage),  in rxrpc_service_connection_reaper()
422 		if (atomic_cmpxchg(&conn->usage, 1, 0) != 1)  in rxrpc_service_connection_reaper()
424 		trace_rxrpc_conn(conn->debug_id, rxrpc_conn_reap_service, 0, NULL);  in rxrpc_service_connection_reaper()
426 		if (rxrpc_conn_is_client(conn))  in rxrpc_service_connection_reaper()
429 			rxrpc_unpublish_service_conn(conn);  in rxrpc_service_connection_reaper()
431 		list_move_tail(&conn->link, &graveyard);  in rxrpc_service_connection_reaper()
442 		conn = list_entry(graveyard.next, struct rxrpc_connection,  in rxrpc_service_connection_reaper()
444 		list_del_init(&conn->link);  in rxrpc_service_connection_reaper()
446 		ASSERTCMP(atomic_read(&conn->usage), ==, 0);  in rxrpc_service_connection_reaper()
447 		rxrpc_kill_connection(conn);  in rxrpc_service_connection_reaper()
459 	struct rxrpc_connection *conn, *_p;  in rxrpc_destroy_all_connections()  local
472 	list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) {  in rxrpc_destroy_all_connections()
474 		       conn, atomic_read(&conn->usage));  in rxrpc_destroy_all_connections()