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()
144 struct rxrpc_connection *conn; in rxrpc_alloc_client_connection() local
151 conn = rxrpc_alloc_connection(rxnet, GFP_ATOMIC | __GFP_NOWARN); in rxrpc_alloc_client_connection()
152 if (!conn) in rxrpc_alloc_client_connection()
155 id = idr_alloc_cyclic(&local->conn_ids, conn, 1, 0x40000000, in rxrpc_alloc_client_connection()
158 kfree(conn); in rxrpc_alloc_client_connection()
162 refcount_set(&conn->ref, 1); in rxrpc_alloc_client_connection()
163 conn->proto.cid = id << RXRPC_CIDSHIFT; in rxrpc_alloc_client_connection()
164 conn->proto.epoch = local->rxnet->epoch; in rxrpc_alloc_client_connection()
165 conn->out_clientflag = RXRPC_CLIENT_INITIATED; in rxrpc_alloc_client_connection()
166 conn->bundle = rxrpc_get_bundle(bundle, rxrpc_bundle_get_client_conn); in rxrpc_alloc_client_connection()
167 conn->local = rxrpc_get_local(bundle->local, rxrpc_local_get_client_conn); in rxrpc_alloc_client_connection()
168 conn->peer = rxrpc_get_peer(bundle->peer, rxrpc_peer_get_client_conn); in rxrpc_alloc_client_connection()
169 conn->key = key_get(bundle->key); in rxrpc_alloc_client_connection()
170 conn->security = bundle->security; in rxrpc_alloc_client_connection()
171 conn->exclusive = bundle->exclusive; in rxrpc_alloc_client_connection()
172 conn->upgrade = bundle->upgrade; in rxrpc_alloc_client_connection()
173 conn->orig_service_id = bundle->service_id; in rxrpc_alloc_client_connection()
174 conn->security_level = bundle->security_level; in rxrpc_alloc_client_connection()
175 conn->state = RXRPC_CONN_CLIENT_UNSECURED; in rxrpc_alloc_client_connection()
176 conn->service_id = conn->orig_service_id; in rxrpc_alloc_client_connection()
178 if (conn->security == &rxrpc_no_security) in rxrpc_alloc_client_connection()
179 conn->state = RXRPC_CONN_CLIENT; in rxrpc_alloc_client_connection()
183 list_add_tail(&conn->proc_link, &rxnet->conn_proc_list); in rxrpc_alloc_client_connection()
186 rxrpc_see_connection(conn, rxrpc_conn_new_client); in rxrpc_alloc_client_connection()
189 trace_rxrpc_client(conn, -1, rxrpc_client_alloc); in rxrpc_alloc_client_connection()
190 return conn; in rxrpc_alloc_client_connection()
196 static bool rxrpc_may_reuse_conn(struct rxrpc_connection *conn) in rxrpc_may_reuse_conn() argument
201 if (!conn) in rxrpc_may_reuse_conn()
204 rxnet = conn->rxnet; in rxrpc_may_reuse_conn()
205 if (test_bit(RXRPC_CONN_DONT_REUSE, &conn->flags)) in rxrpc_may_reuse_conn()
208 if ((conn->state != RXRPC_CONN_CLIENT_UNSECURED && in rxrpc_may_reuse_conn()
209 conn->state != RXRPC_CONN_CLIENT) || in rxrpc_may_reuse_conn()
210 conn->proto.epoch != rxnet->epoch) in rxrpc_may_reuse_conn()
219 id_cursor = idr_get_cursor(&conn->local->conn_ids); in rxrpc_may_reuse_conn()
220 id = conn->proto.cid >> RXRPC_CIDSHIFT; in rxrpc_may_reuse_conn()
231 set_bit(RXRPC_CONN_DONT_REUSE, &conn->flags); in rxrpc_may_reuse_conn()
333 struct rxrpc_connection *conn, *old; in rxrpc_add_conn_to_bundle() local
344 conn = rxrpc_alloc_client_connection(bundle); in rxrpc_add_conn_to_bundle()
345 if (IS_ERR(conn)) { in rxrpc_add_conn_to_bundle()
346 bundle->alloc_error = PTR_ERR(conn); in rxrpc_add_conn_to_bundle()
351 conn->bundle_shift = shift; in rxrpc_add_conn_to_bundle()
352 bundle->conns[slot] = conn; in rxrpc_add_conn_to_bundle()
402 static void rxrpc_activate_one_channel(struct rxrpc_connection *conn, in rxrpc_activate_one_channel() argument
405 struct rxrpc_channel *chan = &conn->channels[channel]; in rxrpc_activate_one_channel()
406 struct rxrpc_bundle *bundle = conn->bundle; in rxrpc_activate_one_channel()
411 _enter("C=%x,%u", conn->debug_id, channel); in rxrpc_activate_one_channel()
415 trace_rxrpc_client(conn, channel, rxrpc_client_chan_activate); in rxrpc_activate_one_channel()
420 clear_bit(RXRPC_CONN_FINAL_ACK_0 + channel, &conn->flags); in rxrpc_activate_one_channel()
421 clear_bit(conn->bundle_shift + channel, &bundle->avail_chans); in rxrpc_activate_one_channel()
424 call->conn = rxrpc_get_connection(conn, rxrpc_conn_get_activate_call); in rxrpc_activate_one_channel()
425 call->cid = conn->proto.cid | channel; in rxrpc_activate_one_channel()
427 call->dest_srx.srx_service = conn->service_id; in rxrpc_activate_one_channel()
449 static void rxrpc_unidle_conn(struct rxrpc_connection *conn) in rxrpc_unidle_conn() argument
451 if (!list_empty(&conn->cache_link)) { in rxrpc_unidle_conn()
452 list_del_init(&conn->cache_link); in rxrpc_unidle_conn()
453 rxrpc_put_connection(conn, rxrpc_conn_put_unidle); in rxrpc_unidle_conn()
462 struct rxrpc_connection *conn; in rxrpc_activate_channels() local
481 conn = bundle->conns[slot]; in rxrpc_activate_channels()
482 if (!conn) in rxrpc_activate_channels()
486 set_bit(RXRPC_CONN_PROBING_FOR_UPGRADE, &conn->flags); in rxrpc_activate_channels()
487 rxrpc_unidle_conn(conn); in rxrpc_activate_channels()
490 conn->act_chans |= 1 << channel; in rxrpc_activate_channels()
491 rxrpc_activate_one_channel(conn, channel); in rxrpc_activate_channels()
523 struct rxrpc_connection *conn = call->conn; in rxrpc_expose_client_call() local
524 struct rxrpc_channel *chan = &conn->channels[channel]; in rxrpc_expose_client_call()
534 set_bit(RXRPC_CONN_DONT_REUSE, &conn->flags); in rxrpc_expose_client_call()
535 trace_rxrpc_client(conn, channel, rxrpc_client_exposed); in rxrpc_expose_client_call()
562 struct rxrpc_connection *conn; in rxrpc_disconnect_client_call() local
574 conn = call->conn; in rxrpc_disconnect_client_call()
575 if (!conn) { in rxrpc_disconnect_client_call()
585 chan = &conn->channels[channel]; in rxrpc_disconnect_client_call()
586 trace_rxrpc_client(conn, channel, rxrpc_client_chan_disconnect); in rxrpc_disconnect_client_call()
591 may_reuse = rxrpc_may_reuse_conn(conn); in rxrpc_disconnect_client_call()
604 __rxrpc_disconnect_call(conn, call); in rxrpc_disconnect_client_call()
606 if (test_and_clear_bit(RXRPC_CONN_PROBING_FOR_UPGRADE, &conn->flags)) { in rxrpc_disconnect_client_call()
607 trace_rxrpc_client(conn, channel, rxrpc_client_to_active); in rxrpc_disconnect_client_call()
616 trace_rxrpc_client(conn, channel, rxrpc_client_chan_pass); in rxrpc_disconnect_client_call()
617 rxrpc_activate_one_channel(conn, channel); in rxrpc_disconnect_client_call()
631 set_bit(RXRPC_CONN_FINAL_ACK_0 + channel, &conn->flags); in rxrpc_disconnect_client_call()
632 rxrpc_reduce_conn_timer(conn, final_ack_at); in rxrpc_disconnect_client_call()
637 set_bit(conn->bundle_shift + channel, &conn->bundle->avail_chans); in rxrpc_disconnect_client_call()
638 conn->act_chans &= ~(1 << channel); in rxrpc_disconnect_client_call()
644 if (!conn->act_chans) { in rxrpc_disconnect_client_call()
645 trace_rxrpc_client(conn, channel, rxrpc_client_to_idle); in rxrpc_disconnect_client_call()
646 conn->idle_timestamp = jiffies; in rxrpc_disconnect_client_call()
648 rxrpc_get_connection(conn, rxrpc_conn_get_idle); in rxrpc_disconnect_client_call()
649 list_move_tail(&conn->cache_link, &local->idle_client_conns); in rxrpc_disconnect_client_call()
658 static void rxrpc_unbundle_conn(struct rxrpc_connection *conn) in rxrpc_unbundle_conn() argument
660 struct rxrpc_bundle *bundle = conn->bundle; in rxrpc_unbundle_conn()
664 _enter("C=%x", conn->debug_id); in rxrpc_unbundle_conn()
666 if (conn->flags & RXRPC_CONN_FINAL_ACK_MASK) in rxrpc_unbundle_conn()
667 rxrpc_process_delayed_final_acks(conn, true); in rxrpc_unbundle_conn()
669 bindex = conn->bundle_shift / RXRPC_MAXCALLS; in rxrpc_unbundle_conn()
670 if (bundle->conns[bindex] == conn) { in rxrpc_unbundle_conn()
674 clear_bit(conn->bundle_shift + i, &bundle->avail_chans); in rxrpc_unbundle_conn()
675 rxrpc_put_client_connection_id(bundle->local, conn); in rxrpc_unbundle_conn()
677 rxrpc_put_connection(conn, rxrpc_conn_put_unbundle); in rxrpc_unbundle_conn()
709 void rxrpc_kill_client_conn(struct rxrpc_connection *conn) in rxrpc_kill_client_conn() argument
711 struct rxrpc_local *local = conn->local; in rxrpc_kill_client_conn()
714 _enter("C=%x", conn->debug_id); in rxrpc_kill_client_conn()
716 trace_rxrpc_client(conn, -1, rxrpc_client_cleanup); in rxrpc_kill_client_conn()
719 rxrpc_put_client_connection_id(local, conn); in rxrpc_kill_client_conn()
731 struct rxrpc_connection *conn; in rxrpc_discard_expired_client_conns() local
743 conn = list_first_entry_or_null(&local->idle_client_conns, in rxrpc_discard_expired_client_conns()
745 if (!conn) in rxrpc_discard_expired_client_conns()
757 if (conn->local->service_closed) in rxrpc_discard_expired_client_conns()
760 conn_expires_at = conn->idle_timestamp + expiry; in rxrpc_discard_expired_client_conns()
767 atomic_dec(&conn->active); in rxrpc_discard_expired_client_conns()
768 trace_rxrpc_client(conn, -1, rxrpc_client_discard); in rxrpc_discard_expired_client_conns()
769 list_del_init(&conn->cache_link); in rxrpc_discard_expired_client_conns()
771 rxrpc_unbundle_conn(conn); in rxrpc_discard_expired_client_conns()
773 rxrpc_put_connection(conn, rxrpc_conn_put_discard_idle); in rxrpc_discard_expired_client_conns()
798 struct rxrpc_connection *conn; in rxrpc_clean_up_local_conns() local
806 while ((conn = list_first_entry_or_null(&local->idle_client_conns, in rxrpc_clean_up_local_conns()
808 list_del_init(&conn->cache_link); in rxrpc_clean_up_local_conns()
809 atomic_dec(&conn->active); in rxrpc_clean_up_local_conns()
810 trace_rxrpc_client(conn, -1, rxrpc_client_discard); in rxrpc_clean_up_local_conns()
811 rxrpc_unbundle_conn(conn); in rxrpc_clean_up_local_conns()
812 rxrpc_put_connection(conn, rxrpc_conn_put_local_dead); in rxrpc_clean_up_local_conns()