audacity::network_manager::CurlResponseFactory Class Reference

#include <CurlResponseFactory.h>

Inheritance diagram for audacity::network_manager::CurlResponseFactory:

Collaboration diagram for audacity::network_manager::CurlResponseFactory:

Public Member Functions
	CurlResponseFactory ()
void	setProxy (const std::string &proxy) override
ResponsePtr	performRequest (RequestVerb verb, const Request &request) override
ResponsePtr	performRequest (RequestVerb verb, const Request &request, const void *data, size_t size) override
ResponsePtr	performRequest (RequestVerb verb, const Request &request, std::unique_ptr< MultipartData > form) override
void	terminate () override
Public Member Functions inherited from audacity::network_manager::IResponseFactory
virtual	~IResponseFactory ()=default
virtual void	setProxy (const std::string &proxy)=0
virtual ResponsePtr	performRequest (RequestVerb verb, const Request &request)=0
virtual ResponsePtr	performRequest (RequestVerb verb, const Request &request, const void *data, size_t size)=0
virtual ResponsePtr	performRequest (RequestVerb verb, const Request &request, std::unique_ptr< MultipartData > form)=0
virtual void	terminate ()=0

Private Attributes
std::unique_ptr< CurlHandleManager >	mHandleManager { std::make_unique<CurlHandleManager> () }
std::unique_ptr< ThreadPool >	mThreadPool

Detailed Description

Definition at line 28 of file CurlResponseFactory.h.

Constructor & Destructor Documentation

CurlResponseFactory()

audacity::network_manager::CurlResponseFactory::CurlResponseFactory

(

)

Definition at line 25 of file CurlResponseFactory.cpp.

    : mThreadPool (std::make_unique<ThreadPool>(
        std::max (
            MIN_CURL_THREADS, 
            std::thread::hardware_concurrency ()
        )))
{
 
}

Member Function Documentation

performRequest() [1/3]

ResponsePtr audacity::network_manager::CurlResponseFactory::performRequest ( RequestVerb  verb, const Request &  request  )

overridevirtual

Implements audacity::network_manager::IResponseFactory.

Definition at line 40 of file CurlResponseFactory.cpp.

{
    return performRequest (verb, request, nullptr, 0);
}

References performRequest().

Referenced by performRequest().

Here is the call graph for this function:

Here is the caller graph for this function:

performRequest() [2/3]

ResponsePtr audacity::network_manager::CurlResponseFactory::performRequest ( RequestVerb  verb, const Request &  request, const void *  data, size_t  size  )

overridevirtual

Implements audacity::network_manager::IResponseFactory.

Definition at line 45 of file CurlResponseFactory.cpp.

{
    if (!mThreadPool)
        return {};
 
    std::shared_ptr<CurlResponse> response = std::make_shared<CurlResponse> (
        verb, request, mHandleManager.get ()
    );
 
    std::vector<uint8_t> buffer;
 
    if (data != nullptr && size != 0)
    {
        const uint8_t* start = static_cast<const uint8_t*>(data);
        const uint8_t* end = static_cast<const uint8_t*>(data) + size;
 
        buffer.insert (buffer.begin (), start, end);
    }
 
    mThreadPool->enqueue ([response, dataBuffer = std::move (buffer)]() {
        if (!dataBuffer.empty())
            response->setPayload (dataBuffer.data (), dataBuffer.size ());
        
        response->perform ();
    });
 
    return response;
}

References PackedArray::end(), mHandleManager, mThreadPool, and size.

Here is the call graph for this function:

performRequest() [3/3]

ResponsePtr audacity::network_manager::CurlResponseFactory::performRequest ( RequestVerb  verb, const Request &  request, std::unique_ptr< MultipartData >  form  )

overridevirtual

Implements audacity::network_manager::IResponseFactory.

Definition at line 74 of file CurlResponseFactory.cpp.

{
   if (!mThreadPool)
      return {};
 
   std::shared_ptr<CurlResponse> response =
      std::make_shared<CurlResponse>(verb, request, mHandleManager.get());
 
 
   mThreadPool->enqueue(
      [response, rawForm = form.release()]() mutable
      {
         if (rawForm != nullptr && !rawForm->IsEmpty())
            response->setForm(std::unique_ptr<MultipartData>(rawForm));
 
         response->perform();
      });
 
   return response;
}

References mHandleManager, and mThreadPool.

setProxy()

void audacity::network_manager::CurlResponseFactory::setProxy ( const std::string &  proxy )

overridevirtual

Implements audacity::network_manager::IResponseFactory.

Definition at line 35 of file CurlResponseFactory.cpp.

{
    mHandleManager->setProxy (proxy);
}

References mHandleManager.

terminate()

void audacity::network_manager::CurlResponseFactory::terminate ( )

overridevirtual

Implements audacity::network_manager::IResponseFactory.

Definition at line 97 of file CurlResponseFactory.cpp.

{
    mThreadPool.reset ();
    mHandleManager.reset ();
}

References mHandleManager, and mThreadPool.

Member Data Documentation

mHandleManager

std::unique_ptr<CurlHandleManager> audacity::network_manager::CurlResponseFactory::mHandleManager { std::make_unique<CurlHandleManager> () }

private

Definition at line 42 of file CurlResponseFactory.h.

Referenced by performRequest(), setProxy(), and terminate().

mThreadPool

std::unique_ptr<ThreadPool> audacity::network_manager::CurlResponseFactory::mThreadPool

private

Definition at line 43 of file CurlResponseFactory.h.

Referenced by performRequest(), and terminate().

---

The documentation for this class was generated from the following files:

• CurlResponseFactory.h
• CurlResponseFactory.cpp