diff options
Diffstat (limited to 'cli/tools')
| -rw-r--r-- | cli/tools/bench/reporters.rs | 2 | ||||
| -rw-r--r-- | cli/tools/coverage/range_tree.rs | 2 | ||||
| -rw-r--r-- | cli/tools/registry/api.rs | 1 | ||||
| -rw-r--r-- | cli/tools/registry/provenance.rs | 1 | ||||
| -rw-r--r-- | cli/tools/test/channel.rs | 23 | ||||
| -rw-r--r-- | cli/tools/test/mod.rs | 4 |
6 files changed, 13 insertions, 20 deletions
diff --git a/cli/tools/bench/reporters.rs b/cli/tools/bench/reporters.rs index b5229cf0a..690373dc8 100644 --- a/cli/tools/bench/reporters.rs +++ b/cli/tools/bench/reporters.rs @@ -169,7 +169,7 @@ impl BenchReporter for ConsoleReporter { fn report_register(&mut self, _desc: &BenchDescription) {} fn report_wait(&mut self, desc: &BenchDescription) { - self.name = desc.name.clone(); + self.name.clone_from(&desc.name); match &desc.group { None => {} diff --git a/cli/tools/coverage/range_tree.rs b/cli/tools/coverage/range_tree.rs index 027c7d9e7..bca52844c 100644 --- a/cli/tools/coverage/range_tree.rs +++ b/cli/tools/coverage/range_tree.rs @@ -150,7 +150,7 @@ impl<'rt> RangeTree<'rt> { Self::from_sorted_ranges_inner( rta, &mut ranges.iter().peekable(), - ::std::usize::MAX, + usize::MAX, 0, ) } diff --git a/cli/tools/registry/api.rs b/cli/tools/registry/api.rs index c7097267d..ee9579a19 100644 --- a/cli/tools/registry/api.rs +++ b/cli/tools/registry/api.rs @@ -39,6 +39,7 @@ pub struct OidcTokenResponse { #[derive(serde::Deserialize)] #[serde(rename_all = "camelCase")] pub struct PublishingTaskError { + #[allow(dead_code)] pub code: String, pub message: String, } diff --git a/cli/tools/registry/provenance.rs b/cli/tools/registry/provenance.rs index 7fa2be381..622e483d6 100644 --- a/cli/tools/registry/provenance.rs +++ b/cli/tools/registry/provenance.rs @@ -570,6 +570,7 @@ static DEFAULT_REKOR_URL: Lazy<String> = Lazy::new(|| { #[derive(Debug, Deserialize)] #[serde(rename_all = "camelCase")] pub struct LogEntry { + #[allow(dead_code)] #[serde(rename = "logID")] pub log_id: String, pub log_index: u64, diff --git a/cli/tools/test/channel.rs b/cli/tools/test/channel.rs index a8ce7a955..9a003f2d5 100644 --- a/cli/tools/test/channel.rs +++ b/cli/tools/test/channel.rs @@ -1,7 +1,6 @@ // Copyright 2018-2024 the Deno authors. All rights reserved. MIT license. use super::TestEvent; -use super::TestStdioStream; use deno_core::futures::future::poll_fn; use deno_core::parking_lot; use deno_core::parking_lot::lock_api::RawMutex; @@ -105,7 +104,6 @@ impl TestEventReceiver { struct TestStream { id: usize, - which: TestStdioStream, read_opt: Option<AsyncPipeRead>, sender: UnboundedSender<(usize, TestEvent)>, } @@ -113,7 +111,6 @@ struct TestStream { impl TestStream { fn new( id: usize, - which: TestStdioStream, pipe_reader: PipeRead, sender: UnboundedSender<(usize, TestEvent)>, ) -> std::io::Result<Self> { @@ -121,7 +118,6 @@ impl TestStream { let read_opt = Some(pipe_reader.into_async()?); Ok(Self { id, - which, read_opt, sender, }) @@ -135,7 +131,7 @@ impl TestStream { true } else if self .sender - .send((self.id, TestEvent::Output(self.which, buffer))) + .send((self.id, TestEvent::Output(buffer))) .is_err() { self.read_opt.take(); @@ -275,14 +271,9 @@ impl TestEventSenderFactory { .build() .unwrap(); runtime.block_on(tokio::task::unconstrained(async move { - let mut test_stdout = TestStream::new( - id, - TestStdioStream::Stdout, - stdout_reader, - sender.clone(), - )?; - let mut test_stderr = - TestStream::new(id, TestStdioStream::Stderr, stderr_reader, sender)?; + let mut test_stdout = + TestStream::new(id, stdout_reader, sender.clone())?; + let mut test_stderr = TestStream::new(id, stderr_reader, sender)?; // This ensures that the stdout and stderr streams in the select! loop below cannot starve each // other. @@ -488,7 +479,7 @@ mod tests { let mut count = 0; for message in messages { match message { - TestEvent::Output(_, vec) => { + TestEvent::Output(vec) => { assert_eq!(vec[0], expected); count += vec.len(); } @@ -619,7 +610,7 @@ mod tests { while let Some((_, message)) = receiver.recv().await { if i % 2 == 0 { let expected_text = format!("{:08x}", i / 2).into_bytes(); - let TestEvent::Output(TestStdioStream::Stderr, text) = message else { + let TestEvent::Output(text) = message else { panic!("Incorrect message: {message:?}"); }; assert_eq!(text, expected_text); @@ -665,7 +656,7 @@ mod tests { .unwrap(); drop(worker); let (_, message) = receiver.recv().await.unwrap(); - let TestEvent::Output(TestStdioStream::Stderr, text) = message else { + let TestEvent::Output(text) = message else { panic!("Incorrect message: {message:?}"); }; assert_eq!(text.as_slice(), b"hello"); diff --git a/cli/tools/test/mod.rs b/cli/tools/test/mod.rs index 7416b5a26..88b539470 100644 --- a/cli/tools/test/mod.rs +++ b/cli/tools/test/mod.rs @@ -454,7 +454,7 @@ pub enum TestEvent { Register(Arc<TestDescriptions>), Plan(TestPlan), Wait(usize), - Output(TestStdioStream, Vec<u8>), + Output(Vec<u8>), Slow(usize, u64), Result(usize, TestResult, u64), UncaughtError(String, Box<JsError>), @@ -1491,7 +1491,7 @@ pub async fn report_tests( reporter.report_wait(tests.get(&id).unwrap()); } } - TestEvent::Output(_, output) => { + TestEvent::Output(output) => { reporter.report_output(&output); } TestEvent::Slow(id, elapsed) => { |
