Differences From Artifact [95bd8d7b45]:
- File
src/OFHTTPClient.m
— part of check-in
[34cb121dc5]
at
2021-11-06 00:10:48
on branch trunk
— Make OFTLSSocket an abstract class
This should make it easier to add TLS support using various
implementations. (user: js, size: 30051) [annotate] [blame] [check-ins using]
To Artifact [63931bf44e]:
- File
src/OFHTTPClient.m
— part of check-in
[d1d36ae522]
at
2021-11-06 15:57:29
on branch trunk
— OFStream: New write API
The old write API made it too easy to lose bytes when a stream is set to
non-blocking mode. The new API always throws when not all bytes were
written, which forces handling the number of bytes being written being
smaller than the number of bytes requested to be written. (user: js, size: 29819) [annotate] [blame] [check-ins using]
| ︙ | ︙ | |||
765 766 767 768 769 770 771 | [self close]; [_handler release]; [super dealloc]; } | | < < < > | < | | | | | < < < | < < < < < < < | | 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789 790 791 792 793 794 795 796 797 798 799 800 801 802 803 804 805 806 807 808 809 810 811 812 813 814 815 816 |
[self close];
[_handler release];
[super dealloc];
}
- (size_t)lowlevelWriteBuffer: (const void *)buffer length: (size_t)length
{
/* TODO: Use non-blocking writes */
if (_socket == nil)
@throw [OFNotOpenException exceptionWithObject: self];
/*
* We must not send a chunk of size 0, as that would end the body. We
* always ignore writing 0 bytes to still allow writing 0 bytes after
* the end of stream.
*/
if (length == 0)
return 0;
if (_atEndOfStream)
@throw [OFWriteFailedException exceptionWithObject: self
requestedLength: length
bytesWritten: 0
errNo: ENOTCONN];
if (_chunked)
[_socket writeFormat: @"%zX\r\n", length];
else if (length > _toWrite)
@throw [OFOutOfRangeException exception];
[_socket writeBuffer: buffer length: length];
if (_chunked)
[_socket writeString: @"\r\n"];
if (!_chunked) {
_toWrite -= length;
if (_toWrite == 0)
_atEndOfStream = true;
}
return length;
}
- (bool)lowlevelIsAtEndOfStream
{
return _atEndOfStream;
}
|
| ︙ | ︙ |