From 490e977cda2b71ebd02beea9593ea0a8d23f67da Mon Sep 17 00:00:00 2001
From: grekiki <gregor1234567890@gmail.com>
Date: Mon, 17 May 2021 10:28:24 +0200
Subject: [PATCH] CI: Valgrind assert leaks (#20863)

* update with improvement to process replay

* reduce diff
old-commit-hash: 243bec3444d6c23db20944b67d5ccf44354f63bf
---
 selfdrive/test/test_valgrind_replay.py | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/selfdrive/test/test_valgrind_replay.py b/selfdrive/test/test_valgrind_replay.py
index 7a78bb7329..cffe1443ad 100644
--- a/selfdrive/test/test_valgrind_replay.py
+++ b/selfdrive/test/test_valgrind_replay.py
@@ -83,7 +83,9 @@ class TestValgrind(unittest.TestCase):
     thread.daemon = True
     thread.start()
 
-    time.sleep(5)  # We give the process time to start
+    while not all(pm.all_readers_updated(s) for s in config.pub_sub.keys()):
+      time.sleep(0)
+
     for msg in tqdm(pub_msgs):
       pm.send(msg.which(), msg.as_builder())
       if config.wait_for_response:
@@ -100,6 +102,7 @@ class TestValgrind(unittest.TestCase):
       lr = LogReader(get_segment(URL))
       self.replay_process(cfg, lr)
       time.sleep(1)  # Wait for the logs to get written
+      self.assertFalse(self.leak)
 
 if __name__ == "__main__":
   unittest.main()