Pobieranie danych z NSTask w czasie rzeczywistym za pomocą powiadomień nie działa

Question

Mam program wiersza poleceń Cocoa, w którym próbuję uruchomić program NSTask (tshark, aby monitorować sieć) i pobierać z niego dane w czasie rzeczywistym. Zrobiłem więc NSFileHandle , zadzwonić pod numer waitForDataInBackgroundAndNotify, aby wysłać powiadomienia, a następnie zarejestrować moją klasę pomocy w centrum powiadomień, aby przetworzyć dane, ale żadne powiadomienie nie zostanie wysłane do mojej klasy pomocy.

Czy ktoś ma pojęcie, co może być nie tak?

góry dzięki

Oto mój kod:

#import <Foundation/Foundation.h> 
#import <string> 
#import <iostream> 

@interface toff : NSObject {} 
-(void) process:(NSNotification*)notification; 
@end 

@implementation toff 
-(void) process:(NSNotification*)notification{ 
    printf("Packet caught!\n"); 
} 
@end 

int main (int argc, const char * argv[]){ 
    @autoreleasepool { 
     NSTask* tshark = [[NSTask alloc] init]; 
     NSPipe* p = [NSPipe pipe]; 
     NSFileHandle* read = [p fileHandleForReading]; 
     toff* t1 = [[toff alloc] init]; 
     NSNotificationCenter* nc = [NSNotificationCenter defaultCenter]; 

     [read waitForDataInBackgroundAndNotify]; 
     [nc addObserver:t1 selector:@selector(process:) name:nil object:nil]; 

     printf("Type 'stop' to stop monitoring network traffic.\n"); 
     [tshark setLaunchPath:@"/usr/local/bin/tshark"]; 
     [tshark setStandardOutput:p]; 
     [tshark launch]; 

     while(1){ 
      std::string buffer; 
      getline(std::cin, buffer); 
      if(buffer.empty()) continue; 
      else if(buffer.compare("stop") == 0){ 
       [tshark interrupt]; 
       break; 
      } 
     } 

     //NSData* dataRead = [read readDataToEndOfFile]; 
     //NSLog(@"Data: %@", dataRead); 
     //NSString* stringRead = [[NSString alloc] initWithData:dataRead encoding:NSUTF8StringEncoding]; 
     //NSLog(@"Output: %@", stringRead); 

    } 
    return 0; 
} 

EDIT: Kiedy Odkomentuj skomentował fragment kodu i usunąć wszystkie tego powiadomienia rzeczy, wszystkie żądane dane są pobierane z uchwytu pliku po zakończenie zadania.

Zastanawiam się również, czy problem nie może być w rzeczywistości, że mój program jest "Narzędzie wiersza poleceń", więc nie jestem pewien, czy uruchomiono pętlę - jak mówi dokumentacja Apple jest potrzebna (w waitForDataInBackgroundAndNotify wiadomość NSFileHandle):

Musisz wywołać tę metodę z wątku, który ma aktywną pętlę uruchamiania.

Answer 1

Twój program kończy się natychmiast po uruchomieniu zadania. Musisz powiedzieć zadanie: wait until exit. To uruchomi pętlę uruchamiania, czekając na zakończenie procesu potomnego i przypadkowe włączenie uchwytu pliku do monitorowania potoku. Kiedy zadanie zostanie zakończone, metoda powróci i możesz przejść do końca main.

Answer 2

Zapoznaj się z asynctask.m, przykładowy kod, który pokazuje, jak zaimplementować asynchroniczne stdin, stdout & strumienie stderr do przetwarzania danych z NSTask (może być jednak miejsce na poprawę).

Answer 3

Istnieje nowy interfejs API od 10,7, więc można uniknąć używania NSNotifications.

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 
    [self.taskOutput appendData:data]; 
}]; 

Prawdopodobnie chcesz powtórzyć to samo powyżej dla task.standardError.

WAŻNE:

Gdy zadanie kończy, trzeba ustawić readabilityHandler blok do zera; w przeciwnym razie wystąpi duże obciążenie procesora, ponieważ odczyt nigdy się nie zatrzyma.

[task setTerminationHandler:^(NSTask *task) { 

    // do your stuff on completion 

    [task.standardOutput fileHandleForReading].readabilityHandler = nil; 
    [task.standardError fileHandleForReading].readabilityHandler = nil; 
}]; 

To wszystko jest asynchroniczne (i powinieneś zrobić to asynchronicznie), więc twoja metoda powinna mieć blok zakończenia ^.