Lines Matching refs:conn
46 struct rxrpc_connection *conn) in rxrpc_put_client_connection_id() argument
48 idr_remove(&local->conn_ids, conn->proto.cid >> RXRPC_CIDSHIFT); in rxrpc_put_client_connection_id()
56 struct rxrpc_connection *conn; in rxrpc_destroy_client_conn_ids() local
60 idr_for_each_entry(&local->conn_ids, conn, id) { in rxrpc_destroy_client_conn_ids()
62 conn, refcount_read(&conn->ref)); in rxrpc_destroy_client_conn_ids()
154 struct rxrpc_connection *conn; in rxrpc_alloc_client_connection() local
161 conn = rxrpc_alloc_connection(rxnet, GFP_ATOMIC | __GFP_NOWARN); in rxrpc_alloc_client_connection()
162 if (!conn) in rxrpc_alloc_client_connection()
165 id = idr_alloc_cyclic(&local->conn_ids, conn, 1, 0x40000000, in rxrpc_alloc_client_connection()
168 kfree(conn); in rxrpc_alloc_client_connection()
172 refcount_set(&conn->ref, 1); in rxrpc_alloc_client_connection()
173 conn->proto.cid = id << RXRPC_CIDSHIFT; in rxrpc_alloc_client_connection()
174 conn->proto.epoch = local->rxnet->epoch; in rxrpc_alloc_client_connection()
175 conn->out_clientflag = RXRPC_CLIENT_INITIATED; in rxrpc_alloc_client_connection()
176 conn->bundle = rxrpc_get_bundle(bundle, rxrpc_bundle_get_client_conn); in rxrpc_alloc_client_connection()
177 conn->local = rxrpc_get_local(bundle->local, rxrpc_local_get_client_conn); in rxrpc_alloc_client_connection()
178 conn->peer = rxrpc_get_peer(bundle->peer, rxrpc_peer_get_client_conn); in rxrpc_alloc_client_connection()
179 conn->key = key_get(bundle->key); in rxrpc_alloc_client_connection()
180 conn->security = bundle->security; in rxrpc_alloc_client_connection()
181 conn->exclusive = bundle->exclusive; in rxrpc_alloc_client_connection()
182 conn->upgrade = bundle->upgrade; in rxrpc_alloc_client_connection()
183 conn->orig_service_id = bundle->service_id; in rxrpc_alloc_client_connection()
184 conn->security_level = bundle->security_level; in rxrpc_alloc_client_connection()
185 conn->state = RXRPC_CONN_CLIENT_UNSECURED; in rxrpc_alloc_client_connection()
186 conn->service_id = conn->orig_service_id; in rxrpc_alloc_client_connection()
188 if (conn->security == &rxrpc_no_security) in rxrpc_alloc_client_connection()
189 conn->state = RXRPC_CONN_CLIENT; in rxrpc_alloc_client_connection()
193 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); in rxrpc_alloc_client_connection()
196 rxrpc_see_connection(conn, rxrpc_conn_new_client); in rxrpc_alloc_client_connection()
199 trace_rxrpc_client(conn, -1, rxrpc_client_alloc); in rxrpc_alloc_client_connection()
200 return conn; in rxrpc_alloc_client_connection()
206 static bool rxrpc_may_reuse_conn(struct rxrpc_connection *conn) in rxrpc_may_reuse_conn() argument
211 if (!conn) in rxrpc_may_reuse_conn()
214 rxnet = conn->rxnet; in rxrpc_may_reuse_conn()
215 if (test_bit(RXRPC_CONN_DONT_REUSE, &conn->flags)) in rxrpc_may_reuse_conn()
218 if ((conn->state != RXRPC_CONN_CLIENT_UNSECURED && in rxrpc_may_reuse_conn()
219 conn->state != RXRPC_CONN_CLIENT) || in rxrpc_may_reuse_conn()
220 conn->proto.epoch != rxnet->epoch) in rxrpc_may_reuse_conn()
229 id_cursor = idr_get_cursor(&conn->local->conn_ids); in rxrpc_may_reuse_conn()
230 id = conn->proto.cid >> RXRPC_CIDSHIFT; in rxrpc_may_reuse_conn()
241 set_bit(RXRPC_CONN_DONT_REUSE, &conn->flags); in rxrpc_may_reuse_conn()
341 struct rxrpc_connection *conn, *old; in rxrpc_add_conn_to_bundle() local
353 conn = rxrpc_alloc_client_connection(bundle); in rxrpc_add_conn_to_bundle()
354 if (IS_ERR(conn)) { in rxrpc_add_conn_to_bundle()
355 bundle->alloc_error = PTR_ERR(conn); in rxrpc_add_conn_to_bundle()
360 conn->bundle_shift = shift; in rxrpc_add_conn_to_bundle()
361 bundle->conns[slot] = conn; in rxrpc_add_conn_to_bundle()
362 bundle->conn_ids[slot] = conn->debug_id; in rxrpc_add_conn_to_bundle()
412 static void rxrpc_activate_one_channel(struct rxrpc_connection *conn, in rxrpc_activate_one_channel() argument
415 struct rxrpc_channel *chan = &conn->channels[channel]; in rxrpc_activate_one_channel()
416 struct rxrpc_bundle *bundle = conn->bundle; in rxrpc_activate_one_channel()
421 _enter("C=%x,%u", conn->debug_id, channel); in rxrpc_activate_one_channel()
425 trace_rxrpc_client(conn, channel, rxrpc_client_chan_activate); in rxrpc_activate_one_channel()
430 clear_bit(RXRPC_CONN_FINAL_ACK_0 + channel, &conn->flags); in rxrpc_activate_one_channel()
431 clear_bit(conn->bundle_shift + channel, &bundle->avail_chans); in rxrpc_activate_one_channel()
434 call->conn = rxrpc_get_connection(conn, rxrpc_conn_get_activate_call); in rxrpc_activate_one_channel()
435 call->cid = conn->proto.cid | channel; in rxrpc_activate_one_channel()
437 call->dest_srx.srx_service = conn->service_id; in rxrpc_activate_one_channel()
459 static void rxrpc_unidle_conn(struct rxrpc_connection *conn) in rxrpc_unidle_conn() argument
461 if (!list_empty(&conn->cache_link)) { in rxrpc_unidle_conn()
462 list_del_init(&conn->cache_link); in rxrpc_unidle_conn()
463 rxrpc_put_connection(conn, rxrpc_conn_put_unidle); in rxrpc_unidle_conn()
472 struct rxrpc_connection *conn; in rxrpc_activate_channels() local
491 conn = bundle->conns[slot]; in rxrpc_activate_channels()
492 if (!conn) in rxrpc_activate_channels()
496 set_bit(RXRPC_CONN_PROBING_FOR_UPGRADE, &conn->flags); in rxrpc_activate_channels()
497 rxrpc_unidle_conn(conn); in rxrpc_activate_channels()
500 conn->act_chans |= 1 << channel; in rxrpc_activate_channels()
501 rxrpc_activate_one_channel(conn, channel); in rxrpc_activate_channels()
534 struct rxrpc_connection *conn = call->conn; in rxrpc_expose_client_call() local
535 struct rxrpc_channel *chan = &conn->channels[channel]; in rxrpc_expose_client_call()
545 set_bit(RXRPC_CONN_DONT_REUSE, &conn->flags); in rxrpc_expose_client_call()
546 trace_rxrpc_client(conn, channel, rxrpc_client_exposed); in rxrpc_expose_client_call()
573 struct rxrpc_connection *conn; in rxrpc_disconnect_client_call() local
585 conn = call->conn; in rxrpc_disconnect_client_call()
586 if (!conn) { in rxrpc_disconnect_client_call()
599 chan = &conn->channels[channel]; in rxrpc_disconnect_client_call()
600 trace_rxrpc_client(conn, channel, rxrpc_client_chan_disconnect); in rxrpc_disconnect_client_call()
605 may_reuse = rxrpc_may_reuse_conn(conn); in rxrpc_disconnect_client_call()
618 __rxrpc_disconnect_call(conn, call); in rxrpc_disconnect_client_call()
620 if (test_and_clear_bit(RXRPC_CONN_PROBING_FOR_UPGRADE, &conn->flags)) { in rxrpc_disconnect_client_call()
621 trace_rxrpc_client(conn, channel, rxrpc_client_to_active); in rxrpc_disconnect_client_call()
630 trace_rxrpc_client(conn, channel, rxrpc_client_chan_pass); in rxrpc_disconnect_client_call()
631 rxrpc_activate_one_channel(conn, channel); in rxrpc_disconnect_client_call()
645 set_bit(RXRPC_CONN_FINAL_ACK_0 + channel, &conn->flags); in rxrpc_disconnect_client_call()
646 rxrpc_reduce_conn_timer(conn, final_ack_at); in rxrpc_disconnect_client_call()
651 set_bit(conn->bundle_shift + channel, &conn->bundle->avail_chans); in rxrpc_disconnect_client_call()
652 conn->act_chans &= ~(1 << channel); in rxrpc_disconnect_client_call()
658 if (!conn->act_chans) { in rxrpc_disconnect_client_call()
659 trace_rxrpc_client(conn, channel, rxrpc_client_to_idle); in rxrpc_disconnect_client_call()
660 conn->idle_timestamp = jiffies; in rxrpc_disconnect_client_call()
662 rxrpc_get_connection(conn, rxrpc_conn_get_idle); in rxrpc_disconnect_client_call()
663 list_move_tail(&conn->cache_link, &local->idle_client_conns); in rxrpc_disconnect_client_call()
672 static void rxrpc_unbundle_conn(struct rxrpc_connection *conn) in rxrpc_unbundle_conn() argument
674 struct rxrpc_bundle *bundle = conn->bundle; in rxrpc_unbundle_conn()
678 _enter("C=%x", conn->debug_id); in rxrpc_unbundle_conn()
680 if (conn->flags & RXRPC_CONN_FINAL_ACK_MASK) in rxrpc_unbundle_conn()
681 rxrpc_process_delayed_final_acks(conn, true); in rxrpc_unbundle_conn()
683 bindex = conn->bundle_shift / RXRPC_MAXCALLS; in rxrpc_unbundle_conn()
684 if (bundle->conns[bindex] == conn) { in rxrpc_unbundle_conn()
689 clear_bit(conn->bundle_shift + i, &bundle->avail_chans); in rxrpc_unbundle_conn()
690 rxrpc_put_client_connection_id(bundle->local, conn); in rxrpc_unbundle_conn()
692 rxrpc_put_connection(conn, rxrpc_conn_put_unbundle); in rxrpc_unbundle_conn()
724 void rxrpc_kill_client_conn(struct rxrpc_connection *conn) in rxrpc_kill_client_conn() argument
726 struct rxrpc_local *local = conn->local; in rxrpc_kill_client_conn()
729 _enter("C=%x", conn->debug_id); in rxrpc_kill_client_conn()
731 trace_rxrpc_client(conn, -1, rxrpc_client_cleanup); in rxrpc_kill_client_conn()
734 rxrpc_put_client_connection_id(local, conn); in rxrpc_kill_client_conn()
746 struct rxrpc_connection *conn; in rxrpc_discard_expired_client_conns() local
758 conn = list_first_entry_or_null(&local->idle_client_conns, in rxrpc_discard_expired_client_conns()
760 if (!conn) in rxrpc_discard_expired_client_conns()
772 if (conn->local->service_closed) in rxrpc_discard_expired_client_conns()
775 conn_expires_at = conn->idle_timestamp + expiry; in rxrpc_discard_expired_client_conns()
782 atomic_dec(&conn->active); in rxrpc_discard_expired_client_conns()
783 trace_rxrpc_client(conn, -1, rxrpc_client_discard); in rxrpc_discard_expired_client_conns()
784 list_del_init(&conn->cache_link); in rxrpc_discard_expired_client_conns()
786 rxrpc_unbundle_conn(conn); in rxrpc_discard_expired_client_conns()
788 rxrpc_put_connection(conn, rxrpc_conn_put_discard_idle); in rxrpc_discard_expired_client_conns()
813 struct rxrpc_connection *conn; in rxrpc_clean_up_local_conns() local
821 while ((conn = list_first_entry_or_null(&local->idle_client_conns, in rxrpc_clean_up_local_conns()
823 list_del_init(&conn->cache_link); in rxrpc_clean_up_local_conns()
824 atomic_dec(&conn->active); in rxrpc_clean_up_local_conns()
825 trace_rxrpc_client(conn, -1, rxrpc_client_discard); in rxrpc_clean_up_local_conns()
826 rxrpc_unbundle_conn(conn); in rxrpc_clean_up_local_conns()
827 rxrpc_put_connection(conn, rxrpc_conn_put_local_dead); in rxrpc_clean_up_local_conns()