6#ifdef USERVER_TVM2_HTTP_CLIENT
7#error Use clients::Http from clients/http.hpp instead
12#include <userver/moodycamel/concurrentqueue_fwd.h>
14#include <userver/clients/dns/resolver_fwd.hpp>
15#include <userver/clients/http/config.hpp>
16#include <userver/clients/http/plugin.hpp>
17#include <userver/clients/http/request.hpp>
18#include <userver/engine/task/task_processor_fwd.hpp>
19#include <userver/rcu/rcu.hpp>
20#include <userver/utils/fast_pimpl.hpp>
21#include <userver/utils/not_null.hpp>
22#include <userver/utils/periodic_task.hpp>
23#include <userver/utils/swappingsmart.hpp>
24#include <userver/yaml_config/fwd.hpp>
26USERVER_NAMESPACE_BEGIN
29class TracingManagerBase;
35class ConnectRateLimiter;
42namespace clients::http {
47struct TestsuiteConfig;
50struct InstanceStatistics;
51class DestinationStatistics;
66 ClientSettings settings,
67 engine::TaskProcessor& fs_task_processor,
86 void SetMultiplexingEnabled(
bool enabled);
89 void SetMaxHostConnections(size_t max_host_connections);
92 PoolStatistics GetPoolStatistics()
const;
96 void SetDestinationMetricsAutoMaxSize(size_t max_size);
99 const http::DestinationStatistics& GetDestinationStatistics()
const;
102 void SetTestsuiteConfig(
const TestsuiteConfig& config);
105 void SetAllowedUrlsExtra(std::vector<std::string>&& urls);
108 void SetConfig(
const impl::Config&);
134 InstanceStatistics GetMultiStatistics(size_t n)
const;
136 size_t FindMultiIndex(
const curl::multi*)
const;
140 friend class impl::EasyWrapper;
141 void IncPending()
noexcept { ++pending_tasks_; }
142 void DecPending()
noexcept { --pending_tasks_; }
143 void PushIdleEasy(std::shared_ptr<curl::easy>&& easy)
noexcept;
145 std::shared_ptr<curl::easy> TryDequeueIdle()
noexcept;
147 std::atomic<std::size_t> pending_tasks_{0};
150 CancellationPolicy cancellation_policy_;
152 std::shared_ptr<DestinationStatistics> destination_statistics_;
153 std::unique_ptr<engine::
ev::ThreadPool> thread_pool_;
154 std::vector<Statistics> statistics_;
155 std::vector<std::unique_ptr<curl::multi>> multis_;
157 static constexpr size_t kIdleQueueSize = 616;
158 static constexpr size_t kIdleQueueAlignment = 8;
159 using IdleQueueTraits = moodycamel::ConcurrentQueueDefaultTraits;
160 using IdleQueueValue = std::shared_ptr<curl::easy>;
161 using IdleQueue = moodycamel::ConcurrentQueue<IdleQueueValue, IdleQueueTraits>;
162 utils::FastPimpl<IdleQueue, kIdleQueueSize, kIdleQueueAlignment> idle_queue_;
164 engine::TaskProcessor& fs_task_processor_;
165 std::optional<std::string> user_agent_;
166 rcu::Variable<std::string> proxy_;
169 utils::PeriodicTask easy_reinit_task_;
172 std::shared_ptr<
const TestsuiteConfig> testsuite_config_;
173 rcu::Variable<std::vector<std::string>> allowed_urls_extra_;
175 std::shared_ptr<curl::ConnectRateLimiter> connect_rate_limiter_;