Skip to content

Commit a42909e

Browse files
authored
Merge pull request #1150 from rust-lang/maint
Maintenance
2 parents 8e1798a + f28e37a commit a42909e

File tree

13 files changed

+2523
-2329
lines changed

13 files changed

+2523
-2329
lines changed

compiler/base/Cargo.toml

Lines changed: 142 additions & 170 deletions
Large diffs are not rendered by default.

compiler/base/crate-information.json

Lines changed: 63 additions & 83 deletions
Large diffs are not rendered by default.

compiler/base/modify-cargo-toml/Cargo.lock

Lines changed: 21 additions & 14 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

compiler/base/orchestrator/Cargo.lock

Lines changed: 48 additions & 47 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

compiler/base/orchestrator/src/coordinator.rs

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -4,6 +4,7 @@ use snafu::prelude::*;
44
use std::{
55
collections::{BTreeSet, HashMap},
66
fmt, mem, ops,
7+
pin::pin,
78
process::Stdio,
89
sync::{
910
atomic::{AtomicU64, Ordering},
@@ -1839,14 +1840,12 @@ impl Container {
18391840

18401841
let task = tokio::spawn({
18411842
async move {
1842-
let mut already_cancelled = false;
1843+
let mut cancelled = pin!(token.cancelled().fuse());
18431844
let mut stdin_open = true;
18441845

18451846
loop {
18461847
select! {
1847-
() = token.cancelled(), if !already_cancelled => {
1848-
already_cancelled = true;
1849-
1848+
() = &mut cancelled => {
18501849
let msg = CoordinatorMessage::Kill;
18511850
trace!(msg_name = msg.as_ref(), "processing");
18521851
to_worker_tx.send(msg).await.context(KillSnafu)?;

0 commit comments

Comments
 (0)