Differences From Artifact [277ef6a678]:
- File src/OFStream.m — part of check-in [f663d40cbd] at 2017-05-13 16:29:52 on branch trunk — Also use nonatomic for non-object properties (user: js, size: 31537) [annotate] [blame] [check-ins using]
To Artifact [563c34066f]:
- File
src/OFStream.m
— part of check-in
[6b77a5dd8b]
at
2017-05-21 21:28:57
on branch trunk
— Prefix private methods with of_ instead of OF_
This matches Apple's style. (user: js, size: 31537) [annotate] [blame] [check-ins using]
| ︙ | ︙ | |||
50 51 52 53 54 55 56 | #import "OFSetOptionFailedException.h" #import "of_asprintf.h" #define MIN_READ_SIZE 512 @implementation OFStream | | | 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 |
#import "OFSetOptionFailedException.h"
#import "of_asprintf.h"
#define MIN_READ_SIZE 512
@implementation OFStream
@synthesize of_waitingForDelimiter = _waitingForDelimiter;
#ifndef OF_WINDOWS
+ (void)initialize
{
if (self == [OFStream class])
signal(SIGPIPE, SIG_IGN);
}
|
| ︙ | ︙ | |||
183 184 185 186 187 188 189 |
#ifdef OF_HAVE_SOCKETS
- (void)asyncReadIntoBuffer: (void *)buffer
length: (size_t)length
target: (id)target
selector: (SEL)selector
{
| | | | | | 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227 228 229 230 231 |
#ifdef OF_HAVE_SOCKETS
- (void)asyncReadIntoBuffer: (void *)buffer
length: (size_t)length
target: (id)target
selector: (SEL)selector
{
[OFRunLoop of_addAsyncReadForStream: self
buffer: buffer
length: length
target: target
selector: selector];
}
- (void)asyncReadIntoBuffer: (void *)buffer
exactLength: (size_t)length
target: (id)target
selector: (SEL)selector
{
[OFRunLoop of_addAsyncReadForStream: self
buffer: buffer
exactLength: length
target: target
selector: selector];
}
# ifdef OF_HAVE_BLOCKS
- (void)asyncReadIntoBuffer: (void *)buffer
length: (size_t)length
block: (of_stream_async_read_block_t)block
{
[OFRunLoop of_addAsyncReadForStream: self
buffer: buffer
length: length
block: block];
}
- (void)asyncReadIntoBuffer: (void *)buffer
exactLength: (size_t)length
block: (of_stream_async_read_block_t)block
{
[OFRunLoop of_addAsyncReadForStream: self
buffer: buffer
exactLength: length
block: block];
}
# endif
#endif
|
| ︙ | ︙ | |||
758 759 760 761 762 763 764 |
selector: selector];
}
- (void)asyncReadLineWithEncoding: (of_string_encoding_t)encoding
target: (id)target
selector: (SEL)selector
{
| | | | 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 |
selector: selector];
}
- (void)asyncReadLineWithEncoding: (of_string_encoding_t)encoding
target: (id)target
selector: (SEL)selector
{
[OFRunLoop of_addAsyncReadLineForStream: self
encoding: encoding
target: target
selector: selector];
}
# ifdef OF_HAVE_BLOCKS
- (void)asyncReadLineWithBlock: (of_stream_async_read_line_block_t)block
{
[self asyncReadLineWithEncoding: OF_STRING_ENCODING_UTF_8
block: block];
}
- (void)asyncReadLineWithEncoding: (of_string_encoding_t)encoding
block: (of_stream_async_read_line_block_t)block
{
[OFRunLoop of_addAsyncReadLineForStream: self
encoding: encoding
block: block];
}
# endif
#endif
- (OFString *)tryReadLine
|
| ︙ | ︙ | |||
1513 1514 1515 1516 1517 1518 1519 |
{
OF_UNRECOGNIZED_SELECTOR
}
#ifdef OF_HAVE_SOCKETS
- (void)cancelAsyncRequests
{
| | | 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 |
{
OF_UNRECOGNIZED_SELECTOR
}
#ifdef OF_HAVE_SOCKETS
- (void)cancelAsyncRequests
{
[OFRunLoop of_cancelAsyncRequestsForObject: self];
}
#endif
- (void)unreadFromBuffer: (const void *)buffer
length: (size_t)length
{
char *readBuffer;
|
| ︙ | ︙ |