audacity::cloud::audiocom::sync::DataUploader Class Reference

#include <DataUploader.h>

Collaboration diagram for audacity::cloud::audiocom::sync::DataUploader:

Classes
struct	UploadOperation

Public Member Functions
void	Upload (CancellationContextPtr cancellationContex, const ServiceConfig &config, const UploadUrls &target, std::vector< uint8_t > data, std::function< void(ResponseResult)> callback, std::function< void(double)> progressCallback={})
void	Upload (CancellationContextPtr cancellationContex, const ServiceConfig &config, const UploadUrls &target, std::string filePath, std::function< void(ResponseResult)> callback, std::function< void(double)> progressCallback={})

Static Public Member Functions
static DataUploader &	Get ()

Private Types
using	ResponsesList = std::vector< std::shared_ptr< UploadOperation > >

Private Member Functions
	DataUploader ()=default
	~DataUploader ()
	DataUploader (const DataUploader &)=delete
	DataUploader (DataUploader &&)=delete
DataUploader &	operator= (const DataUploader &)=delete
DataUploader &	operator= (DataUploader &&)=delete
void	RemoveResponse (UploadOperation &response)

Private Attributes
std::mutex	mResponseMutex
ResponsesList	mResponses

Detailed Description

Definition at line 34 of file DataUploader.h.

Member Typedef Documentation

ResponsesList

using audacity::cloud::audiocom::sync::DataUploader::ResponsesList = std::vector<std::shared_ptr<UploadOperation> >

private

Definition at line 66 of file DataUploader.h.

Constructor & Destructor Documentation

DataUploader() [1/3]

audacity::cloud::audiocom::sync::DataUploader::DataUploader ( )

privatedefault

~DataUploader()

audacity::cloud::audiocom::sync::DataUploader::~DataUploader ( )

private

Definition at line 205 of file DataUploader.cpp.

{
}

DataUploader() [2/3]

audacity::cloud::audiocom::sync::DataUploader::DataUploader ( const DataUploader &  )

privatedelete

DataUploader() [3/3]

audacity::cloud::audiocom::sync::DataUploader::DataUploader ( DataUploader &&  )

privatedelete

Member Function Documentation

Get()

DataUploader & audacity::cloud::audiocom::sync::DataUploader::Get ( )

static

Definition at line 209 of file DataUploader.cpp.

{
   static DataUploader instance;
   return instance;
}

Referenced by audacity::cloud::audiocom::sync::MissingBlocksUploader::ConsumeBlock(), audacity::cloud::audiocom::sync::LocalProjectSnapshot::OnSnapshotCreated(), audacity::cloud::audiocom::sync::MixdownUploader::UploadMixdown(), and audacity::cloud::audiocom::sync::anonymous_namespace{ResumedSnaphotUploadOperation.cpp}::ResumedSnaphotUploadOperation::UploadSnapshot().

Here is the caller graph for this function:

operator=() [1/2]

DataUploader & audacity::cloud::audiocom::sync::DataUploader::operator= ( const DataUploader &  )

privatedelete

operator=() [2/2]

DataUploader & audacity::cloud::audiocom::sync::DataUploader::operator= ( DataUploader &&  )

privatedelete

RemoveResponse()

void audacity::cloud::audiocom::sync::DataUploader::RemoveResponse ( UploadOperation &  response )

private

Definition at line 275 of file DataUploader.cpp.

{
   auto lock = std::lock_guard { mResponseMutex };
 
   mResponses.erase(
      std::remove_if(
         mResponses.begin(), mResponses.end(),
         [&response](const auto& item) { return item.get() == &response; }),
      mResponses.end());
}

References mResponseMutex, and mResponses.

Referenced by audacity::cloud::audiocom::sync::DataUploader::UploadOperation::CleanUp().

Here is the caller graph for this function:

Upload() [1/2]

void audacity::cloud::audiocom::sync::DataUploader::Upload	(	CancellationContextPtr	cancellationContex,
		const ServiceConfig &	config,
		const UploadUrls &	target,
		std::string	filePath,
		std::function< void(ResponseResult)>	callback,
		std::function< void(double)>	progressCallback = {}
	)

Definition at line 240 of file DataUploader.cpp.

{
   if (!callback)
      callback = [](auto...) {};
 
   if (!progressCallback)
      progressCallback = [](auto...) { return true; };
 
   if (!cancellationContex)
      cancellationContex = concurrency::CancellationContext::Create();
 
   if (!wxFileExists(audacity::ToWXString(filePath)))
   {
      if (callback)
         callback(ResponseResult {
            SyncResultCode::UnknownError,
            audacity::ToUTF8(XO("File not found").Translation()) });
 
      return;
   }
 
   auto lock = std::lock_guard { mResponseMutex };
 
   mResponses.emplace_back(std::make_shared<UploadOperation>(
      *this, cancellationContex, target, std::move(filePath),
      audacity::network_manager::common_content_types::ApplicationXOctetStream,
      std::move(callback), std::move(progressCallback)));
 
   mResponses.back()->PerformUpload(RetriesCount);
}

References audacity::network_manager::common_content_types::ApplicationXOctetStream, audacity::concurrency::CancellationContext::Create(), mResponseMutex, mResponses, audacity::cloud::audiocom::sync::RetriesCount, audacity::ToUTF8(), audacity::ToWXString(), audacity::cloud::audiocom::UnknownError, and XO().

Here is the call graph for this function:

Upload() [2/2]

void audacity::cloud::audiocom::sync::DataUploader::Upload	(	CancellationContextPtr	cancellationContex,
		const ServiceConfig &	config,
		const UploadUrls &	target,
		std::vector< uint8_t >	data,
		std::function< void(ResponseResult)>	callback,
		std::function< void(double)>	progressCallback = {}
	)

Definition at line 215 of file DataUploader.cpp.

{
   if (!callback)
      callback = [](auto...) {};
 
   if (!progressCallback)
      progressCallback = [](auto...) { return true; };
 
   if (!cancellationContex)
      cancellationContex = concurrency::CancellationContext::Create();
 
   auto lock = std::lock_guard { mResponseMutex };
 
   mResponses.emplace_back(std::make_unique<UploadOperation>(
      *this, cancellationContex, target, std::move(data),
      audacity::network_manager::common_content_types::ApplicationXOctetStream,
      std::move(callback), std::move(progressCallback)));
 
   mResponses.back()->PerformUpload(RetriesCount);
}

References audacity::network_manager::common_content_types::ApplicationXOctetStream, audacity::concurrency::CancellationContext::Create(), mResponseMutex, mResponses, and audacity::cloud::audiocom::sync::RetriesCount.

Referenced by audacity::cloud::audiocom::sync::MissingBlocksUploader::ConsumeBlock(), audacity::cloud::audiocom::sync::LocalProjectSnapshot::OnSnapshotCreated(), audacity::cloud::audiocom::sync::MixdownUploader::UploadMixdown(), and audacity::cloud::audiocom::sync::anonymous_namespace{ResumedSnaphotUploadOperation.cpp}::ResumedSnaphotUploadOperation::UploadSnapshot().

Here is the call graph for this function:

Here is the caller graph for this function:

Member Data Documentation

mResponseMutex

std::mutex audacity::cloud::audiocom::sync::DataUploader::mResponseMutex

private

Definition at line 64 of file DataUploader.h.

Referenced by RemoveResponse(), and Upload().

mResponses

ResponsesList audacity::cloud::audiocom::sync::DataUploader::mResponses

private

Definition at line 67 of file DataUploader.h.

Referenced by RemoveResponse(), and Upload().

---

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

• DataUploader.h
• DataUploader.cpp