Changeset 127 for portaudio/trunk/pa_unix_oss

Timestamp:

02/25/02 12:20:39 (9 years ago)

Author:

philburk

Message:

If watchdog detects canary getting starved, then just lower audio thread
priority instead of killing it. If audio completely hung then still kill it.

File:

• portaudio/trunk/pa_unix_oss/pa_unix_oss.c (modified) (17 diffs)

portaudio/trunk/pa_unix_oss/pa_unix_oss.c

@@ -99 +99 @@
 #include <memory.h>
 #include <math.h>
-#include "portaudio.h"
-#include "pa_host.h"
-#include "pa_trace.h"
-
 #include <sys/ioctl.h>
 #include <sys/time.h>
@@ -108 +104 @@
 #include <unistd.h>
 #include <signal.h>
-#include <stdio.h>
-#include <stdlib.h>
+#include <sched.h>
+#include <pthread.h>
+#include <errno.h>
 
 #ifdef __linux__
@@ -117 +114 @@
 #endif
 
-#include <sched.h>
-#include <pthread.h>
-
+#include "portaudio.h"
+#include "pa_host.h"
+#include "pa_trace.h"
 
 #define PRINT(x)   { printf x; fflush(stdout); }
@@ -160 +157 @@
     int              pahsc_AudioPriority;          /* priority of background audio thread */
     pthread_t        pahsc_AudioThread;            /* background audio thread */
+    pid_t            pahsc_AudioThreadPID;         /* background audio thread */
     pthread_t        pahsc_WatchDogThread;         /* highest priority thread that protects system */
+    int              pahsc_WatchDogRun;           /* Ask WatchDog to stop. */
     pthread_t        pahsc_CanaryThread;           /* low priority thread that detects abuse by audio */
     struct timeval   pahsc_CanaryTime;
+    int              pahsc_CanaryRun;             /* Ask Canary to stop. */
     short           *pahsc_NativeInputBuffer;
     short           *pahsc_NativeOutputBuffer;
