70 					   struct rxrpc_transport *trans,  in rxrpc_get_bundle()  argument
79 	       rx, key_serial(key), trans->debug_id, ntohs(service_id));  in rxrpc_get_bundle()
81 	if (rx->trans == trans && rx->bundle) {  in rxrpc_get_bundle()
88 	spin_lock(&trans->client_lock);  in rxrpc_get_bundle()
90 	p = trans->bundles.rb_node;  in rxrpc_get_bundle()
102 	spin_unlock(&trans->client_lock);  in rxrpc_get_bundle()
115 	spin_lock(&trans->client_lock);  in rxrpc_get_bundle()
117 	pp = &trans->bundles.rb_node;  in rxrpc_get_bundle()
136 	rb_insert_color(&bundle->node, &trans->bundles);  in rxrpc_get_bundle()
137 	spin_unlock(&trans->client_lock);  in rxrpc_get_bundle()
138 	_net("BUNDLE new on trans %d", trans->debug_id);  in rxrpc_get_bundle()
149 	spin_unlock(&trans->client_lock);  in rxrpc_get_bundle()
150 	_net("BUNDLE old on trans %d", trans->debug_id);  in rxrpc_get_bundle()
161 	spin_unlock(&trans->client_lock);  in rxrpc_get_bundle()
163 	_net("BUNDLE old2 on trans %d", trans->debug_id);  in rxrpc_get_bundle()
175 void rxrpc_put_bundle(struct rxrpc_transport *trans,  in rxrpc_put_bundle()  argument
178 	_enter("%p,%p{%d}",trans, bundle, atomic_read(&bundle->usage));  in rxrpc_put_bundle()
180 	if (atomic_dec_and_lock(&bundle->usage, &trans->client_lock)) {  in rxrpc_put_bundle()
182 		rb_erase(&bundle->node, &trans->bundles);  in rxrpc_put_bundle()
183 		spin_unlock(&trans->client_lock);  in rxrpc_put_bundle()
239 	write_lock_bh(&conn->trans->conn_lock);  in rxrpc_assign_connection_id()
241 	conn->trans->conn_idcounter += RXRPC_CID_INC;  in rxrpc_assign_connection_id()
242 	if (conn->trans->conn_idcounter < RXRPC_CID_INC)  in rxrpc_assign_connection_id()
243 		conn->trans->conn_idcounter = RXRPC_CID_INC;  in rxrpc_assign_connection_id()
244 	real_conn_id = conn->trans->conn_idcounter;  in rxrpc_assign_connection_id()
248 	p = &conn->trans->client_conns.rb_node;  in rxrpc_assign_connection_id()
269 	rb_insert_color(&conn->node, &conn->trans->client_conns);  in rxrpc_assign_connection_id()
273 	write_unlock_bh(&conn->trans->conn_lock);  in rxrpc_assign_connection_id()
284 			conn->trans->conn_idcounter = real_conn_id;  in rxrpc_assign_connection_id()
336 				   struct rxrpc_transport *trans,  in rxrpc_connect_exclusive()  argument
356 		conn->trans = trans;  in rxrpc_connect_exclusive()
380 		spin_lock(&trans->client_lock);  in rxrpc_connect_exclusive()
381 		atomic_inc(&trans->usage);  in rxrpc_connect_exclusive()
384 		     conn->debug_id, conn->trans->debug_id);  in rxrpc_connect_exclusive()
389 		spin_lock(&trans->client_lock);  in rxrpc_connect_exclusive()
413 	spin_unlock(&trans->client_lock);  in rxrpc_connect_exclusive()
420 	spin_unlock(&trans->client_lock);  in rxrpc_connect_exclusive()
430 		       struct rxrpc_transport *trans,  in rxrpc_connect_call()  argument
443 		return rxrpc_connect_exclusive(rx, trans, bundle->service_id,  in rxrpc_connect_call()
446 	spin_lock(&trans->client_lock);  in rxrpc_connect_call()
495 		spin_unlock(&trans->client_lock);  in rxrpc_connect_call()
521 			spin_lock(&trans->client_lock);  in rxrpc_connect_call()
533 		candidate->trans = trans;  in rxrpc_connect_call()
557 		spin_lock(&trans->client_lock);  in rxrpc_connect_call()
562 		atomic_inc(&trans->usage);  in rxrpc_connect_call()
565 		     candidate->debug_id, candidate->trans->debug_id);  in rxrpc_connect_call()
603 	spin_unlock(&trans->client_lock);  in rxrpc_connect_call()
622 rxrpc_incoming_connection(struct rxrpc_transport *trans,  in rxrpc_incoming_connection()  argument
640 	read_lock_bh(&trans->conn_lock);  in rxrpc_incoming_connection()
642 	p = trans->server_conns.rb_node;  in rxrpc_incoming_connection()
659 	read_unlock_bh(&trans->conn_lock);  in rxrpc_incoming_connection()
669 	candidate->trans = trans;  in rxrpc_incoming_connection()
681 	write_lock_bh(&trans->conn_lock);  in rxrpc_incoming_connection()
683 	pp = &trans->server_conns.rb_node;  in rxrpc_incoming_connection()
705 	rb_insert_color(&conn->node, &trans->server_conns);  in rxrpc_incoming_connection()
706 	atomic_inc(&conn->trans->usage);  in rxrpc_incoming_connection()
708 	write_unlock_bh(&trans->conn_lock);  in rxrpc_incoming_connection()
725 		read_unlock_bh(&trans->conn_lock);  in rxrpc_incoming_connection()
729 	read_unlock_bh(&trans->conn_lock);  in rxrpc_incoming_connection()
735 		write_unlock_bh(&trans->conn_lock);  in rxrpc_incoming_connection()
739 	write_unlock_bh(&trans->conn_lock);  in rxrpc_incoming_connection()
753 struct rxrpc_connection *rxrpc_find_connection(struct rxrpc_transport *trans,  in rxrpc_find_connection()  argument
763 	read_lock_bh(&trans->conn_lock);  in rxrpc_find_connection()
769 		p = trans->server_conns.rb_node;  in rxrpc_find_connection()
771 		p = trans->client_conns.rb_node;  in rxrpc_find_connection()
790 	read_unlock_bh(&trans->conn_lock);  in rxrpc_find_connection()
796 	read_unlock_bh(&trans->conn_lock);  in rxrpc_find_connection()
832 		rxrpc_put_bundle(conn->trans, conn->bundle);  in rxrpc_destroy_connection()
838 	rxrpc_put_transport(conn->trans);  in rxrpc_destroy_connection()
867 		spin_lock(&conn->trans->client_lock);  in rxrpc_connection_reaper()
868 		write_lock(&conn->trans->conn_lock);  in rxrpc_connection_reaper()
877 					 &conn->trans->client_conns);  in rxrpc_connection_reaper()
880 					 &conn->trans->server_conns);  in rxrpc_connection_reaper()
890 		write_unlock(&conn->trans->conn_lock);  in rxrpc_connection_reaper()
891 		spin_unlock(&conn->trans->client_lock);  in rxrpc_connection_reaper()