net/rxrpc/io_thread.c

12 static int rxrpc_input_packet_on_conn(struct rxrpc_connection *conn,
177 	struct rxrpc_connection *conn;
284 		conn = rxrpc_find_client_connection_rcu(local, &peer_srx, skb);
285 		conn = rxrpc_get_connection_maybe(conn, rxrpc_conn_get_call_input);
287 		if (!conn)
290 		ret = rxrpc_input_packet_on_conn(conn, &peer_srx, skb);
291 		rxrpc_put_connection(conn, rxrpc_conn_put_call_input);
307 	conn = rxrpc_find_service_conn_rcu(peer, skb);
308 	conn = rxrpc_get_connection_maybe(conn, rxrpc_conn_get_call_input);
309 	if (conn) {
311 		ret = rxrpc_input_packet_on_conn(conn, &peer_srx, skb);
312 		rxrpc_put_connection(conn, rxrpc_conn_put_call_input);
327 static int rxrpc_input_packet_on_conn(struct rxrpc_connection *conn,
337 	if (sp->hdr.securityIndex != conn->security_ix)
341 	if (sp->hdr.serviceId != conn->service_id) {
344 		if (!test_bit(RXRPC_CONN_PROBING_FOR_UPGRADE, &conn->flags))
347 		old_id = cmpxchg(&conn->service_id, conn->orig_service_id,
349 		if (old_id != conn->orig_service_id &&
354 	if (after(sp->hdr.serial, conn->hi_serial))
355 		conn->hi_serial = sp->hdr.serial;
359 		return rxrpc_input_conn_packet(conn, skb);
363 	chan = &conn->channels[channel];
377 		if (rxrpc_conn_is_service(conn) &&
389 		rxrpc_conn_retransmit_call(conn, skb, channel);
412 		return rxrpc_new_incoming_call(conn->local, conn->peer, conn,
426 	struct rxrpc_connection *conn;
446 		conn = list_first_entry_or_null(&local->conn_attend_q,
449 		if (conn) {
451 			list_del_init(&conn->attend_link);
454 			rxrpc_input_conn_event(conn, NULL);
455 			rxrpc_put_connection(conn, rxrpc_conn_put_poke);
496 				rxrpc_input_conn_event(sp->conn, skb);
497 				rxrpc_put_connection(sp->conn, rxrpc_conn_put_poke);