@@ -543 +543 @@
 static int PaHost_CanaryProc( PaHostSoundControl   *pahsc )
 {
-    int   result;
+    int   result = 0;
 
 #ifdef GNUSTEP
@@ -549 +549 @@
 #endif
 
-    while( (result = usleep( WATCHDOG_INTERVAL_USEC )) == 0 )
+    while( pahsc->pahsc_CanaryRun && ((result = usleep( WATCHDOG_INTERVAL_USEC )) == 0) )
     { 
         gettimeofday( &pahsc->pahsc_CanaryTime, NULL );
@@ -564 +564 @@
 
 /*******************************************************************************************
- * Monitor audio thread and kill it if it hogs the CPU.
+ * Monitor audio thread and lower its it if it hogs the CPU.
  * To prevent getting killed, the audio thread must update a
  * variable with a timer value.
@@ -595 +595 @@
     /* Compare watchdog time with audio and canary thread times. */
     /* Sleep for a while or until thread cancelled. */
-    while( (result = usleep( WATCHDOG_INTERVAL_USEC )) == 0 )
+    while( pahsc->pahsc_WatchDogRun && ((result = usleep( WATCHDOG_INTERVAL_USEC )) == 0) )
     {
         int              delta;
@@ -602 +602 @@
         gettimeofday( &currentTime, NULL );
 
-        /* If audio thread is not advancing, then kill it. */
+        /* If audio thread is not advancing, then lower its priority. */
         delta = currentTime.tv_sec - pahsc->pahsc_EntryTime.tv_sec;
         DBUG(("PaHost_WatchDogProc: audio delta = %d\n", delta ));
         if( delta > WATCHDOG_MAX_SECONDS )
         {
-            ERR_RPT(("PaHost_WatchDogProc: killing hung audio thread!\n"));
             goto killAudio;
         }
@@ -615 +614 @@
         if( delta > WATCHDOG_MAX_SECONDS )
         {
-            ERR_RPT(("PaHost_WatchDogProc: canary died! Killing runaway audio thread!\n"));
-            goto killAudio;
+            ERR_RPT(("PaHost_WatchDogProc: canary died!\n"));
+            goto lowerAudio;
         }
     }
@@ -626 +625 @@
     return 0;
     
+lowerAudio:
+    {
+        struct sched_param    schat = { 0 };
+        if( sched_setscheduler(pahsc->pahsc_AudioThreadPID, SCHED_OTHER, &schat) != 0)
+        {
+            ERR_RPT(("PaHost_WatchDogProc: failed to lower audio priority. errno = %d\n", errno ));
+            /* Fall through into killing audio thread. */
+        }
+        else
+        {
+            ERR_RPT(("PaHost_WatchDogProc: lowered audio priority to prevent hogging of CPU.\n"));
+            goto cleanup;
+        }
+    }
+    
 killAudio:
+    ERR_RPT(("PaHost_WatchDogProc: killing hung audio thread!\n"));
     pthread_kill( pahsc->pahsc_AudioThread, SIGKILL );
+
+cleanup:
+    pahsc->pahsc_CanaryRun = 0;
+    DBUG(("PaHost_WatchDogProc: cancel Canary\n"));
     pthread_cancel( pahsc->pahsc_CanaryThread );
+    DBUG(("PaHost_WatchDogProc: join Canary\n"));
     pthread_join( pahsc->pahsc_CanaryThread, NULL );
+    DBUG(("PaHost_WatchDogProc: forget Canary\n"));
     pahsc->pahsc_CanaryThread = INVALID_THREAD;
-    pahsc->pahsc_WatchDogThread = INVALID_THREAD;
     
 #ifdef GNUSTEP
@@ -645 +665 @@
     if( pahsc->pahsc_WatchDogThread != INVALID_THREAD )
     {
+        pahsc->pahsc_WatchDogRun = 0;
+        DBUG(("PaHost_StopWatchDog: cancel WatchDog\n"));
         pthread_cancel( pahsc->pahsc_WatchDogThread );
         pthread_join( pahsc->pahsc_WatchDogThread, NULL );
@@ -652 +674 @@
     if( pahsc->pahsc_CanaryThread != INVALID_THREAD )
     {
+        pahsc->pahsc_CanaryRun = 0;
+        DBUG(("PaHost_StopWatchDog: cancel Canary\n"));
         pthread_cancel( pahsc->pahsc_CanaryThread );
+        DBUG(("PaHost_StopWatchDog: join Canary\n"));
         pthread_join( pahsc->pahsc_CanaryThread, NULL );
         pahsc->pahsc_CanaryThread = INVALID_THREAD;
@@ -669 +694 @@
 
     /* Launch a canary thread to detect priority abuse. */
+    pahsc->pahsc_CanaryRun = 1;
     hres = pthread_create(&(pahsc->pahsc_CanaryThread),
                       NULL /*pthread_attr_t * attr*/,
@@ -681 +707 @@
 
     /* Launch a watchdog thread to prevent runaway audio thread. */
+    pahsc->pahsc_WatchDogRun = 1;
     hres = pthread_create(&(pahsc->pahsc_WatchDogThread),
                       NULL /*pthread_attr_t * attr*/,
@@ -711 +738 @@
     if( pahsc == NULL ) return paInternalError;
         
+    pahsc->pahsc_AudioThreadPID = getpid();
+    DBUG(("PaHost_BoostPriority: audio PID = %d\n", pahsc->pahsc_AudioThreadPID ));
+    
     /* Choose a priority in the middle of the range. */
     pahsc->pahsc_AudioPriority = (sched_get_priority_max(SCHEDULER_POLICY) -
@@ -807 +837 @@
         pahsc->pahsc_LastPosPtr = info.bytes;
     }
-
+    DBUG(("Pa_AudioThreadProc: left audio loop.\n"));
+    
     past->past_IsActive = 0;
-
     PaHost_StopWatchDog( pahsc );
     
+error:
     DBUG(("leaving audio thread.\n"));
-error:
 #ifdef GNUSTEP
     GSUnregisterCurrentThread();  /* SB20010904 */