133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
/*
* Make sure to keep the streams retained and thus the file descriptors
* valid until the actual change has been performed.
*/
[self OF_processQueueAndStoreRemovedIn: _removedArray];
if ([self OF_processCache]) {
objc_autoreleasePoolPop(pool);
return true;
}
objc_autoreleasePoolPop(pool);
events = kevent(_kernelQueue, [_changeList items],
|
|
|
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
/*
* Make sure to keep the streams retained and thus the file descriptors
* valid until the actual change has been performed.
*/
[self OF_processQueueAndStoreRemovedIn: _removedArray];
if ([self OF_processReadBuffers]) {
objc_autoreleasePoolPop(pool);
return true;
}
objc_autoreleasePoolPop(pool);
events = kevent(_kernelQueue, [_changeList items],
|