| 262 | } |
| 263 | |
| 264 | ReadWriteBufferFromHTTP::CallResult ReadWriteBufferFromHTTP::callImpl( |
| 265 | Poco::Net::HTTPResponse & response, const std::string & method_, const std::optional<HTTPRange> & range, bool allow_redirects) const |
| 266 | { |
| 267 | if (remote_host_filter) |
| 268 | remote_host_filter->checkURL(current_uri); |
| 269 | |
| 270 | Poco::Net::HTTPRequest request(method_, current_uri.getPathAndQuery(), Poco::Net::HTTPRequest::HTTP_1_1); |
| 271 | prepareRequest(request, range); |
| 272 | |
| 273 | auto session = makeHTTPSession(connection_group, current_uri, timeouts, proxy_config); |
| 274 | |
| 275 | ProfileEvents::increment(ProfileEvents::ReadWriteBufferFromHTTPRequestsSent); |
| 276 | |
| 277 | auto & stream_out = session->sendRequest(request); |
| 278 | if (out_stream_callback) |
| 279 | out_stream_callback(stream_out); |
| 280 | |
| 281 | auto & resp_stream = session->receiveResponse(response); |
| 282 | |
| 283 | assertResponseIsOk(current_uri.toString(), response, resp_stream, allow_redirects); |
| 284 | |
| 285 | return ReadWriteBufferFromHTTP::CallResult(std::move(session), resp_stream); |
| 286 | } |
| 287 | |
| 288 | ReadWriteBufferFromHTTP::CallResult ReadWriteBufferFromHTTP::callWithRedirects( |
| 289 | Poco::Net::HTTPResponse & response, const String & method_, const std::optional<HTTPRange> & range) |
nothing calls this directly
no test coverage detected