| ︙ | | |
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
-
+
|
#include "config.h"
#include <assert.h>
#import "OFRunLoop.h"
#import "OFDictionary.h"
#ifdef OF_THREADS
#ifdef OF_HAVE_THREADS
# import "OFThread.h"
# import "OFMutex.h"
#endif
#import "OFSortedList.h"
#import "OFTimer.h"
#import "OFDate.h"
|
| ︙ | | |
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
|
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
|
-
+
|
+ (OFRunLoop*)mainRunLoop
{
return [[mainRunLoop retain] autorelease];
}
+ (OFRunLoop*)currentRunLoop
{
#ifdef OF_THREADS
#ifdef OF_HAVE_THREADS
return [[OFThread currentThread] runLoop];
#else
return [self mainRunLoop];
#endif
}
+ (void)OF_setMainRunLoop: (OFRunLoop*)runLoop
|
| ︙ | | |
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
|
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
|
-
+
-
+
-
+
-
+
-
+
-
+
|
- init
{
self = [super init];
@try {
timersQueue = [[OFSortedList alloc] init];
#ifdef OF_THREADS
#ifdef OF_HAVE_THREADS
timersQueueLock = [[OFMutex alloc] init];
#endif
streamObserver = [[OFStreamObserver alloc] init];
[streamObserver setDelegate: self];
readQueues = [[OFMutableDictionary alloc] init];
} @catch (id e) {
[self release];
@throw e;
}
return self;
}
- (void)dealloc
{
[timersQueue release];
#ifdef OF_THREADS
#ifdef OF_HAVE_THREADS
[timersQueueLock release];
#endif
[streamObserver release];
[readQueues release];
[super dealloc];
}
- (void)addTimer: (OFTimer*)timer
{
#ifdef OF_THREADS
#ifdef OF_HAVE_THREADS
[timersQueueLock lock];
@try {
#endif
[timersQueue insertObject: timer];
#ifdef OF_THREADS
#ifdef OF_HAVE_THREADS
} @finally {
[timersQueueLock unlock];
}
#endif
[timer OF_setInRunLoop: self];
[streamObserver cancel];
}
- (void)OF_removeTimer: (OFTimer*)timer
{
#ifdef OF_THREADS
#ifdef OF_HAVE_THREADS
[timersQueueLock lock];
@try {
#endif
of_list_object_t *iter;
for (iter = [timersQueue firstListObject]; iter != NULL;
iter = iter->next) {
if ([iter->object isEqual: timer]) {
[timersQueue removeListObject: iter];
break;
}
}
#ifdef OF_THREADS
#ifdef OF_HAVE_THREADS
} @finally {
[timersQueueLock unlock];
}
#endif
}
- (void)streamIsReadyForReading: (OFStream*)stream
|
| ︙ | | |
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
|
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
619
620
621
622
623
624
625
626
627
628
629
630
631
632
633
|
-
+
-
+
-
+
-
+
|
{
for (;;) {
void *pool = objc_autoreleasePoolPush();
OFDate *now = [OFDate date];
OFTimer *timer;
OFDate *nextTimer;
#ifdef OF_THREADS
#ifdef OF_HAVE_THREADS
[timersQueueLock lock];
@try {
#endif
of_list_object_t *listObject =
[timersQueue firstListObject];
if (listObject != NULL &&
[[listObject->object fireDate] compare: now] !=
OF_ORDERED_DESCENDING) {
timer =
[[listObject->object retain] autorelease];
[timersQueue removeListObject: listObject];
[timer OF_setInRunLoop: nil];
} else
timer = nil;
#ifdef OF_THREADS
#ifdef OF_HAVE_THREADS
} @finally {
[timersQueueLock unlock];
}
#endif
if ([timer isValid])
[timer fire];
#ifdef OF_THREADS
#ifdef OF_HAVE_THREADS
[timersQueueLock lock];
@try {
#endif
nextTimer = [[timersQueue firstObject] fireDate];
#ifdef OF_THREADS
#ifdef OF_HAVE_THREADS
} @finally {
[timersQueueLock unlock];
}
#endif
/* Watch for stream events until the next timer is due */
if (nextTimer != nil) {
|
| ︙ | | |