net/rxrpc/conn_object.c

26 void rxrpc_poke_conn(struct rxrpc_connection *conn, enum rxrpc_conn_trace why)
28 	struct rxrpc_local *local = conn->local;
35 	busy = !list_empty(&conn->attend_link);
37 		rxrpc_get_connection(conn, why);
38 		list_add_tail(&conn->attend_link, &local->conn_attend_q);
46 	struct rxrpc_connection *conn =
49 	rxrpc_poke_conn(conn, rxrpc_conn_get_poke_timer);
58 	struct rxrpc_connection *conn;
62 	conn = kzalloc(sizeof(struct rxrpc_connection), gfp);
63 	if (conn) {
64 		INIT_LIST_HEAD(&conn->cache_link);
65 		timer_setup(&conn->timer, &rxrpc_connection_timer, 0);
66 		INIT_WORK(&conn->processor, rxrpc_process_connection);
67 		INIT_WORK(&conn->destructor, rxrpc_clean_up_connection);
68 		INIT_LIST_HEAD(&conn->proc_link);
69 		INIT_LIST_HEAD(&conn->link);
70 		mutex_init(&conn->security_lock);
71 		mutex_init(&conn->tx_data_alloc_lock);
72 		skb_queue_head_init(&conn->rx_queue);
73 		conn->rxnet = rxnet;
74 		conn->security = &rxrpc_no_security;
75 		spin_lock_init(&conn->state_lock);
76 		conn->debug_id = atomic_inc_return(&rxrpc_debug_id);
77 		conn->idle_timestamp = jiffies;
80 	_leave(" = %p{%d}", conn, conn ? conn->debug_id : 0);
81 	return conn;
99 	struct rxrpc_connection *conn;
108 	conn = idr_find(&local->conn_ids, sp->hdr.cid >> RXRPC_CIDSHIFT);
109 	if (!conn || refcount_read(&conn->ref) == 0) {
110 		_debug("no conn");
114 	if (conn->proto.epoch != sp->hdr.epoch ||
115 	    conn->local != local)
118 	peer = conn->peer;
141 	_leave(" = %p", conn);
142 	return conn;
154 void __rxrpc_disconnect_call(struct rxrpc_connection *conn,
158 		&conn->channels[call->cid & RXRPC_CHANNELMASK];
160 	_enter("%d,%x", conn->debug_id, call->cid);
196 	struct rxrpc_connection *conn = call->conn;
212 		__rxrpc_disconnect_call(conn, call);
213 		conn->idle_timestamp = jiffies;
214 		if (atomic_dec_and_test(&conn->active))
215 			rxrpc_set_service_reap_timer(conn->rxnet,
226 void rxrpc_queue_conn(struct rxrpc_connection *conn, enum rxrpc_conn_trace why)
228 	if (atomic_read(&conn->active) >= 0 &&
229 	    rxrpc_queue_work(&conn->processor))
230 		rxrpc_see_connection(conn, why);
236 void rxrpc_see_connection(struct rxrpc_connection *conn,
239 	if (conn) {
240 		int r = refcount_read(&conn->ref);
242 		trace_rxrpc_conn(conn->debug_id, r, why);
249 struct rxrpc_connection *rxrpc_get_connection(struct rxrpc_connection *conn,
254 	__refcount_inc(&conn->ref, &r);
255 	trace_rxrpc_conn(conn->debug_id, r + 1, why);
256 	return conn;
263 rxrpc_get_connection_maybe(struct rxrpc_connection *conn,
268 	if (conn) {
269 		if (__refcount_inc_not_zero(&conn->ref, &r))
270 			trace_rxrpc_conn(conn->debug_id, r + 1, why);
272 			conn = NULL;
274 	return conn;
292 	struct rxrpc_connection *conn =
294 	struct rxrpc_net *rxnet = conn->rxnet;
296 	_enter("{%d,u=%d}", conn->debug_id, refcount_read(&conn->ref));
298 	trace_rxrpc_conn(conn->debug_id, refcount_read(&conn->ref),
300 	kfree(conn);
311 	struct rxrpc_connection *conn =
313 	struct rxrpc_net *rxnet = conn->rxnet;
315 	ASSERT(!conn->channels[0].call &&
316 	       !conn->channels[1].call &&
317 	       !conn->channels[2].call &&
318 	       !conn->channels[3].call);
319 	ASSERT(list_empty(&conn->cache_link));
321 	del_timer_sync(&conn->timer);
322 	cancel_work_sync(&conn->processor); /* Processing may restart the timer */
323 	del_timer_sync(&conn->timer);
326 	list_del_init(&conn->proc_link);
329 	rxrpc_purge_queue(&conn->rx_queue);
331 	rxrpc_kill_client_conn(conn);
333 	conn->security->clear(conn);
334 	key_put(conn->key);
335 	rxrpc_put_bundle(conn->bundle, rxrpc_bundle_put_conn);
336 	rxrpc_put_peer(conn->peer, rxrpc_peer_put_conn);
337 	rxrpc_put_local(conn->local, rxrpc_local_put_kill_conn);
343 	rxrpc_purge_queue(&conn->rx_queue);
345 	if (conn->tx_data_alloc.va)
346 		__page_frag_cache_drain(virt_to_page(conn->tx_data_alloc.va),
347 					conn->tx_data_alloc.pagecnt_bias);
348 	call_rcu(&conn->rcu, rxrpc_rcu_free_connection);
354 void rxrpc_put_connection(struct rxrpc_connection *conn,
361 	if (!conn)
364 	debug_id = conn->debug_id;
365 	dead = __refcount_dec_and_test(&conn->ref, &r);
368 		del_timer(&conn->timer);
369 		cancel_work(&conn->processor);
371 		if (in_softirq() || work_busy(&conn->processor) ||
372 		    timer_pending(&conn->timer))
376 			schedule_work(&conn->destructor);
378 			rxrpc_clean_up_connection(&conn->destructor);
387 	struct rxrpc_connection *conn, *_p;
401 	list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) {
402 		ASSERTCMP(atomic_read(&conn->active), >=, 0);
403 		if (likely(atomic_read(&conn->active) > 0))
405 		if (conn->state == RXRPC_CONN_SERVICE_PREALLOC)
408 		if (rxnet->live && !conn->local->dead) {
409 			idle_timestamp = READ_ONCE(conn->idle_timestamp);
411 			if (conn->local->service_closed)
415 			       conn->debug_id, atomic_read(&conn->active),
425 		/* The activity count sits at 0 whilst the conn is unused on
426 		 * the list; we reduce that to -1 to make the conn unavailable.
429 		if (!atomic_try_cmpxchg(&conn->active, &active, -1))
431 		rxrpc_see_connection(conn, rxrpc_conn_see_reap_service);
433 		if (rxrpc_conn_is_client(conn))
436 			rxrpc_unpublish_service_conn(conn);
438 		list_move_tail(&conn->link, &graveyard);
449 		conn = list_entry(graveyard.next, struct rxrpc_connection,
451 		list_del_init(&conn->link);
453 		ASSERTCMP(atomic_read(&conn->active), ==, -1);
454 		rxrpc_put_connection(conn, rxrpc_conn_put_service_reaped);
466 	struct rxrpc_connection *conn, *_p;
478 	list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) {
479 		pr_err("AF_RXRPC: Leaked conn %p {%d}\n",
480 		       conn, refcount_read(&conn->ref));