couple more small fixes

Author: cartpauj

auto_rx/auto_rx.py

@@ -1073,27 +1073,28 @@ def main():
     if args.type != None:
         handle_scan_results()
 
-    # Loop - Optimized to use event-driven queue instead of pure polling
+    # Loop - Event-driven processing with periodic maintenance
     while True:
-        # OPTIMIZATION: Use blocking queue get with timeout instead of sleep
-        # This allows immediate response to scan results while still doing periodic cleanup
+        # Process any scan results in the queue
+        # handle_scan_results() checks qsize and processes all available results
+        handle_scan_results()
+
+        # Check for finished tasks
+        clean_task_list()
+
+        # Wait for new scan results or timeout after 2 seconds
+        # This allows immediate response when results arrive while still doing periodic cleanup
         try:
-            # Wait for scan result with timeout (replaces pure 2s sleep)
-            # If result arrives, it will be processed by handle_scan_results() below
+            # Block until result arrives or timeout
             result = autorx.scan_results.get(timeout=2.0)
-            # Put it back so handle_scan_results() can process it with all safety checks
+            # Put it back for handle_scan_results() to process on next loop iteration
+            # This maintains the existing queue processing logic without changes
             autorx.scan_results.put(result)
         except Empty:
-            # Queue.get timeout - this is normal, means no scan results for 2s
-            # Continue to cleanup tasks
+            # Timeout - normal condition when no scan results for 2s
+            # Loop will continue to next iteration for periodic maintenance
             pass
 
-        # Check for finished tasks (runs every 2s when queue is empty, or after processing result)
-        clean_task_list()
-
-        # Handle scan results with all safety checks (temporary blocks, spacing, allocation, etc.)
-        handle_scan_results()
-
         if len(autorx.sdr_list) == 0:
             # No Functioning SDRs!
             logging.critical("Task Manager - No SDRs available! Cannot continue...")

auto_rx/autorx/scan.py

@@ -1169,7 +1169,9 @@ def sonde_search(self, first_only=False):
                         return _search_results
 
             except Exception as e:
+                import traceback
                 self.log_error(f"Async scanning failed: {e}, falling back to sequential")
+                self.log_debug(f"Async scan traceback: {traceback.format_exc()}")
 
         # Standard sequential scanning (for RTLSDR, SpyServer, or single peaks)
         else:

auto_rx/autorx/scan_async.py

@@ -173,6 +173,7 @@ async def detect_sonde_async(
     )
 
     process = None
+    ret_output = ""
     try:
         _start = time.time()
 
@@ -403,12 +404,14 @@ def run_async_scan(peak_frequencies: list, max_concurrent: int = 2, **detect_kwa
         asyncio.get_running_loop()
         # An event loop is running - we can't use asyncio.run() here
         # Solution: Run the async code in a separate thread with its own event loop
+        # Note: We create the coroutine inside the worker thread to avoid cross-thread issues
         import concurrent.futures
-        with concurrent.futures.ThreadPoolExecutor() as executor:
-            future = executor.submit(
-                asyncio.run,
+        def run_in_thread():
+            return asyncio.run(
                 scan_peaks_concurrent(peak_frequencies, max_concurrent, **detect_kwargs)
             )
+        with concurrent.futures.ThreadPoolExecutor() as executor:
+            future = executor.submit(run_in_thread)
             return future.result()
     except RuntimeError:
         # No event loop running - we can use asyncio.run() directly