44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
|
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
|
+
+
|
#endif
#import "OFInitializationFailedException.h"
#import "OFInvalidArgumentException.h"
#import "OFOutOfRangeException.h"
#ifdef OF_AMIGAOS
# define Class IntuitionClass
# include <proto/exec.h>
# undef Class
#endif
@implementation OFKernelEventObserver
@synthesize delegate = _delegate;
#ifdef OF_AMIGAOS
@synthesize execSignalMask = _execSignalMask;
#endif
|
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
|
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
|
-
+
-
-
-
+
+
+
+
+
+
+
+
|
- (bool)of_processReadBuffers
{
void *pool = objc_autoreleasePoolPush();
bool foundInReadBuffer = false;
for (id object in [[_readObjects copy] autorelease]) {
void *pool2 = objc_autoreleasePoolPush();
void *pool2;
if ([object isKindOfClass: [OFStream class]] &&
[object hasDataInReadBuffer] &&
![(OFStream *)object of_isWaitingForDelimiter]) {
if (![object isKindOfClass: [OFStream class]])
continue;
pool2 = objc_autoreleasePoolPush();
if ([object hasDataInReadBuffer] &&
(![object of_isWaitingForDelimiter] ||
[object lowlevelHasDataInReadBuffer])) {
if ([_delegate respondsToSelector:
@selector(objectIsReadyForReading:)])
[_delegate objectIsReadyForReading: object];
foundInReadBuffer = true;
}
|