387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
|
#ifdef OF_HAVE_SOCKETS
- (void)streamIsReadyForReading: (OFStream*)stream
{
OFList *queue = [_readQueues objectForKey: stream];
of_list_object_t *listObject;
OF_ENSURE(queue != nil);
listObject = [queue firstListObject];
if ([listObject->object isKindOfClass:
[OFRunLoop_ReadQueueItem class]]) {
OFRunLoop_ReadQueueItem *queueItem = listObject->object;
size_t length;
|
|
|
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
|
#ifdef OF_HAVE_SOCKETS
- (void)streamIsReadyForReading: (OFStream*)stream
{
OFList *queue = [_readQueues objectForKey: stream];
of_list_object_t *listObject;
assert(queue != nil);
listObject = [queue firstListObject];
if ([listObject->object isKindOfClass:
[OFRunLoop_ReadQueueItem class]]) {
OFRunLoop_ReadQueueItem *queueItem = listObject->object;
size_t length;
|
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
|
removeObjectForKey: stream];
}
}
# ifdef OF_HAVE_BLOCKS
}
# endif
} else
OF_ENSURE(0);
}
#endif
- (void)run
{
_running = true;
|
|
|
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
|
removeObjectForKey: stream];
}
}
# ifdef OF_HAVE_BLOCKS
}
# endif
} else
assert(0);
}
#endif
- (void)run
{
_running = true;
|