600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
|
for (;;) {
void *pool;
OFDate *now;
OFTimer *timer;
OFDate *nextTimer;
of_memory_read_barrier();
if (!_running)
break;
pool = objc_autoreleasePoolPush();
now = [OFDate date];
#ifdef OF_HAVE_THREADS
|
>
>
|
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
|
for (;;) {
void *pool;
OFDate *now;
OFTimer *timer;
OFDate *nextTimer;
#ifdef OF_HAVE_THREADS
of_memory_read_barrier();
#endif
if (!_running)
break;
pool = objc_autoreleasePoolPush();
now = [OFDate date];
#ifdef OF_HAVE_THREADS
|
667
668
669
670
671
672
673
674
675
676
677
|
objc_autoreleasePoolPop(pool);
}
}
- (void)stop
{
_running = false;
of_memory_write_barrier();
[_streamObserver cancel];
}
@end
|
>
>
|
669
670
671
672
673
674
675
676
677
678
679
680
681
|
objc_autoreleasePoolPop(pool);
}
}
- (void)stop
{
_running = false;
#ifdef OF_HAVE_THREADS
of_memory_write_barrier();
#endif
[_streamObserver cancel];
}
@end
|