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 		timer_setup(&conn->timer, &rxrpc_connection_timer, 0);  in rxrpc_alloc_connection()
45 		INIT_WORK(&conn->processor, &rxrpc_process_connection);  in rxrpc_alloc_connection()
46 		INIT_LIST_HEAD(&conn->proc_link);  in rxrpc_alloc_connection()
47 		INIT_LIST_HEAD(&conn->link);  in rxrpc_alloc_connection()
48 		skb_queue_head_init(&conn->rx_queue);  in rxrpc_alloc_connection()
49 		conn->security = &rxrpc_no_security;  in rxrpc_alloc_connection()
50 		spin_lock_init(&conn->state_lock);  in rxrpc_alloc_connection()
51 		conn->debug_id = atomic_inc_return(&rxrpc_debug_id);  in rxrpc_alloc_connection()
52 		conn->size_align = 4;  in rxrpc_alloc_connection()
53 		conn->idle_timestamp = jiffies;  in rxrpc_alloc_connection()
56 	_leave(" = %p{%d}", conn, conn ? conn->debug_id : 0);  in rxrpc_alloc_connection()
57 	return conn;  in rxrpc_alloc_connection()
75 	struct rxrpc_connection *conn;  in rxrpc_find_connection_rcu()  local
107 		conn = rxrpc_find_service_conn_rcu(peer, skb);  in rxrpc_find_connection_rcu()
108 		if (!conn || atomic_read(&conn->usage) == 0)  in rxrpc_find_connection_rcu()
110 		_leave(" = %p", conn);  in rxrpc_find_connection_rcu()
111 		return conn;  in rxrpc_find_connection_rcu()
116 		conn = idr_find(&rxrpc_client_conn_ids,  in rxrpc_find_connection_rcu()
118 		if (!conn || atomic_read(&conn->usage) == 0) {  in rxrpc_find_connection_rcu()
123 		if (conn->proto.epoch != k.epoch ||  in rxrpc_find_connection_rcu()
124 		    conn->params.local != local)  in rxrpc_find_connection_rcu()
127 		peer = conn->params.peer;  in rxrpc_find_connection_rcu()
150 		_leave(" = %p", conn);  in rxrpc_find_connection_rcu()
151 		return conn;  in rxrpc_find_connection_rcu()
164 void __rxrpc_disconnect_call(struct rxrpc_connection *conn,  in __rxrpc_disconnect_call()  argument
168 		&conn->channels[call->cid & RXRPC_CHANNELMASK];  in __rxrpc_disconnect_call()
170 	_enter("%d,%x", conn->debug_id, call->cid);  in __rxrpc_disconnect_call()
209 	struct rxrpc_connection *conn = call->conn;  in rxrpc_disconnect_call()  local
220 		return rxrpc_disconnect_client_call(conn->bundle, call);  in rxrpc_disconnect_call()
222 	spin_lock(&conn->bundle->channel_lock);  in rxrpc_disconnect_call()
223 	__rxrpc_disconnect_call(conn, call);  in rxrpc_disconnect_call()
224 	spin_unlock(&conn->bundle->channel_lock);  in rxrpc_disconnect_call()
227 	conn->idle_timestamp = jiffies;  in rxrpc_disconnect_call()
233 void rxrpc_kill_connection(struct rxrpc_connection *conn)  in rxrpc_kill_connection()  argument
235 	struct rxrpc_net *rxnet = conn->params.local->rxnet;  in rxrpc_kill_connection()
237 	ASSERT(!rcu_access_pointer(conn->channels[0].call) &&  in rxrpc_kill_connection()
238 	       !rcu_access_pointer(conn->channels[1].call) &&  in rxrpc_kill_connection()
239 	       !rcu_access_pointer(conn->channels[2].call) &&  in rxrpc_kill_connection()
240 	       !rcu_access_pointer(conn->channels[3].call));  in rxrpc_kill_connection()
241 	ASSERT(list_empty(&conn->cache_link));  in rxrpc_kill_connection()
244 	list_del_init(&conn->proc_link);  in rxrpc_kill_connection()
251 	rxrpc_purge_queue(&conn->rx_queue);  in rxrpc_kill_connection()
257 	call_rcu(&conn->rcu, rxrpc_destroy_connection);  in rxrpc_kill_connection()
264 bool rxrpc_queue_conn(struct rxrpc_connection *conn)  in rxrpc_queue_conn()  argument
267 	int n = atomic_fetch_add_unless(&conn->usage, 1, 0);  in rxrpc_queue_conn()
270 	if (rxrpc_queue_work(&conn->processor))  in rxrpc_queue_conn()
271 		trace_rxrpc_conn(conn->debug_id, rxrpc_conn_queued, n + 1, here);  in rxrpc_queue_conn()
273 		rxrpc_put_connection(conn);  in rxrpc_queue_conn()
280 void rxrpc_see_connection(struct rxrpc_connection *conn)  in rxrpc_see_connection()  argument
283 	if (conn) {  in rxrpc_see_connection()
284 		int n = atomic_read(&conn->usage);  in rxrpc_see_connection()
286 		trace_rxrpc_conn(conn->debug_id, rxrpc_conn_seen, n, here);  in rxrpc_see_connection()
293 struct rxrpc_connection *rxrpc_get_connection(struct rxrpc_connection *conn)  in rxrpc_get_connection()  argument
296 	int n = atomic_inc_return(&conn->usage);  in rxrpc_get_connection()
298 	trace_rxrpc_conn(conn->debug_id, rxrpc_conn_got, n, here);  in rxrpc_get_connection()
299 	return conn;  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_bundle(conn->bundle);  in rxrpc_destroy_connection()
368 	rxrpc_put_peer(conn->params.peer);  in rxrpc_destroy_connection()
370 	if (atomic_dec_and_test(&conn->params.local->rxnet->nr_conns))  in rxrpc_destroy_connection()
371 		wake_up_var(&conn->params.local->rxnet->nr_conns);  in rxrpc_destroy_connection()
372 	rxrpc_put_local(conn->params.local);  in rxrpc_destroy_connection()
374 	kfree(conn);  in rxrpc_destroy_connection()
383 	struct rxrpc_connection *conn, *_p;  in rxrpc_service_connection_reaper()  local
396 	list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) {  in rxrpc_service_connection_reaper()
397 		ASSERTCMP(atomic_read(&conn->usage), >, 0);  in rxrpc_service_connection_reaper()
398 		if (likely(atomic_read(&conn->usage) > 1))  in rxrpc_service_connection_reaper()
400 		if (conn->state == RXRPC_CONN_SERVICE_PREALLOC)  in rxrpc_service_connection_reaper()
403 		if (rxnet->live && !conn->params.local->dead) {  in rxrpc_service_connection_reaper()
404 			idle_timestamp = READ_ONCE(conn->idle_timestamp);  in rxrpc_service_connection_reaper()
406 			if (conn->params.local->service_closed)  in rxrpc_service_connection_reaper()
410 			       conn->debug_id, atomic_read(&conn->usage),  in rxrpc_service_connection_reaper()
423 		if (atomic_cmpxchg(&conn->usage, 1, 0) != 1)  in rxrpc_service_connection_reaper()
425 		trace_rxrpc_conn(conn->debug_id, rxrpc_conn_reap_service, 0, NULL);  in rxrpc_service_connection_reaper()
427 		if (rxrpc_conn_is_client(conn))  in rxrpc_service_connection_reaper()
430 			rxrpc_unpublish_service_conn(conn);  in rxrpc_service_connection_reaper()
432 		list_move_tail(&conn->link, &graveyard);  in rxrpc_service_connection_reaper()
443 		conn = list_entry(graveyard.next, struct rxrpc_connection,  in rxrpc_service_connection_reaper()
445 		list_del_init(&conn->link);  in rxrpc_service_connection_reaper()
447 		ASSERTCMP(atomic_read(&conn->usage), ==, 0);  in rxrpc_service_connection_reaper()
448 		rxrpc_kill_connection(conn);  in rxrpc_service_connection_reaper()
460 	struct rxrpc_connection *conn, *_p;  in rxrpc_destroy_all_connections()  local
473 	list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) {  in rxrpc_destroy_all_connections()
475 		       conn, atomic_read(&conn->usage));  in rxrpc_destroy_all_connections()