Overview
| Comment: | Add -[pendingBytes] to OFStream.
This way, the method to determine whether OFStreamSocket should |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | trunk |
| Files: | files | file ages | folders |
| SHA3-256: |
f4151a36e30282849a3d0dd22a4899dd |
| User & Date: | js on 2011-04-03 19:52:49 |
| Other Links: | manifest | tags |
Context
|
2011-04-04
| ||
| 23:02 | Indent -[description] of collections. check-in: 1df836eacc user: js tags: trunk | |
|
2011-04-03
| ||
| 19:52 | Add -[pendingBytes] to OFStream. check-in: f4151a36e3 user: js tags: trunk | |
| 19:25 | OPEN_MAX is not available on every system. check-in: 6d9854419c user: js tags: trunk | |
Changes
Modified src/OFStream.h from [24a5771adb] to [30f45428be].
| ︙ | ︙ | |||
325 326 327 328 329 330 331 332 333 334 335 336 337 338 | * \param fmt A string used as format * \param args The arguments used in the format string * \return The number of bytes written */ - (size_t)writeFormat: (OFString*)fmt withArguments: (va_list)args; /** * \return Whether the stream is in blocking mode */ - (BOOL)isBlocking; /** * Enables or disables non-blocking I/O. | > > > > > | 325 326 327 328 329 330 331 332 333 334 335 336 337 338 339 340 341 342 343 | * \param fmt A string used as format * \param args The arguments used in the format string * \return The number of bytes written */ - (size_t)writeFormat: (OFString*)fmt withArguments: (va_list)args; /** * \return The number of bytes still present in the internal cache. */ - (size_t)pendingBytes; /** * \return Whether the stream is in blocking mode */ - (BOOL)isBlocking; /** * Enables or disables non-blocking I/O. |
| ︙ | ︙ |
Modified src/OFStream.m from [d928d7a5b3] to [3989a671e1].
| ︙ | ︙ | |||
698 699 700 701 702 703 704 705 706 707 708 709 710 711 |
} @finally {
free(t);
}
/* Get rid of a warning, never reached anyway */
assert(0);
}
- (BOOL)isBlocking
{
return isBlocking;
}
- (void)setBlocking: (BOOL)enable
| > > > > > | 698 699 700 701 702 703 704 705 706 707 708 709 710 711 712 713 714 715 716 |
} @finally {
free(t);
}
/* Get rid of a warning, never reached anyway */
assert(0);
}
- (size_t)pendingBytes
{
return cacheLen;
}
- (BOOL)isBlocking
{
return isBlocking;
}
- (void)setBlocking: (BOOL)enable
|
| ︙ | ︙ |
Modified src/OFStreamObserver.m from [68c03424f8] to [b3c7d0cf87].
| ︙ | ︙ | |||
356 357 358 359 360 361 362 |
[self _processQueue];
cArray = [readStreams cArray];
count = [readStreams count];
for (i = 0; i < count; i++) {
| | | 356 357 358 359 360 361 362 363 364 365 366 367 368 369 370 |
[self _processQueue];
cArray = [readStreams cArray];
count = [readStreams count];
for (i = 0; i < count; i++) {
if ([cArray[i] pendingBytes] > 0) {
[delegate streamDidBecomeReadyForReading: cArray[i]];
foundInCache = YES;
[pool releaseObjects];
}
}
/*
|
| ︙ | ︙ |