Skip to content

Commit 9f03cfc

Browse files
SwatinemSwatinem
committed
Remove identity_future indirection
This was previously needed because the indirection used to hide some unexplained lifetime errors, which it turned out were related to the `min_choice` algorithm. Removing the indirection also solves a couple of cycle errors, large moves and makes async blocks support the `#[track_caller]` annotation.
1 parent 64165aa commit 9f03cfc

32 files changed

+145
-357
lines changed

‎compiler/rustc_ast_lowering/src/expr.rs

Lines changed: 27 additions & 37 deletions
Original file line numberDiff line numberDiff line change
@@ -32,7 +32,7 @@ impl<'hir> LoweringContext<'_, 'hir> {
3232
pub(super) fn lower_expr_mut(&mut self, e: &Expr) -> hir::Expr<'hir> {
3333
ensure_sufficient_stack(|| {
3434
match &e.kind {
35-
// Paranthesis expression does not have a HirId and is handled specially.
35+
// Parenthesis expression does not have a HirId and is handled specially.
3636
ExprKind::Paren(ex) => {
3737
let mut ex = self.lower_expr_mut(ex);
3838
// Include parens in span, but only if it is a super-span.
@@ -63,6 +63,20 @@ impl<'hir> LoweringContext<'_, 'hir> {
6363
ExprKind::ForLoop(pat, head, body, opt_label) => {
6464
return self.lower_expr_for(e, pat, head, body, *opt_label);
6565
}
66+
// Similarly, async blocks do not use `e.id` but rather `closure_node_id`.
67+
ExprKind::Async(capture_clause, closure_node_id, block) => {
68+
let hir_id = self.lower_node_id(*closure_node_id);
69+
self.lower_attrs(hir_id, &e.attrs);
70+
return self.make_async_expr(
71+
*capture_clause,
72+
hir_id,
73+
*closure_node_id,
74+
None,
75+
e.span,
76+
hir::AsyncGeneratorKind::Block,
77+
|this| this.with_new_scopes(|this| this.lower_block_expr(block)),
78+
);
79+
}
6680
_ => (),
6781
}
6882

@@ -182,15 +196,6 @@ impl<'hir> LoweringContext<'_, 'hir> {
182196
self.arena.alloc_from_iter(arms.iter().map(|x| self.lower_arm(x))),
183197
hir::MatchSource::Normal,
184198
),
185-
ExprKind::Async(capture_clause, closure_node_id, block) => self.make_async_expr(
186-
*capture_clause,
187-
hir_id,
188-
*closure_node_id,
189-
None,
190-
e.span,
191-
hir::AsyncGeneratorKind::Block,
192-
|this| this.with_new_scopes(|this| this.lower_block_expr(block)),
193-
),
194199
ExprKind::Await(expr) => {
195200
let dot_await_span = if expr.span.hi() < e.span.hi() {
196201
let span_with_whitespace = self
@@ -324,7 +329,9 @@ impl<'hir> LoweringContext<'_, 'hir> {
324329
),
325330
ExprKind::Try(sub_expr) => self.lower_expr_try(e.span, sub_expr),
326331

327-
ExprKind::Paren(_) | ExprKind::ForLoop(..) => unreachable!("already handled"),
332+
ExprKind::Paren(_) | ExprKind::ForLoop(..) | ExprKind::Async(..) => {
333+
unreachable!("already handled")
334+
}
328335

329336
ExprKind::MacCall(_) => panic!("{:?} shouldn't exist here", e.span),
330337
};
@@ -586,9 +593,9 @@ impl<'hir> LoweringContext<'_, 'hir> {
586593
/// This results in:
587594
///
588595
/// ```text
589-
/// std::future::identity_future(static move? |_task_context| -> <ret_ty> {
596+
/// static move? |_task_context| -> <ret_ty> {
590597
/// <body>
591-
/// })
598+
/// }
592599
/// ```
593600
pub(super) fn make_async_expr(
594601
&mut self,
@@ -599,7 +606,7 @@ impl<'hir> LoweringContext<'_, 'hir> {
599606
span: Span,
600607
async_gen_kind: hir::AsyncGeneratorKind,
601608
body: impl FnOnce(&mut Self) -> hir::Expr<'hir>,
602-
) -> hir::ExprKind<'hir> {
609+
) -> hir::Expr<'hir> {
603610
let output = ret_ty.unwrap_or_else(|| hir::FnRetTy::DefaultReturn(self.lower_span(span)));
604611

605612
// Resume argument type: `ResumeTy`
@@ -664,13 +671,12 @@ impl<'hir> LoweringContext<'_, 'hir> {
664671
};
665672

