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_;