Асинхронное соединение CFStream с runloop - PullRequest
Новая
       9

Асинхронное соединение CFStream с runloop

0 голосов
/ 23 ноября 2010

Я пытаюсь реализовать асинхронную TCP-сеть с помощью runloop. в настоящее время мне удается подключиться, но когда я пытаюсь отправить что-то, я получаю, что -1 байт уже записано - но CFWriteStreamCopyError возвращает ноль.

Пример кода ниже, первая функция подключается, вторая отправляет простое сообщение. любая помощь будет оценена, в том числе случайное обнаружение ошибок (я новичок в Objective-C и в разработке iphone в целом). 

struct header
{
    uint32_t length;
    uint32_t type;
} header;

- (void) connect
{
    NSLog(@"Attempting to (re)connect to %@:%d", m_host, m_port);
    while(TRUE)
    {
        CFHostRef host = CFHostCreateWithName(kCFAllocatorDefault, (CFStringRef)m_host);
        if (!host)
        {
            NSLog(@"Error resolving host %@", m_host);
            [NSThread sleepForTimeInterval:5.0];
            continue;
        }
        CFStreamCreatePairWithSocketToCFHost(kCFAllocatorDefault, host , m_port, &m_in, &m_out);
        CFRelease(host);

        if (!m_in)
        {
            NSLog(@"Error");
        }

        CFStreamClientContext context = {0, self,nil,nil,nil};

        if (CFReadStreamSetClient(m_in, kCFStreamEventHasBytesAvailable | kCFStreamEventErrorOccurred | kCFStreamEventEndEncountered, networkReadEvent, &context))
        {
            CFReadStreamScheduleWithRunLoop(m_in, CFRunLoopGetCurrent(),kCFRunLoopCommonModes);
        }

        if (CFWriteStreamSetClient(m_out, kCFStreamEventErrorOccurred | kCFStreamEventEndEncountered, networkWriteEvent, &context))
        {
            CFWriteStreamScheduleWithRunLoop(m_out, CFRunLoopGetCurrent(),kCFRunLoopCommonModes);
        }


        BOOL success = CFReadStreamOpen(m_in);
        CFErrorRef error = CFReadStreamCopyError(m_in);
        if (!success || (error && CFErrorGetCode(error) != 0))
        {
            NSLog(@"Connect error %s : %d", CFErrorGetDomain(error), CFErrorGetCode(error));
            [NSThread sleepForTimeInterval:5.0];
        }
        else 
        {
            NSLog(@"Connected");
            break;
        }
    }


    [self startSession];
}

- (void) startSession
{
    struct header hh;
    hh.type = RTR_CREATE_SESSION;
    hh.length = 0;
    CFIndex res = CFWriteStreamWrite(self.m_out, (const UInt8*)&hh, sizeof(hh));
    NSLog(@"Written %d", res);

    CFErrorRef error = CFWriteStreamCopyError(self.m_out);
    if (error)
    {
        NSLog(@"Read error %s : %d", CFErrorGetDomain(error), CFErrorGetCode(error));
        CFRelease(error);
    }
}

1 Ответ

0 голосов
/ 23 ноября 2010

разобрался, я тоже забыл открыть поток записи: 

CFWriteStreamOpen(m_out);
...