666673
let hir_id = self.lower_node_id(closure_node_id);
667-
let unstable_span =
668-
self.mark_span_with_reason(DesugaringKind::Async, span, self.allow_gen_future.clone());
669-
670674
if self.tcx.features().closure_track_caller
671675
&& let Some(attrs) = self.attrs.get(&outer_hir_id.local_id)
672676
&& attrs.into_iter().any(|attr| attr.has_name(sym::track_caller))
673677
{
678+
let unstable_span =
679+
self.mark_span_with_reason(DesugaringKind::Async, span, self.allow_gen_future.clone());
674680
self.lower_attrs(
675681
hir_id,
676682
&[Attribute {
@@ -689,22 +695,7 @@ impl<'hir> LoweringContext<'_, 'hir> {
689695
);
690696
}
691697

692-
let generator = hir::Expr { hir_id, kind: generator_kind, span: self.lower_span(span) };
693-
694-
// FIXME(swatinem):
695-
// For some reason, the async block needs to flow through *any*
696-
// call (like the identity function), as otherwise type and lifetime
697-
// inference have a hard time figuring things out.
698-
// Without this, we would get:
699-
// E0720 in tests/ui/impl-trait/in-trait/default-body-with-rpit.rs
700-
// E0700 in tests/ui/self/self_lifetime-async.rs
701-
702-
// `future::identity_future`:
703-
let identity_future =
704-
self.expr_lang_item_path(unstable_span, hir::LangItem::IdentityFuture, None);
705-
706-
// `future::identity_future(generator)`:
707-
hir::ExprKind::Call(self.arena.alloc(identity_future), arena_vec![self; generator])
698+
hir::Expr { hir_id, kind: generator_kind, span: self.lower_span(span) }
708699
}
709700

710701
/// Desugar `<expr>.await` into:
@@ -1010,7 +1001,7 @@ impl<'hir> LoweringContext<'_, 'hir> {
10101001
}
10111002

10121003
// Transform `async |x: u8| -> X { ... }` into
1013-
// `|x: u8| identity_future(|| -> X { ... })`.
1004+
// `|x: u8| || -> X { ... }`.
10141005
let body_id = this.lower_fn_body(&outer_decl, |this| {
10151006
let async_ret_ty = if let FnRetTy::Ty(ty) = &decl.output {
10161007
let itctx = ImplTraitContext::Disallowed(ImplTraitPosition::AsyncBlock);
@@ -1019,16 +1010,15 @@ impl<'hir> LoweringContext<'_, 'hir> {
10191010
None
10201011
};
10211012

1022-
let async_body = this.make_async_expr(
1013+
this.make_async_expr(
10231014
capture_clause,
10241015
closure_hir_id,
10251016
inner_closure_id,
10261017
async_ret_ty,
10271018
body.span,
10281019
hir::AsyncGeneratorKind::Closure,
10291020
|this| this.with_new_scopes(|this| this.lower_expr_mut(body)),
1030-
);
1031-
this.expr(fn_decl_span, async_body)
1021+
)
10321022
});
10331023
body_id
10341024
});

‎compiler/rustc_ast_lowering/src/item.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1180,7 +1180,7 @@ impl<'hir> LoweringContext<'_, 'hir> {
11801180
},
11811181
);
11821182

1183-
(this.arena.alloc_from_iter(parameters), this.expr(body.span, async_expr))
1183+
(this.arena.alloc_from_iter(parameters), async_expr)
11841184
})
11851185
}
11861186

