diff options
author | nalpp <nalpp@yandex-team.ru> | 2022-02-10 16:46:46 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:46:46 +0300 |
commit | 30d1ef3941e0dc835be7609de5ebee66958f215a (patch) | |
tree | 49e222ea1c5804306084bb3ae065bb702625360f /contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/http/HttpClient.cpp | |
parent | 87f3eb38999df2d3c1cb77f8ffb9c52ec9c516fb (diff) | |
download | ydb-30d1ef3941e0dc835be7609de5ebee66958f215a.tar.gz |
Restoring authorship annotation for <nalpp@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/http/HttpClient.cpp')
-rw-r--r-- | contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/http/HttpClient.cpp | 84 |
1 files changed, 42 insertions, 42 deletions
diff --git a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/http/HttpClient.cpp b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/http/HttpClient.cpp index 91a802c170..8542023393 100644 --- a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/http/HttpClient.cpp +++ b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/http/HttpClient.cpp @@ -2,48 +2,48 @@ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. * SPDX-License-Identifier: Apache-2.0. */ - -#include <aws/core/http/HttpClient.h> -#include <aws/core/http/HttpRequest.h> - -using namespace Aws; -using namespace Aws::Http; - -HttpClient::HttpClient() : - m_disableRequestProcessing( false ), - m_requestProcessingSignalLock(), - m_requestProcessingSignal() + +#include <aws/core/http/HttpClient.h> +#include <aws/core/http/HttpRequest.h> + +using namespace Aws; +using namespace Aws::Http; + +HttpClient::HttpClient() : + m_disableRequestProcessing( false ), + m_requestProcessingSignalLock(), + m_requestProcessingSignal() +{ +} + +void HttpClient::DisableRequestProcessing() { -} - -void HttpClient::DisableRequestProcessing() -{ - m_disableRequestProcessing = true; - m_requestProcessingSignal.notify_all(); -} - -void HttpClient::EnableRequestProcessing() -{ - m_disableRequestProcessing = false; -} - -bool HttpClient::IsRequestProcessingEnabled() const -{ - return m_disableRequestProcessing.load() == false; -} - -void HttpClient::RetryRequestSleep(std::chrono::milliseconds sleepTime) + m_disableRequestProcessing = true; + m_requestProcessingSignal.notify_all(); +} + +void HttpClient::EnableRequestProcessing() { - std::unique_lock< std::mutex > signalLocker(m_requestProcessingSignalLock); - m_requestProcessingSignal.wait_for(signalLocker, sleepTime, [this](){ return m_disableRequestProcessing.load() == true; }); -} - -bool HttpClient::ContinueRequest(const Aws::Http::HttpRequest& request) const + m_disableRequestProcessing = false; +} + +bool HttpClient::IsRequestProcessingEnabled() const { - if (request.GetContinueRequestHandler()) - { - return request.GetContinueRequestHandler()(&request); - } - - return true; -} + return m_disableRequestProcessing.load() == false; +} + +void HttpClient::RetryRequestSleep(std::chrono::milliseconds sleepTime) +{ + std::unique_lock< std::mutex > signalLocker(m_requestProcessingSignalLock); + m_requestProcessingSignal.wait_for(signalLocker, sleepTime, [this](){ return m_disableRequestProcessing.load() == true; }); +} + +bool HttpClient::ContinueRequest(const Aws::Http::HttpRequest& request) const +{ + if (request.GetContinueRequestHandler()) + { + return request.GetContinueRequestHandler()(&request); + } + + return true; +} |