CurlHandleContainer.h

 
#pragma once
 
#include <aws/core/utils/ResourceManager.h>
#include <aws/core/http/Version.h>
 
#include <utility>
#include <curl/curl.h>
 
namespace Aws
{
namespace Http
{
 
class CurlHandleContainer
{
public:
    CurlHandleContainer(unsigned maxSize = 50, long httpRequestTimeout = 0, long connectTimeout = 1000, bool tcpKeepAlive = true,
                        unsigned long tcpKeepAliveIntervalMs = 30000, long lowSpeedTime = 3000, unsigned long lowSpeedLimit = 1,
                        Version version = Version::HTTP_VERSION_2TLS);
    ~CurlHandleContainer();
 
    CURL* AcquireCurlHandle();
    void ReleaseCurlHandle(CURL* handle);
 
    void DestroyCurlHandle(CURL* handle);
 
private:
    CurlHandleContainer(const CurlHandleContainer&) = delete;
    const CurlHandleContainer& operator = (const CurlHandleContainer&) = delete;
    CurlHandleContainer(const CurlHandleContainer&&) = delete;
    const CurlHandleContainer& operator = (const CurlHandleContainer&&) = delete;
 
    CURL* CreateCurlHandleInPool();
    bool CheckAndGrowPool();
    void SetDefaultOptionsOnHandle(CURL* handle);
    static long ConvertHttpVersion(Version version);
 
    Aws::Utils::ExclusiveOwnershipResourceManager<CURL*> m_handleContainer;
    unsigned m_maxPoolSize;
    unsigned long m_httpRequestTimeout;
    unsigned long m_connectTimeout;
    bool m_enableTcpKeepAlive;
    unsigned long m_tcpKeepAliveIntervalMs;
    unsigned long m_lowSpeedTime;
    unsigned long m_lowSpeedLimit;
    unsigned m_poolSize;
    std::mutex m_containerLock;
    Version m_version;
};
 
} // namespace Http
} // namespace Aws