Lines Matching refs:conn
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->idle_timestamp = jiffies; in rxrpc_alloc_connection()
55 _leave(" = %p{%d}", conn, conn ? conn->debug_id : 0); in rxrpc_alloc_connection()
56 return conn; in rxrpc_alloc_connection()
74 struct rxrpc_connection *conn; in rxrpc_find_connection_rcu() local
106 conn = rxrpc_find_service_conn_rcu(peer, skb); in rxrpc_find_connection_rcu()
107 if (!conn || atomic_read(&conn->usage) == 0) in rxrpc_find_connection_rcu()
109 _leave(" = %p", conn); in rxrpc_find_connection_rcu()
110 return conn; in rxrpc_find_connection_rcu()
115 conn = idr_find(&rxrpc_client_conn_ids, in rxrpc_find_connection_rcu()
117 if (!conn || atomic_read(&conn->usage) == 0) { in rxrpc_find_connection_rcu()
122 if (conn->proto.epoch != k.epoch || in rxrpc_find_connection_rcu()
123 conn->params.local != local) in rxrpc_find_connection_rcu()
126 peer = conn->params.peer; in rxrpc_find_connection_rcu()
149 _leave(" = %p", conn); in rxrpc_find_connection_rcu()
150 return conn; in rxrpc_find_connection_rcu()
163 void __rxrpc_disconnect_call(struct rxrpc_connection *conn, in __rxrpc_disconnect_call() argument
167 &conn->channels[call->cid & RXRPC_CHANNELMASK]; in __rxrpc_disconnect_call()
169 _enter("%d,%x", conn->debug_id, call->cid); in __rxrpc_disconnect_call()
208 struct rxrpc_connection *conn = call->conn; in rxrpc_disconnect_call() local
219 return rxrpc_disconnect_client_call(conn->bundle, call); in rxrpc_disconnect_call()
221 spin_lock(&conn->bundle->channel_lock); in rxrpc_disconnect_call()
222 __rxrpc_disconnect_call(conn, call); in rxrpc_disconnect_call()
223 spin_unlock(&conn->bundle->channel_lock); in rxrpc_disconnect_call()
226 conn->idle_timestamp = jiffies; in rxrpc_disconnect_call()
232 void rxrpc_kill_connection(struct rxrpc_connection *conn) in rxrpc_kill_connection() argument
234 struct rxrpc_net *rxnet = conn->params.local->rxnet; in rxrpc_kill_connection()
236 ASSERT(!rcu_access_pointer(conn->channels[0].call) && in rxrpc_kill_connection()
237 !rcu_access_pointer(conn->channels[1].call) && in rxrpc_kill_connection()
238 !rcu_access_pointer(conn->channels[2].call) && in rxrpc_kill_connection()
239 !rcu_access_pointer(conn->channels[3].call)); in rxrpc_kill_connection()
240 ASSERT(list_empty(&conn->cache_link)); in rxrpc_kill_connection()
243 list_del_init(&conn->proc_link); in rxrpc_kill_connection()
250 rxrpc_purge_queue(&conn->rx_queue); in rxrpc_kill_connection()
256 call_rcu(&conn->rcu, rxrpc_destroy_connection); in rxrpc_kill_connection()
263 bool rxrpc_queue_conn(struct rxrpc_connection *conn) in rxrpc_queue_conn() argument
266 int n = atomic_fetch_add_unless(&conn->usage, 1, 0); in rxrpc_queue_conn()
269 if (rxrpc_queue_work(&conn->processor)) in rxrpc_queue_conn()
270 trace_rxrpc_conn(conn->debug_id, rxrpc_conn_queued, n + 1, here); in rxrpc_queue_conn()
272 rxrpc_put_connection(conn); in rxrpc_queue_conn()
279 void rxrpc_see_connection(struct rxrpc_connection *conn) in rxrpc_see_connection() argument
282 if (conn) { in rxrpc_see_connection()
283 int n = atomic_read(&conn->usage); in rxrpc_see_connection()
285 trace_rxrpc_conn(conn->debug_id, rxrpc_conn_seen, n, here); in rxrpc_see_connection()
292 struct rxrpc_connection *rxrpc_get_connection(struct rxrpc_connection *conn) in rxrpc_get_connection() argument
295 int n = atomic_inc_return(&conn->usage); in rxrpc_get_connection()
297 trace_rxrpc_conn(conn->debug_id, rxrpc_conn_got, n, here); in rxrpc_get_connection()
298 return conn; in rxrpc_get_connection()
305 rxrpc_get_connection_maybe(struct rxrpc_connection *conn) in rxrpc_get_connection_maybe() argument
309 if (conn) { in rxrpc_get_connection_maybe()
310 int n = atomic_fetch_add_unless(&conn->usage, 1, 0); in rxrpc_get_connection_maybe()
312 trace_rxrpc_conn(conn->debug_id, rxrpc_conn_got, n + 1, here); in rxrpc_get_connection_maybe()
314 conn = NULL; in rxrpc_get_connection_maybe()
316 return conn; in rxrpc_get_connection_maybe()
332 void rxrpc_put_service_conn(struct rxrpc_connection *conn) in rxrpc_put_service_conn() argument
335 unsigned int debug_id = conn->debug_id; in rxrpc_put_service_conn()
338 n = atomic_dec_return(&conn->usage); in rxrpc_put_service_conn()
342 rxrpc_set_service_reap_timer(conn->params.local->rxnet, in rxrpc_put_service_conn()
351 struct rxrpc_connection *conn = in rxrpc_destroy_connection() local
354 _enter("{%d,u=%d}", conn->debug_id, atomic_read(&conn->usage)); in rxrpc_destroy_connection()
356 ASSERTCMP(atomic_read(&conn->usage), ==, 0); in rxrpc_destroy_connection()
358 _net("DESTROY CONN %d", conn->debug_id); in rxrpc_destroy_connection()
360 del_timer_sync(&conn->timer); in rxrpc_destroy_connection()
361 rxrpc_purge_queue(&conn->rx_queue); in rxrpc_destroy_connection()
363 conn->security->clear(conn); in rxrpc_destroy_connection()
364 key_put(conn->params.key); in rxrpc_destroy_connection()
365 rxrpc_put_bundle(conn->bundle); in rxrpc_destroy_connection()
366 rxrpc_put_peer(conn->params.peer); in rxrpc_destroy_connection()
368 if (atomic_dec_and_test(&conn->params.local->rxnet->nr_conns)) in rxrpc_destroy_connection()
369 wake_up_var(&conn->params.local->rxnet->nr_conns); in rxrpc_destroy_connection()
370 rxrpc_put_local(conn->params.local); in rxrpc_destroy_connection()
372 kfree(conn); in rxrpc_destroy_connection()
381 struct rxrpc_connection *conn, *_p; in rxrpc_service_connection_reaper() local
394 list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) { in rxrpc_service_connection_reaper()
395 ASSERTCMP(atomic_read(&conn->usage), >, 0); in rxrpc_service_connection_reaper()
396 if (likely(atomic_read(&conn->usage) > 1)) in rxrpc_service_connection_reaper()
398 if (conn->state == RXRPC_CONN_SERVICE_PREALLOC) in rxrpc_service_connection_reaper()
401 if (rxnet->live && !conn->params.local->dead) { in rxrpc_service_connection_reaper()
402 idle_timestamp = READ_ONCE(conn->idle_timestamp); in rxrpc_service_connection_reaper()
404 if (conn->params.local->service_closed) in rxrpc_service_connection_reaper()
408 conn->debug_id, atomic_read(&conn->usage), in rxrpc_service_connection_reaper()
421 if (atomic_cmpxchg(&conn->usage, 1, 0) != 1) in rxrpc_service_connection_reaper()
423 trace_rxrpc_conn(conn->debug_id, rxrpc_conn_reap_service, 0, NULL); in rxrpc_service_connection_reaper()
425 if (rxrpc_conn_is_client(conn)) in rxrpc_service_connection_reaper()
428 rxrpc_unpublish_service_conn(conn); in rxrpc_service_connection_reaper()
430 list_move_tail(&conn->link, &graveyard); in rxrpc_service_connection_reaper()
441 conn = list_entry(graveyard.next, struct rxrpc_connection, in rxrpc_service_connection_reaper()
443 list_del_init(&conn->link); in rxrpc_service_connection_reaper()
445 ASSERTCMP(atomic_read(&conn->usage), ==, 0); in rxrpc_service_connection_reaper()
446 rxrpc_kill_connection(conn); in rxrpc_service_connection_reaper()
458 struct rxrpc_connection *conn, *_p; in rxrpc_destroy_all_connections() local
471 list_for_each_entry_safe(conn, _p, &rxnet->service_conns, link) { in rxrpc_destroy_all_connections()
473 conn, atomic_read(&conn->usage)); in rxrpc_destroy_all_connections()