CurlHandleContainer.h

Go to the documentation of this file.

/*
  * Copyright 2010-2015 Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * 
  * Licensed under the Apache License, Version 2.0 (the "License").
  * You may not use this file except in compliance with the License.
  * A copy of the License is located at
  * 
  *  http://aws.amazon.com/apache2.0
  * 
  * or in the "license" file accompanying this file. This file is distributed
  * on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either
  * express or implied. See the License for the specific language governing
  * permissions and limitations under the License.
  */

#pragma once

#include <aws/core/utils/memory/stl/AWSStack.h>

#include <utility>
#include <mutex>
#include <condition_variable>
#include <curl/curl.h>

namespace Aws
{
namespace Http
{

class CurlHandleContainer
{
public:
    CurlHandleContainer(unsigned maxSize = 50, long requestTimeout = 3000, long connectTimeout = 1000);
    ~CurlHandleContainer();

    CURL* AcquireCurlHandle();
    void ReleaseCurlHandle(CURL* handle);

private:
    CurlHandleContainer(const CurlHandleContainer&) = delete;
    const CurlHandleContainer& operator = (const CurlHandleContainer&) = delete;
    CurlHandleContainer(const CurlHandleContainer&&) = delete;
    const CurlHandleContainer& operator = (const CurlHandleContainer&&) = delete;

    bool CheckAndGrowPool();
    void SetDefaultOptionsOnHandle(void* handle);

    Aws::Stack<CURL*> m_handleContainer;
    std::mutex m_handleContainerMutex;
    std::condition_variable m_conditionVariable;
    unsigned m_maxPoolSize;
    unsigned long m_requestTimeout;
    unsigned long m_connectTimeout;
    unsigned m_poolSize;
};

} // namespace Http
} // namespace Aws