add some debug prints

Signed-off-by: Nathan Goldbaum <nathan.goldbaum@gmail.com>

Author: ngoldbaum

Makefile

@@ -83,7 +83,7 @@ checks: check
 
 TEST_ARGS :=
 test-py: ## Clean and Make unit tests
-	python -m pytest -v csp/tests --junitxml=junit.xml $(TEST_ARGS)
+	python -m pytest -sv csp/tests --junitxml=junit.xml $(TEST_ARGS)
 
 coverage-py:
 	python -m pytest -v csp/tests --junitxml=junit.xml --cov=csp --cov-report xml --cov-report html --cov-branch --cov-fail-under=80 --cov-report term-missing $(TEST_ARGS)

csp/impl/wiring/threaded_runtime.py

@@ -21,6 +21,7 @@ def stop(self):
         self._pusher.unregister_impl()
 
     def signal_stop(self):
+        print("_EngineStopSignalImpl.signal_stop called")
         self.push_tick(True)
 
 
@@ -29,19 +30,23 @@ def signal_stop(self):
 
 class _EngineStopper:
     def __init__(self):
+        print("_EngineStopper.__init__")
         self._pushimpl = None
         self._deferred_stop = False
 
     def register_impl(self, impl):
+        print(f"_EngineStopper.register_impl: {impl}")
         self._pushimpl = impl
         # For the case where stop is called before push input was actually created on the engine thread
         if self._deferred_stop:
+            print("_EngineStopper.register_impl: signal_stop() called")
             self._pushimpl.signal_stop()
 
     def unregister_impl(self):
         self._pushimpl = None
 
     def stop_engine(self):
+        print(f"_EngineStopper.stop_engine: {self._pushimpl}")
         if self._pushimpl is not None:
             self._pushimpl.signal_stop()
         else:

csp/tests/test_engine.py

@@ -1386,6 +1386,7 @@ def test_threaded_run(self):
         @csp.graph
         def g(count: int) -> csp.ts[int]:
             x = csp.count(csp.timer(timedelta(seconds=0.1)))
+            print(f"g: count, x: {count} {x}")
             stop = x == count
             stop = csp.filter(stop, stop)
 
@@ -1400,7 +1401,9 @@ def g(count: int) -> csp.ts[int]:
         runner = csp.run_on_thread(g, 50000, starttime=datetime.utcnow(), endtime=timedelta(minutes=1), realtime=True)
         import time
 
+        print("calling sleep")
         time.sleep(1)
+        print("calling stop_engine")
         runner.stop_engine()
         res = runner.join()[0]
         self.assertLess(len(res), 20)