Differences From Artifact [fb20fdd1d1]:
- File
src/OFKernelEventObserver.m
— part of check-in
[acc999a75e]
at
2014-05-31 17:57:21
on branch trunk
— OFStream: Add -[hasDataInReadBuffer].
This replaces -[numberOfBytesInReadBuffer], as it's not always known how
many bytes there are exactly and thus the number would often be wrong
(e.g. because data is compressed). (user: js, size: 8993) [annotate] [blame] [check-ins using]
To Artifact [cb71953a13]:
- File
src/OFKernelEventObserver.m
— part of check-in
[68d32a92c1]
at
2014-06-16 15:06:26
on branch trunk
— Make return type of -[OFArray objects] const
After all, this might (and does for OFArray_adjacent!) return an
internal representation that must not be changed, so changes should be
prevented at compile-time. (user: js, size: 9005) [annotate] [blame] [check-ins using]
| ︙ | ︙ | |||
303 304 305 306 307 308 309 |
- (void)OF_processQueue
{
#ifdef OF_HAVE_THREADS
[_mutex lock];
#endif
@try {
| | | 303 304 305 306 307 308 309 310 311 312 313 314 315 316 317 |
- (void)OF_processQueue
{
#ifdef OF_HAVE_THREADS
[_mutex lock];
#endif
@try {
id const *queueObjects = [_queue objects];
int *queueInfoItems = [_queueInfo items];
int *queueFDsItems = [_queueFDs items];
size_t i, count = [_queue count];
for (i = 0; i < count; i++) {
id object = queueObjects[i];
int action = queueInfoItems[i];
|
| ︙ | ︙ | |||
397 398 399 400 401 402 403 |
OF_ENSURE(sendto(_cancelFD[1], "", 1, 0, (struct sockaddr*)&_cancelAddr,
sizeof(_cancelAddr)) > 0);
#endif
}
- (bool)OF_processCache
{
| | | 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 |
OF_ENSURE(sendto(_cancelFD[1], "", 1, 0, (struct sockaddr*)&_cancelAddr,
sizeof(_cancelAddr)) > 0);
#endif
}
- (bool)OF_processCache
{
id const *objects = [_readObjects objects];
size_t i, count = [_readObjects count];
bool foundInCache = false;
for (i = 0; i < count; i++) {
if ([objects[i] isKindOfClass: [OFStream class]] &&
[objects[i] hasDataInReadBuffer] &&
![objects[i] OF_isWaitingForDelimiter]) {
|
| ︙ | ︙ |