From 3cea44abde3db770d3d4397297c3f4e949db2186 Mon Sep 17 00:00:00 2001
From: Nathan Whitaker <17734409+nathanwhit@users.noreply.github.com>
Date: Wed, 15 May 2024 11:38:45 -0700
Subject: chore: Fix flaky semantic tokens caching test (#23831)

The stderr stream from the LSP is consumed by a separate thread, so it
may not have processed the part we care about yet. Instead, wait until
you see the measure for the request you care about.
---
 tests/util/server/src/lsp.rs | 40 ++++++++++++++++++++++++++++++----------
 1 file changed, 30 insertions(+), 10 deletions(-)

(limited to 'tests/util/server/src')

diff --git a/tests/util/server/src/lsp.rs b/tests/util/server/src/lsp.rs
index ed9dd302f..7c48bae23 100644
--- a/tests/util/server/src/lsp.rs
+++ b/tests/util/server/src/lsp.rs
@@ -689,15 +689,33 @@ impl Perf {
       rx,
     }
   }
-  fn drain(&mut self) {
-    while let Ok(record) = self.rx.try_recv() {
-      if let PerfRecord::Measure(measure) = &record {
-        *self
-          .measures_counts
-          .entry(measure.name.clone())
-          .or_default() += 1;
+  fn drain_until(&mut self, f: impl Fn(&PerfRecord) -> bool) {
+    let timeout_time =
+      Instant::now().checked_add(Duration::from_secs(5)).unwrap();
+    let mut found = false;
+    loop {
+      while let Ok(record) = self.rx.try_recv() {
+        if let PerfRecord::Measure(measure) = &record {
+          *self
+            .measures_counts
+            .entry(measure.name.clone())
+            .or_default() += 1;
+        }
+        if f(&record) {
+          found = true;
+        }
+        self.records.push(record);
+      }
+
+      if found {
+        break;
+      }
+
+      std::thread::sleep(Duration::from_millis(20));
+
+      if Instant::now() > timeout_time {
+        panic!("timed out waiting for perf record");
       }
-      self.records.push(record);
     }
   }
   pub fn measures(&self) -> impl IntoIterator<Item = &PerfMeasure> {
@@ -757,12 +775,14 @@ impl LspClient {
     self.reader.pending_len()
   }
 
-  pub fn perf(&mut self) -> &Perf {
+  /// Collects performance records until a measure with the given name is
+  /// emitted.
+  pub fn perf_wait_for_measure(&mut self, name: &str) -> &Perf {
     let perf = self
       .perf
       .as_mut()
       .expect("must setup with client_builder.collect_perf()");
-    perf.drain();
+    perf.drain_until(|record| matches!(record, PerfRecord::Measure(measure) if measure.name == name));
     perf
   }
 
-- 
cgit v1.2.3