In TaskPipelineManager, a periodic NSTimer was added to check the isRunning status of each NSTask in the pipeline. If a NSTask with isRunning = NO is found, all tasks in the pipeline are terminated and purged from the pipeline array.

In AppDelegate, a type error was fixed in an empty NSTimer callback function.

Author: dsward2

LocalRadio/AppDelegate.m

@@ -126,6 +126,8 @@ - (void)applicationDidFinishLaunching:(NSNotification *)aNotification
             [self updateViews:self];
 
             self.periodicUpdateTimer = [NSTimer timerWithTimeInterval:0.1 target:self selector:@selector(periodicUpdateTimerFired:) userInfo:self repeats:YES];
+
+            [[NSRunLoop mainRunLoop] addTimer:self.periodicUpdateTimer forMode:NSDefaultRunLoopMode];
 
             NSNumber * statusPortNumber = [self.localRadioAppSettings integerForKey:@"StatusPort"];
             [self.udpStatusListenerController runServerOnPort:statusPortNumber.integerValue];
@@ -147,7 +149,7 @@ - (void)applicationDidFinishLaunching:(NSNotification *)aNotification
 //	periodicUpdateTimerFired:
 //==================================================================================
 
-- (void)periodicUpdateTimerFired:(NSNotification *)aNotification
+- (void)periodicUpdateTimerFired:(NSTimer *)timer
 {
 
 }

LocalRadio/TaskPipelineManager.h

@@ -19,6 +19,8 @@
 @property (strong) NSMutableArray * taskItemsArray;
 @property (assign) NSInteger taskPipelineStatus;
 
+@property (strong) NSTimer * periodicTaskPipelineCheckTimer;
+
 - (TaskItem *) makeTaskItemWithExecutable:(NSString *)executableName functionName:(NSString *)functionName;
 
 - (void) addTaskItem:(TaskItem *)taskItem;

LocalRadio/TaskPipelineManager.m

@@ -8,17 +8,31 @@
 
 #import "TaskPipelineManager.h"
 #import "TaskItem.h"
+#import "AppDelegate.h"
 
 @implementation TaskPipelineManager
 
 
+- (void) dealloc
+{
+    [self.periodicTaskPipelineCheckTimer invalidate];
+    self.periodicTaskPipelineCheckTimer = NULL;
+}
+
+
+
+
 - (instancetype)init
 {
     self = [super init];
     if (self) {
         self.taskItemsArray = [NSMutableArray array];
 
         self.taskPipelineStatus = kTaskPipelineStatusIdle;
+
+        self.periodicTaskPipelineCheckTimer = [NSTimer timerWithTimeInterval:5.0f target:self selector:@selector(periodicTaskPipelineCheckTimerFired:) userInfo:self repeats:YES];
+
+        [[NSRunLoop mainRunLoop] addTimer:self.periodicTaskPipelineCheckTimer forMode:NSDefaultRunLoopMode];
     }
     return self;
 }
@@ -40,13 +54,16 @@ - (TaskItem *) makeTaskItemWithExecutable:(NSString *)executableName functionNam
 }
 
 
+
+
 - (void) addTaskItem:(TaskItem *)taskItem
 {
     [self.taskItemsArray addObject:taskItem];
 }
 
 
 
+
 - (void) configureTaskPipes
 {
     TaskItem * firstTaskItem = [self.taskItemsArray firstObject];
@@ -90,6 +107,8 @@ - (void) configureTaskPipes
 }
 
 
+
+
 - (void) startTasks
 {
     for (TaskItem * taskItem in self.taskItemsArray)
@@ -113,6 +132,8 @@ - (void) startTasks
 }
 
 
+
+
 - (void) terminateTasks
 {
     //NSArray * reversedTaskItemsArray = [[self.taskItemsArray reverseObjectEnumerator] allObjects];
@@ -131,6 +152,39 @@ - (void) terminateTasks
 }
 
 
+
+- (void) periodicTaskPipelineCheckTimerFired:(NSTimer *)timer
+{
+    BOOL failedTaskFound = NO;
+    TaskItem * failedTaskItem = NULL;
+    
+    for (TaskItem * taskItem in self.taskItemsArray)
+    {
+        if (taskItem.task.isRunning == NO)
+        {
+            failedTaskFound = YES;
+            failedTaskItem = taskItem;
+            break;
+        }
+    }
+
+    if (failedTaskFound == YES)
+    {
+        NSLog(@"TaskPipelineManager - TaskPipelineFailed - %@ - %@", failedTaskItem, self.taskItemsArray);
+
+        [[NSNotificationCenter defaultCenter] postNotificationName:@"TaskPipelineFailedNotification" object:self];
+
+        [self terminateTasks];
+        
+        AppDelegate * appDelegate = (AppDelegate *)[NSApp delegate];
+
+        [appDelegate updateCurrentTasksText];
+    }
+}
+
+
+
+
 - (NSString *)tasksInfoString
 {
     NSMutableString * tasksInfoString = [NSMutableString stringWithString:@"\n\n"];

rtl_fm_localradio/rtl_fm_localradio/rtl_fm_localradio.m

@@ -2043,7 +2043,8 @@ int main(int argc, char **argv)
 		status_cleanup(&status);
 
 		if (output.file != stdout) {
-			fclose(output.file);}
+			fclose(output.file);
+        }
 
 		//fprintf(stderr, "\nrtlsdr_close\n");
 		//NSLog(@"rtlsdr_close");