‎compiler/rustc_hir/src/lang_items.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -296,7 +296,6 @@ language_item_table! {
296296
// FIXME(swatinem): the following lang items are used for async lowering and
297297
// should become obsolete eventually.
298298
ResumeTy, sym::ResumeTy, resume_ty, Target::Struct, GenericRequirement::None;
299-
IdentityFuture, sym::identity_future, identity_future_fn, Target::Fn, GenericRequirement::None;
300299
GetContext, sym::get_context, get_context_fn, Target::Fn, GenericRequirement::None;
301300

302301
Context, sym::Context, context, Target::Struct, GenericRequirement::None;

‎compiler/rustc_hir_typeck/src/callee.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -311,9 +311,9 @@ impl<'a, 'tcx> FnCtxt<'a, 'tcx> {
311311
let fn_decl_span = if hir.body(body).generator_kind
312312
== Some(hir::GeneratorKind::Async(hir::AsyncGeneratorKind::Closure))
313313
{
314-
// Actually need to unwrap a few more layers of HIR to get to
314+
// Actually need to unwrap one more layer of HIR to get to
315315
// the _real_ closure...
316-
let async_closure = hir.parent_id(hir.parent_id(parent_hir_id));
316+
let async_closure = hir.parent_id(parent_hir_id);
317317
if let hir::Node::Expr(hir::Expr {
318318
kind: hir::ExprKind::Closure(&hir::Closure { fn_decl_span, .. }),
319319
..

‎compiler/rustc_hir_typeck/src/fn_ctxt/_impl.rs

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -928,12 +928,7 @@ impl<'a, 'tcx> FnCtxt<'a, 'tcx> {
928928
hir_id,
929929
kind: hir::ExprKind::Closure(..),
930930
..
931-
}) if let Some(Node::Expr(&hir::Expr {
932-
hir_id,
933-
kind: hir::ExprKind::Call(..),
934-
..
935-
})) = self.tcx.hir().find_parent(hir_id) &&
936-
let Some(Node::Item(&hir::Item {
931+
}) if let Some(Node::Item(&hir::Item {
937932
ident,
938933
kind: hir::ItemKind::Fn(ref sig, ..),
939934
..

‎compiler/rustc_span/src/symbol.rs

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -791,7 +791,6 @@ symbols! {
791791
i64,
792792
i8,
793793
ident,
794-
identity_future,
795794
if_let,
796795
if_let_guard,
797796
if_while_or_patterns,

‎compiler/rustc_trait_selection/src/traits/error_reporting/suggestions.rs

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -3025,8 +3025,6 @@ impl<'tcx> TypeErrCtxtExt<'tcx> for TypeErrCtxt<'_, 'tcx> {
30253025
}
30263026
};
30273027

3028-
let identity_future = tcx.require_lang_item(LangItem::IdentityFuture, None);
3029-
30303028
// Don't print the tuple of capture types
30313029
'print: {
30323030
if !is_upvar_tys_infer_tuple {
@@ -3039,12 +3037,7 @@ impl<'tcx> TypeErrCtxtExt<'tcx> for TypeErrCtxt<'_, 'tcx> {
30393037
None => err.note(&msg),
30403038
},
30413039
ty::Alias(ty::Opaque, ty::AliasTy { def_id, .. }) => {
3042-
// Avoid printing the future from `core::future::identity_future`, it's not helpful
3043-
if tcx.parent(*def_id) == identity_future {
3044-
break 'print;
3045-
}
3046-
3047-
// If the previous type is `identity_future`, this is the future generated by the body of an async function.
3040+
// If the previous type is async fn, this is the future generated by the body of an async function.
30483041
// Avoid printing it twice (it was already printed in the `ty::Generator` arm below).
30493042
let is_future = tcx.ty_is_opaque_future(ty);
30503043
debug!(

‎library/core/src/future/mod.rs

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -67,14 +67,10 @@ pub unsafe fn get_context<'a, 'b>(cx: ResumeTy) -> &'a mut Context<'b> {
6767
unsafe { &mut *cx.0.as_ptr().cast() }
6868
}
6969

70-
// FIXME(swatinem): This fn is currently needed to work around shortcomings
71-
// in type and lifetime inference.
72-
// See the comment at the bottom of `LoweringContext::make_async_expr` and
73-
// <https://github.com/rust-lang/rust/issues/104826>.
7470
#[doc(hidden)]
7571
#[unstable(feature = "gen_future", issue = "50547")]
7672
#[inline]
77-
#[lang = "identity_future"]
73+
#[cfg_attr(bootstrap, lang = "identity_future")]
7874
pub const fn identity_future<O, Fut: Future<Output = O>>(f: Fut) -> Fut {
7975
f
8076
}

‎src/tools/clippy/clippy_lints/src/manual_async_fn.rs

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,4 @@
11
use clippy_utils::diagnostics::span_lint_and_then;
2-
use clippy_utils::match_function_call_with_def_id;
32
use clippy_utils::source::{position_before_rarrow, snippet_block, snippet_opt};
43
use if_chain::if_chain;
54
use rustc_errors::Applicability;
@@ -175,16 +174,10 @@ fn captures_all_lifetimes(inputs: &[Ty<'_>], output_lifetimes: &[LifetimeName])
175174
fn desugared_async_block<'tcx>(cx: &LateContext<'tcx>, block: &'tcx Block<'tcx>) -> Option<&'tcx Body<'tcx>> {
176175
if_chain! {
177176
if let Some(block_expr) = block.expr;
178-
if let Some(args) = cx
179-
.tcx
180-
.lang_items()
181-
.identity_future_fn()
182-
.and_then(|def_id| match_function_call_with_def_id(cx, block_expr, def_id));
183-
if args.len() == 1;
184177
if let Expr {
185178
kind: ExprKind::Closure(&Closure { body, .. }),
186179
..
187-
} = args[0];
180+
} = block_expr;
188181
let closure_body = cx.tcx.hir().body(body);
189182
if closure_body.generator_kind == Some(GeneratorKind::Async(AsyncGeneratorKind::Block));
190183
then {

‎src/tools/clippy/clippy_utils/src/lib.rs

Lines changed: 1 addition & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -1904,16 +1904,7 @@ pub fn is_async_fn(kind: FnKind<'_>) -> bool {
19041904

19051905
/// Peels away all the compiler generated code surrounding the body of an async function,
19061906
pub fn get_async_fn_body<'tcx>(tcx: TyCtxt<'tcx>, body: &Body<'_>) -> Option<&'tcx Expr<'tcx>> {
1907-
if let ExprKind::Call(
1908-
_,
1909-
&[
1910-
Expr {
1911-
kind: ExprKind::Closure(&Closure { body, .. }),
1912-
..
1913-
},
1914-
],
1915-
) = body.value.kind
1916-
{
1907+
if let ExprKind::Closure(&Closure { body, .. }) = body.value.kind {
19171908
if let ExprKind::Block(
19181909
Block {
19191910
stmts: [],

‎src/tools/clippy/tests/ui/author/blocks.stdout

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -43,11 +43,7 @@ if let ExprKind::Block(block, None) = expr.kind
4343
if let ExprKind::Closure(CaptureBy::Value, fn_decl, body_id, _, None) = expr.kind
4444
&& let FnRetTy::DefaultReturn(_) = fn_decl.output
4545
&& expr1 = &cx.tcx.hir().body(body_id).value
46-
&& let ExprKind::Call(func, args) = expr1.kind
47-
&& let ExprKind::Path(ref qpath) = func.kind
48-
&& matches!(qpath, QPath::LangItem(LangItem::IdentityFuture, _))
49-
&& args.len() == 1
50-
&& let ExprKind::Closure(CaptureBy::Value, fn_decl1, body_id1, _, Some(Movability::Static)) = args[0].kind
46+
&& let ExprKind::Closure(CaptureBy::Value, fn_decl1, body_id1, _, Some(Movability::Static)) = expr1.kind
5147
&& let FnRetTy::DefaultReturn(_) = fn_decl1.output
5248
&& expr2 = &cx.tcx.hir().body(body_id1).value
5349
&& let ExprKind::Block(block, None) = expr2.kind

‎tests/mir-opt/building/async_await.b-{closure#0}.generator_resume.0.mir

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -4,15 +4,15 @@
44
_0: GeneratorSavedTy {
55
ty: impl std::future::Future<Output = ()>,
66
source_info: SourceInfo {
7-
span: $DIR/async_await.rs:15:8: 15:14 (#9),
7+
span: $DIR/async_await.rs:15:8: 15:14 (#8),
88
scope: scope[0],
99
},
1010
ignore_for_traits: false,
1111
},
1212
_1: GeneratorSavedTy {
1313
ty: impl std::future::Future<Output = ()>,
1414
source_info: SourceInfo {
15-
span: $DIR/async_await.rs:16:8: 16:14 (#12),
15+
span: $DIR/async_await.rs:16:8: 16:14 (#11),
1616
scope: scope[0],
1717
},
1818
ignore_for_traits: false,

‎tests/ui/async-await/generator-desc.stderr

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -2,16 +2,18 @@ error[E0308]: mismatched types
22
--> $DIR/generator-desc.rs:10:19
33
|
44
LL | fun(async {}, async {});
5-
| -------- ^^^^^^^^
6-
| | |
7-
| | expected `async` block, found a different `async` block
8-
| | arguments to this function are incorrect
9-
| the expected `async` block
5+
| --- -------- ^^^^^^^^ expected `async` block, found a different `async` block
6+
| | |
7+
| | the expected `async` block
8+
| arguments to this function are incorrect
109
|
1110
= note: expected `async` block `[async block@$DIR/generator-desc.rs:10:9: 10:17]`
1211
found `async` block `[async block@$DIR/generator-desc.rs:10:19: 10:27]`
1312
note: function defined here
14-
--> $SRC_DIR/core/src/future/mod.rs:LL:COL
13+
--> $DIR/generator-desc.rs:8:4
14+
|
15+
LL | fn fun<F: Future<Output = ()>>(f1: F, f2: F) {}
16+
| ^^^ -----
1517

1618
error[E0308]: mismatched types
1719
--> $DIR/generator-desc.rs:12:16

‎tests/ui/async-await/large_moves.attribute.stderr

Lines changed: 4 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -1,14 +1,8 @@
11
error: moving 10024 bytes
2-
--> $DIR/large_moves.rs:13:13
2+
--> $DIR/large_moves.rs:19:14
33
|
4-
LL | let x = async {
5-
| _____________^
6-
LL | | let y = [0; 9999];
7-
LL | | dbg!(y);
8-
LL | | thing(&y).await;
9-
LL | | dbg!(y);
10-
LL | | };
11-
| |_____^ value moved from here
4+
LL | let z = (x, 42);
5+
| ^ value moved from here
126
|
137
= note: The current maximum size is 1000, but it can be customized with the move_size_limit attribute: `#![move_size_limit = "..."]`
148
note: the lint level is defined here
@@ -17,14 +11,6 @@ note: the lint level is defined here
1711
LL | #![deny(large_assignments)]
1812
| ^^^^^^^^^^^^^^^^^
1913

20-
error: moving 10024 bytes
21-
--> $DIR/large_moves.rs:19:14
22-
|
23-
LL | let z = (x, 42);
24-
| ^ value moved from here
25-
|
26-
= note: The current maximum size is 1000, but it can be customized with the move_size_limit attribute: `#![move_size_limit = "..."]`
27-
2814
error: moving 10024 bytes
2915
--> $DIR/large_moves.rs:19:13
3016
|
@@ -41,5 +27,5 @@ LL | let a = z.0;
4127
|
4228
= note: The current maximum size is 1000, but it can be customized with the move_size_limit attribute: `#![move_size_limit = "..."]`
4329

44-
error: aborting due to 4 previous errors
30+
error: aborting due to 3 previous errors
4531

0 commit comments

Comments
 (0)