watching thread counts during datamanager test. added print statement…

… to watch for responses.
linz · Apr 22, 2024 · 7912d85 · 7912d85
1 parent 9ea627d
commit 7912d85
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 1 deletion.
diff --git a/QGIS-AIMS-Plugin/AIMSDataManager/DataManager.py b/QGIS-AIMS-Plugin/AIMSDataManager/DataManager.py
@@ -244,7 +244,7 @@ def response(self,etft=FeedRef((FeatureType.ADDRESS,FeedType.RESOLUTIONFEED))):
         resp = ()
         delflag = False
         #while self.ioq.get((et,ft)) and not self.ioq[(et,ft)]['resp'].empty():
-        print(f'DataManager.Response -- ETFT: {etft} -- Result Queue Length: {self.ioq[etft]["resp"]} -- ')
+        print(f'DataManager.Response -- ETFT: {etft} -- Result Queue Length: ~{self.ioq[etft]["resp"].qsize()} -- ') #TODO:Delete
         while etft in FEEDS.values() and not self.ioq[etft]['resp'].empty():
             resp += (self.ioq[etft]['resp'].get(),)
             print(f'Response: {resp}')

diff --git a/QGIS-AIMS-Plugin/test/DataManager_Test.py b/QGIS-AIMS-Plugin/test/DataManager_Test.py
@@ -24,6 +24,7 @@
 import string
 import time
 import os
+import threading
 
 ROOT = os.path.join(os.path.dirname(os.path.dirname(__file__)))
 sys.path.append(os.path.join(ROOT, 'AIMSDataManager'))
@@ -202,7 +203,9 @@ class Test_5_DataManagerChangeFeed(unittest.TestCase):
     ver = 1000000
 
     def setUp(self):    
+        for t in threading.enumerate(): print(f'THREAD INFO 0: {t}')
         self.dm = self.initDM()
+        for t in threading.enumerate(): print(f'THREAD INFO 1: {t}')
         self.af = FeedRef((FeatureType.ADDRESS,FeedType.FEATURES))
         self.ac = FeedRef((FeatureType.ADDRESS,FeedType.CHANGEFEED))
         self.ar = FeedRef((FeatureType.ADDRESS,FeedType.RESOLUTIONFEED))
@@ -219,7 +222,13 @@ def initDM(self) -> DataManager:
         return dm
 
     def tearDown(self):
+        print('\nTHREAD CLEANUP - PRE')
+        for t in threading.enumerate(): print(f'PRE: {t}')
+        print('===============================')
         self.dm.close()
+        for t in threading.enumerate(): print(f'POST 0: {t}')
+        print('===============================')
+        print('THREAD CLEANUP - POST\n')
         del self.addr_f
 
     def test10_cast(self):
@@ -231,6 +240,7 @@ def test20_add(self):
         addr_c.setVersion(self.ver)
         self.dm.addAddress(addr_c)
         resp = None
+        for t in threading.enumerate(): print(f'THREAD INFO 2: {t}')
         while not resp: 
             resp = self.dm.response(self.ac)
             print(f'Waiting for Response to be valid: {resp}')
@@ -244,6 +254,7 @@ def test30_update(self):
         addr_c.setVersion(self.ver)
         self.dm.updateAddress(addr_c)
         resp = None
+        for t in threading.enumerate(): print(f'THREAD INFO 3: {t}')
         while not resp: 
             resp = self.dm.response(self.ac)
             for r in resp:
@@ -255,6 +266,7 @@ def test40_retire(self):
         addr_c.setVersion(self.ver)
         self.dm.retireAddress(addr_c)
         resp = None
+        for t in threading.enumerate(): print(f'THREAD INFO 4: {t}')
         while not resp: 
             resp = self.dm.response(self.ac)
             for r in resp: