summaryrefslogtreecommitdiffstats
path: root/yql/essentials/utils/fetch/fetch.cpp
diff options
context:
space:
mode:
authorvvvv <[email protected]>2025-06-17 22:29:00 +0300
committervvvv <[email protected]>2025-06-17 22:43:23 +0300
commiteb5cfac23dd911355748ad88375812f00b50958e (patch)
treef823600ace6fba9caa5356afa53870fc4fed7186 /yql/essentials/utils/fetch/fetch.cpp
parent0a23534b4271d9f9299a4b3bb382be2b3128cfc5 (diff)
YQL-20086 utils
commit_hash:a17cddd8437124cb2737507cf91b8946df93f631
Diffstat (limited to 'yql/essentials/utils/fetch/fetch.cpp')
-rw-r--r--yql/essentials/utils/fetch/fetch.cpp30
1 files changed, 15 insertions, 15 deletions
diff --git a/yql/essentials/utils/fetch/fetch.cpp b/yql/essentials/utils/fetch/fetch.cpp
index d35baeb0974..0797e81b2a7 100644
--- a/yql/essentials/utils/fetch/fetch.cpp
+++ b/yql/essentials/utils/fetch/fetch.cpp
@@ -64,33 +64,33 @@ public:
rqs << "\r\n";
}
- Socket.Reset(new TSocket(TNetworkAddress(host, port), timeout));
- SocketInput.Reset(new TSocketInput(*Socket));
- SocketOutput.Reset(new TSocketOutput(*Socket));
+ Socket_.Reset(new TSocket(TNetworkAddress(host, port), timeout));
+ SocketInput_.Reset(new TSocketInput(*Socket_));
+ SocketOutput_.Reset(new TSocketOutput(*Socket_));
- Socket->SetSocketTimeout(timeout.Seconds(), timeout.MilliSeconds() % 1000);
+ Socket_->SetSocketTimeout(timeout.Seconds(), timeout.MilliSeconds() % 1000);
if (https) {
- Ssl.Reset(new TOpenSslClientIO(SocketInput.Get(), SocketOutput.Get()));
+ Ssl_.Reset(new TOpenSslClientIO(SocketInput_.Get(), SocketOutput_.Get()));
}
{
- THttpOutput ho(Ssl ? (IOutputStream*)Ssl.Get() : (IOutputStream*)SocketOutput.Get());
+ THttpOutput ho(Ssl_ ? (IOutputStream*)Ssl_.Get() : (IOutputStream*)SocketOutput_.Get());
(ho << req).Finish();
}
- HttpInput.Reset(new THttpInput(Ssl ? (IInputStream*)Ssl.Get() : (IInputStream*)SocketInput.Get()));
+ HttpInput_.Reset(new THttpInput(Ssl_ ? (IInputStream*)Ssl_.Get() : (IInputStream*)SocketInput_.Get()));
}
THttpInput& GetStream() override {
- return *HttpInput;
+ return *HttpInput_;
}
unsigned GetRetCode() override {
- return ParseHttpRetCode(HttpInput->FirstLine());
+ return ParseHttpRetCode(HttpInput_->FirstLine());
}
THttpURL GetRedirectURL(const THttpURL& baseUrl) override {
- for (auto i = HttpInput->Headers().Begin(); i != HttpInput->Headers().End(); ++i) {
+ for (auto i = HttpInput_->Headers().Begin(); i != HttpInput_->Headers().End(); ++i) {
if (0 == TCiString::compare(i->Name(), TStringBuf("location"))) {
THttpURL target = ParseURL(i->Value(), THttpURL::FeaturesAll | NUri::TFeature::FeatureConvertHostIDN);
if (!target.IsValidAbs()) {
@@ -107,11 +107,11 @@ public:
}
private:
- THolder<TSocket> Socket;
- THolder<TSocketInput> SocketInput;
- THolder<TSocketOutput> SocketOutput;
- THolder<TOpenSslClientIO> Ssl;
- THolder<THttpInput> HttpInput;
+ THolder<TSocket> Socket_;
+ THolder<TSocketInput> SocketInput_;
+ THolder<TSocketOutput> SocketOutput_;
+ THolder<TOpenSslClientIO> Ssl_;
+ THolder<THttpInput> HttpInput_;
};
inline bool IsRedirectCode(unsigned code) {