Differences From Artifact [f18e106529]:
- File
src/OFStreamObserver.m
— part of check-in
[0a55edad35]
at
2012-10-26 11:04:41
on branch trunk
— Split OFThread.m into multiple files.
It was time to finally have one file per class. (user: js, size: 8821) [annotate] [blame] [check-ins using]
To Artifact [0c778cd456]:
- File src/OFStreamObserver.m — part of check-in [c85ff8d35a] at 2012-12-15 17:52:20 on branch trunk — OFDataArray: Improve API. (user: js, size: 8815) [annotate] [blame] [check-ins using]
| ︙ | ︙ | |||
289 290 291 292 293 294 295 |
}
- (void)OF_processQueue
{
[mutex lock];
@try {
OFStream **queueObjects = [queue objects];
| | | | | | 289 290 291 292 293 294 295 296 297 298 299 300 301 302 303 304 305 306 307 308 309 310 |
}
- (void)OF_processQueue
{
[mutex lock];
@try {
OFStream **queueObjects = [queue objects];
int *queueInfoItems = [queueInfo items];
int *queueFDsItems = [queueFDs items];
size_t i, count = [queue count];
for (i = 0; i < count; i++) {
OFStream *stream = queueObjects[i];
int action = queueInfoItems[i];
int fd = queueFDsItems[i];
if ((action & QUEUE_ACTION) == QUEUE_ADD) {
if (fd > maxFD) {
maxFD = fd;
FDToStream = [self
resizeMemory: FDToStream
size: sizeof(OFStream*)
|
| ︙ | ︙ |