113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
@end
static OFString *
constructRequestString(OFHTTPRequest *request)
{
void *pool = objc_autoreleasePoolPush();
OFHTTPRequestMethod method = request.method;
OFIRI *IRI = request.IRI;
OFString *path;
OFString *user = IRI.user, *password = IRI.password;
OFMutableString *requestString;
OFMutableDictionary OF_GENERIC(OFString *, OFString *) *headers;
bool hasContentLength, chunked;
OFEnumerator OF_GENERIC(OFString *) *keyEnumerator, *objectEnumerator;
OFString *key, *object;
|
|
|
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
|
@end
static OFString *
constructRequestString(OFHTTPRequest *request)
{
void *pool = objc_autoreleasePoolPush();
OFHTTPRequestMethod method = request.method;
OFIRI *IRI = request.IRI.IRIByAddingPercentEncodingForUnicodeCharacters;
OFString *path;
OFString *user = IRI.user, *password = IRI.password;
OFMutableString *requestString;
OFMutableDictionary OF_GENERIC(OFString *, OFString *) *headers;
bool hasContentLength, chunked;
OFEnumerator OF_GENERIC(OFString *) *keyEnumerator, *objectEnumerator;
OFString *key, *object;
|
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
|
if ([_client->_delegate respondsToSelector:
@selector(client:didCreateTLSStream:request:)])
[_client->_delegate client: _client
didCreateTLSStream: stream
request: _request];
stream.delegate = self;
[stream asyncPerformClientHandshakeWithHost: _request.IRI.host];
} else {
sock.delegate = self;
[self performSelector: @selector(handleStream:)
withObject: sock
afterDelay: 0];
}
}
|
|
>
|
663
664
665
666
667
668
669
670
671
672
673
674
675
676
677
678
|
if ([_client->_delegate respondsToSelector:
@selector(client:didCreateTLSStream:request:)])
[_client->_delegate client: _client
didCreateTLSStream: stream
request: _request];
stream.delegate = self;
[stream asyncPerformClientHandshakeWithHost: _request.IRI
.IRIByAddingPercentEncodingForUnicodeCharacters.host];
} else {
sock.delegate = self;
[self performSelector: @selector(handleStream:)
withObject: sock
afterDelay: 0];
}
}
|
724
725
726
727
728
729
730
731
732
733
734
735
736
737
738
|
} else
[self closeAndReconnect];
}
- (void)closeAndReconnect
{
@try {
OFIRI *IRI = _request.IRI;
OFTCPSocket *sock;
uint16_t port;
OFNumber *IRIPort;
[_client close];
sock = [OFTCPSocket socket];
|
|
>
|
725
726
727
728
729
730
731
732
733
734
735
736
737
738
739
740
|
} else
[self closeAndReconnect];
}
- (void)closeAndReconnect
{
@try {
OFIRI *IRI =
_request.IRI.IRIByAddingPercentEncodingForUnicodeCharacters;
OFTCPSocket *sock;
uint16_t port;
OFNumber *IRIPort;
[_client close];
sock = [OFTCPSocket socket];
|