30 	struct rxrpc_connection *conn = NULL;  in rxrpc_find_service_conn_rcu()  local
49 			conn = rb_entry(p, struct rxrpc_connection, service_node);  in rxrpc_find_service_conn_rcu()
51 			if (conn->proto.index_key < k.index_key)  in rxrpc_find_service_conn_rcu()
53 			else if (conn->proto.index_key > k.index_key)  in rxrpc_find_service_conn_rcu()
57 			conn = NULL;  in rxrpc_find_service_conn_rcu()
62 	_leave(" = %d", conn ? conn->debug_id : -1);  in rxrpc_find_service_conn_rcu()
63 	return conn;  in rxrpc_find_service_conn_rcu()
71 				       struct rxrpc_connection *conn)  in rxrpc_publish_service_conn()  argument
74 	struct rxrpc_conn_proto k = conn->proto;  in rxrpc_publish_service_conn()
94 	rb_link_node_rcu(&conn->service_node, parent, pp);  in rxrpc_publish_service_conn()
95 	rb_insert_color(&conn->service_node, &peer->service_conns);  in rxrpc_publish_service_conn()
97 	set_bit(RXRPC_CONN_IN_SERVICE_CONNS, &conn->flags);  in rxrpc_publish_service_conn()
99 	_leave(" = %d [new]", conn->debug_id);  in rxrpc_publish_service_conn()
114 	_debug("replace conn");  in rxrpc_publish_service_conn()
116 			    &conn->service_node,  in rxrpc_publish_service_conn()
129 	struct rxrpc_connection *conn = rxrpc_alloc_connection(gfp);  in rxrpc_prealloc_service_connection()  local
131 	if (conn) {  in rxrpc_prealloc_service_connection()
135 		conn->state = RXRPC_CONN_SERVICE_PREALLOC;  in rxrpc_prealloc_service_connection()
136 		refcount_set(&conn->ref, 2);  in rxrpc_prealloc_service_connection()
137 		conn->bundle = rxrpc_get_bundle(&rxrpc_service_dummy_bundle);  in rxrpc_prealloc_service_connection()
141 		list_add_tail(&conn->link, &rxnet->service_conns);  in rxrpc_prealloc_service_connection()
142 		list_add_tail(&conn->proc_link, &rxnet->conn_proc_list);  in rxrpc_prealloc_service_connection()
145 		trace_rxrpc_conn(conn->debug_id, rxrpc_conn_new_service,  in rxrpc_prealloc_service_connection()
146 				 refcount_read(&conn->ref),  in rxrpc_prealloc_service_connection()
150 	return conn;  in rxrpc_prealloc_service_connection()
158 				   struct rxrpc_connection *conn,  in rxrpc_new_incoming_connection()  argument
167 	conn->proto.epoch	= sp->hdr.epoch;  in rxrpc_new_incoming_connection()
168 	conn->proto.cid		= sp->hdr.cid & RXRPC_CIDMASK;  in rxrpc_new_incoming_connection()
169 	conn->params.service_id	= sp->hdr.serviceId;  in rxrpc_new_incoming_connection()
170 	conn->service_id	= sp->hdr.serviceId;  in rxrpc_new_incoming_connection()
171 	conn->security_ix	= sp->hdr.securityIndex;  in rxrpc_new_incoming_connection()
172 	conn->out_clientflag	= 0;  in rxrpc_new_incoming_connection()
173 	conn->security		= sec;  in rxrpc_new_incoming_connection()
174 	conn->server_key	= key_get(key);  in rxrpc_new_incoming_connection()
175 	if (conn->security_ix)  in rxrpc_new_incoming_connection()
176 		conn->state	= RXRPC_CONN_SERVICE_UNSECURED;  in rxrpc_new_incoming_connection()
178 		conn->state	= RXRPC_CONN_SERVICE;  in rxrpc_new_incoming_connection()
185 	    conn->service_id == rx->service_upgrade.from)  in rxrpc_new_incoming_connection()
186 		conn->service_id = rx->service_upgrade.to;  in rxrpc_new_incoming_connection()
189 	rxrpc_publish_service_conn(conn->params.peer, conn);  in rxrpc_new_incoming_connection()
191 	_net("CONNECTION new %d {%x}", conn->debug_id, conn->proto.cid);  in rxrpc_new_incoming_connection()
198 void rxrpc_unpublish_service_conn(struct rxrpc_connection *conn)  in rxrpc_unpublish_service_conn()  argument
200 	struct rxrpc_peer *peer = conn->params.peer;  in rxrpc_unpublish_service_conn()
203 	if (test_and_clear_bit(RXRPC_CONN_IN_SERVICE_CONNS, &conn->flags))  in rxrpc_unpublish_service_conn()
204 		rb_erase(&conn->service_node, &peer->service_conns);  in rxrpc_unpublish_service_conn()