NSTask/NSPipe odczytano z polecenia Unixa

Question

Piszę aplikację Cocoa, która musi wykonać program UNIX i odczytać jej wynik, linia po linii, ponieważ są one produkowane. Założyłem NSTask i NSPipe jako takie:

task = [[NSTask alloc] init]; 
pipe = [NSPipe pipe]; 
[task setStandardOutput:pipe]; 
//... later ... 
[task setArguments:...]; 
[task setLaunchPath:@"..."]; 
[task launch]; 
handle = [[task fileHandleForReading] retain]; 

Komenda nie kończy aż program mówi, że aby to zrobić z [task terminate]. Próbowałem kilku metod czytania z uchwytu, takich jak -readInBackgroundAndNotify, while([(data = [handle availableData]) length] > 0) i -waitForDataInBackgroundAndNotify, ale rura nigdy nie wydaje żadnych danych. Czy istnieje sposób, aby "poke" "NSTask lub NSPipe przepłukać dane przez?

EDIT: z -readInBackgroundAndNotify:

[handle readInBackgroundAndNotify]; 
notification_block_t handlerBlock = 
    ^(NSNotification *notification) { 
     NSData *data = [[notification userInfo] 
          objectForKey: NSFileHandleNotificationDataItem]; 
     /*... do stuff ...*/ 
     [self addNotification: handle block: handlerBlock]; 
    }; 
[self addNotification: handler block: handlerBlock]; 
//... 
- (void)addNotification:(id)handle block:(notification_block_t)block { 
    [[NSNotificationCenter defaultCenter] 
     addObserverForName: NSFileHandleReadCompletionNotification 
     object: handle 
     queue: [NSOperationQueue mainQueue] 
     usingBlock: block]; 
} 

z -waitForDataInBackgroundAndNotify:

[handle waitForDataInBackgroundAndNotify]; 
notification_block_t handlerBlock = 
    ^(NSNotification *notification) { 
     NSData *data = [handle availableData]; 
     /*... do stuff ...*/ 
    }; 
[self addNotification: handler block: handlerBlock]; 

z while pętli:

[self startProcessingThread: handle]; 
//... 
- (void)startProcessingThread:(NSFileHandle *)handle { 
    [[NSOperationQueue mainQueue] 
     addOperation: [[[NSInvocationOperation alloc] 
          initWithTarget: self 
          selector: @selector(dataLoop:) 
          object: handle] autorelease]]; 
} 
- (void)dataLoop:(NSFileHandle *)handle { 
    NSData *data; 
    while([(data = [handle availableData]) length] > 0) { 
     /*... do stuff ...*/ 
    } 
} 

EDIT 2: Argumenty są następujące (komenda jest tshark):

NSArray *cmd = [NSArray arrayWithObjects:@"-R", @"http.request", 
             @"-Tfields", @"-Eseparator='|'", 
             @"-ehttp.host", @"-ehttp.request.method", 
             @"-ehttp.request.uri", nil]; 
cmd = [[cmd arrayByAddingObjectsFromArray:[self.ports map:^(id arg1, NSUInteger idx) { 
      return [NSString stringWithFormat:@"-d tcp.port==%d,http", [arg1 intValue]]; 
     }]] 
     arrayByAddingObject:[@"dst " stringByAppendingString: 
      [self.hosts componentsJoinedByString:@" or dst "]]]; 
[self.tsharktask setArguments:cmd]; 

Answer 1

Oto przykład pracy, jak zwykle zrobić:

task = [[NSTask alloc] init]; 
    [task setLaunchPath:...]; 
    NSArray *arguments; 
    arguments = ...; 
    [task setArguments:arguments]; 

    NSPipe *outPipe; 
    outPipe = [NSPipe pipe]; 
    [task setStandardOutput:outPipe]; 

    outFile = [outPipe fileHandleForReading]; 
    [outFile waitForDataInBackgroundAndNotify]; 
    [[NSNotificationCenter defaultCenter] addObserver:self 
              selector:@selector(commandNotification:) 
               name:NSFileHandleDataAvailableNotification 
               object:nil];  

    [task launch]; 


- (void)commandNotification:(NSNotification *)notification 
{ 
    NSData *data = nil; 
    while ((data = [self.outFile availableData]) && [data length]){ 
     ... 
    } 
} 

Answer 2

Oto rozwiązanie asynchroniczny uzyskania wyjście zadanie .

task.standardOutput = [NSPipe pipe]; 
[[task.standardOutput fileHandleForReading] setReadabilityHandler:^(NSFileHandle *file) { 
NSData *data = [file availableData]; // this will read to EOF, so call only once 
NSLog(@"Task output! %@", [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding]); 

// if you're collecting the whole output of a task, you may store it on a property 
//maybe you want to appenddata 
//[weakself.taskOutput appendData:data]; 
}]; 

nadzieja może pomóc komuś.