Debug Timing and Decoding

Author: consuelita

AudioCoder/src/main/java/org/operatorfoundation/audiocoder/WSPRProcessor.kt

@@ -205,27 +205,41 @@ class WSPRProcessor
     {
         val allMessages = mutableListOf<WSPRMessage>()
 
+        Timber.d("=== Starting decode with ${windows.size} windows ===")
+        Timber.d("Buffer has ${audioBuffer.size} samples (${getBufferDurationSeconds()}s)")
+        Timber.d("Required: ${REQUIRED_DECODE_SAMPLES} samples (${REQUIRED_DECODE_SECONDS}s)")
+
         for (window in windows)
         {
             try
             {
                 val windowSamples = audioBuffer.subList(window.startIndex, window.endIndex).toShortArray()
                 val audioBytes = convertShortsToBytes(windowSamples)
 
+                Timber.d("Calling native decoder:")
+                Timber.d("  Window: ${window.description}")
+                Timber.d("  Samples: ${windowSamples.size} (${windowSamples.size / WSPR_REQUIRED_SAMPLE_RATE}s)")
+                Timber.d("  Bytes: ${audioBytes.size}")
+                Timber.d("  Frequency: ${dialFrequencyMHz} MHz")
+                Timber.d("  LSB: $useLowerSideband")
+
                 val messages = CJarInterface.WSPRDecodeFromPcm(audioBytes, dialFrequencyMHz, useLowerSideband)
 
+                Timber.d("Native decoder returned: ${messages?.size ?: "null"} messages")
+
                 messages?.let {
                     allMessages.addAll(it.toList())
-                     Timber.d("Decoded ${it.size} messages from ${window.description}")
+                    Timber.d("Decoded ${it.size} messages from ${window.description}")
                 }
             }
             catch (exception: Exception)
             {
-                // Log decode failure but continue with other windows
-                 Timber.w(exception, "Failed to decode ${window.description}")
+                Timber.e(exception, "Failed to decode ${window.description}")
             }
         }
 
+        Timber.d("=== Decode complete: ${allMessages.size} total messages ===")
+
         return if (allMessages.isNotEmpty())
         {
             removeDuplicateMessages(allMessages).toTypedArray()

AudioCoder/src/main/java/org/operatorfoundation/audiocoder/WSPRStation.kt

@@ -302,16 +302,17 @@ class WSPRStation(
         // Phase 2: Collect audio for the required duration
         _stationState.value = WSPRStationState.CollectingAudio
         val audioCollectionStartTime = System.currentTimeMillis()
+        var totalSamplesCollected = 0
 
         while (System.currentTimeMillis() - audioCollectionStartTime < AUDIO_COLLECTION_DURATION_MILLISECONDS)
         {
             val audioChunk = audioSource.readAudioChunk(AUDIO_CHUNK_DURATION_MILLISECONDS)
             signalProcessor.addSamples(audioChunk)
-
-            // Brief pause to prevent excessive CPU usage
-            delay(AUDIO_COLLECTION_PAUSE_MILLISECONDS)
+            totalSamplesCollected += audioChunk.size
         }
 
+        Timber.d("Audio collection complete: ${totalSamplesCollected} samples in ${System.currentTimeMillis() - audioCollectionStartTime}ms")
+
         // Phase 3: Process collected audio through WSPR decoder
         _stationState.value = WSPRStationState.ProcessingAudio