14
15
16
17
18
19
20
21
22
23
24
25
26
27
|
* file.
*/
#include "config.h"
#define __NO_EXT_QNX
#include <unistd.h>
#include <assert.h>
#import "OFStreamObserver.h"
#import "OFArray.h"
#import "OFDictionary.h"
|
>
>
|
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
* file.
*/
#include "config.h"
#define __NO_EXT_QNX
#include <stdlib.h>
#include <unistd.h>
#include <assert.h>
#import "OFStreamObserver.h"
#import "OFArray.h"
#import "OFDictionary.h"
|
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
# import "OFStreamObserver_poll.h"
#endif
#if defined(HAVE_SYS_SELECT_H) || defined(_WIN32)
# import "OFStreamObserver_select.h"
#endif
#import "OFInitializationFailedException.h"
#import "OFNotImplementedException.h"
|
<
|
43
44
45
46
47
48
49
50
51
52
53
54
55
56
|
# import "OFStreamObserver_poll.h"
#endif
#if defined(HAVE_SYS_SELECT_H) || defined(_WIN32)
# import "OFStreamObserver_select.h"
#endif
#import "OFInitializationFailedException.h"
#import "OFOutOfRangeException.h"
#import "autorelease.h"
#import "macros.h"
enum {
QUEUE_ADD = 0,
|
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
|
OF_ENSURE(sendto(cancelFD[1], "", 1, 0, (struct sockaddr*)&cancelAddr,
sizeof(cancelAddr)) > 0);
#endif
}
- (void)OF_addFileDescriptorForReading: (int)fd
{
@throw [OFNotImplementedException exceptionWithClass: [self class]
selector: _cmd];
@throw [OFNotImplementedException exceptionWithClass: [self class]
selector: _cmd];
@throw [OFNotImplementedException exceptionWithClass: [self class]
selector: _cmd];
@throw [OFNotImplementedException exceptionWithClass: [self class]
selector: _cmd];
|
<
|
>
<
|
>
<
|
>
<
|
>
|
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
|
OF_ENSURE(sendto(cancelFD[1], "", 1, 0, (struct sockaddr*)&cancelAddr,
sizeof(cancelAddr)) > 0);
#endif
}
- (void)OF_addFileDescriptorForReading: (int)fd
{
[self doesNotRecognizeSelector: _cmd];
abort();
}
- (void)OF_addFileDescriptorForWriting: (int)fd
{
[self doesNotRecognizeSelector: _cmd];
abort();
}
- (void)OF_removeFileDescriptorForReading: (int)fd
{
[self doesNotRecognizeSelector: _cmd];
abort();
}
- (void)OF_removeFileDescriptorForWriting: (int)fd
{
[self doesNotRecognizeSelector: _cmd];
abort();
}
- (void)OF_processQueue
{
[mutex lock];
@try {
OFStream **queueObjects = [queue objects];
|
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
|
- (void)observe
{
[self observeWithTimeout: -1];
}
- (BOOL)observeWithTimeout: (double)timeout
{
@throw [OFNotImplementedException exceptionWithClass: [self class]
selector: _cmd];
|
<
|
>
|
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
|
- (void)observe
{
[self observeWithTimeout: -1];
}
- (BOOL)observeWithTimeout: (double)timeout
{
[self doesNotRecognizeSelector: _cmd];
abort();
}
- (void)cancel
{
#ifndef _WIN32
OF_ENSURE(write(cancelFD[1], "", 1) > 0);
#else
|