audacity::cloud::audiocom::sync::BlockHasher::Workers Class Reference

Collaboration diagram for audacity::cloud::audiocom::sync::BlockHasher::Workers:

Public Types
using	SampleData = std::vector< std::remove_pointer_t< samplePtr > >

Public Member Functions
	Workers (BlockHashCache &cache, const std::vector< LockedBlock > blocks, std::function< void()> onComplete)
bool	IsReady () const
std::pair< std::string, bool >	ComputeHash (SampleData &sampleData, const LockedBlock &block) const
void	NotifyReady ()
std::vector< std::pair< int64_t, std::string > >	TakeResult ()

Private Types
using	Result = std::unordered_map< int64_t, std::pair< std::string, bool > >

Private Attributes
const size_t	mThreadsCount
BlockHashCache &	mCache
std::vector< std::future< Result > >	mResults
std::future< void >	mWaiter
std::function< void()>	mOnComplete

Detailed Description

Definition at line 25 of file BlockHasher.cpp.

Member Typedef Documentation

Result

using audacity::cloud::audiocom::sync::BlockHasher::Workers::Result = std::unordered_map<int64_t, std::pair<std::string, bool> >

private

Definition at line 150 of file BlockHasher.cpp.

SampleData

using audacity::cloud::audiocom::sync::BlockHasher::Workers::SampleData = std::vector<std::remove_pointer_t<samplePtr> >

Definition at line 28 of file BlockHasher.cpp.

Constructor & Destructor Documentation

Workers()

audacity::cloud::audiocom::sync::BlockHasher::Workers::Workers ( BlockHashCache &  cache, const std::vector< LockedBlock >  blocks, std::function< void()>  onComplete  )

inlineexplicit

Definition at line 30 of file BlockHasher.cpp.

       : mThreadsCount { std::max(1u, std::thread::hardware_concurrency() / 2) }
       , mCache { cache }
       , mOnComplete { std::move(onComplete) }
   {
      mResults.reserve(mThreadsCount);
 
      const auto blocksCount = blocks.size();
      // Try to add no more that 1 extra block per thread
      const size_t blockPerThread = blocks.size() / mThreadsCount + 1;
 
      for (size_t i = 0; i < mThreadsCount; ++i)
      {
         const size_t startIndex = i;
 
         if (startIndex >= blocks.size())
            break;
 
         std::vector<LockedBlock> threadBlocks;
         threadBlocks.reserve(blockPerThread);
 
         for (size_t j = startIndex; j < blocksCount; j += mThreadsCount)
            threadBlocks.emplace_back(blocks[j]);
 
         mResults.emplace_back(std::async(
            std::launch::async,
            [this, threadBlocks = std::move(threadBlocks)]()
            {
               Result result;
               SampleData sampleData;
 
               for (const auto& block : threadBlocks)
                  result.emplace(block.Id, ComputeHash(sampleData, block));
 
               return result;
            }));
      }
 
      mWaiter = std::async(
         std::launch::async,
         [this]
         {
            for (auto& fut : mResults)
               fut.wait();
 
            NotifyReady();
         });
   }

References ComputeHash(), mResults, mThreadsCount, mWaiter, and NotifyReady().

Here is the call graph for this function:

Member Function Documentation

ComputeHash()

std::pair< std::string, bool > audacity::cloud::audiocom::sync::BlockHasher::Workers::ComputeHash ( SampleData &  sampleData, const LockedBlock &  block  ) const

inline

Definition at line 93 of file BlockHasher.cpp.

   {
      std::string hash;
 
      if (mCache.GetHash(block.Id, hash))
         return { hash, false };
 
      const auto sampleFormat = block.Format;
      const auto sampleCount  = block.Block->GetSampleCount();
      const auto dataSize     = sampleCount * SAMPLE_SIZE(sampleFormat);
 
      sampleData.resize(dataSize);
 
      const size_t samplesRead = block.Block->GetSamples(
         sampleData.data(), sampleFormat, 0, sampleCount, false);
 
      if (samplesRead != sampleCount)
         return { {}, false };
 
      hash = crypto::sha256(sampleData);
 
      return { hash, true };
   }

References audacity::cloud::audiocom::sync::LockedBlock::Block, audacity::cloud::audiocom::sync::LockedBlock::Format, audacity::cloud::audiocom::sync::BlockHashCache::GetHash(), audacity::cloud::audiocom::sync::LockedBlock::Id, mCache, SAMPLE_SIZE, and crypto::sha256().

Referenced by Workers().

Here is the call graph for this function:

Here is the caller graph for this function:

IsReady()

bool audacity::cloud::audiocom::sync::BlockHasher::Workers::IsReady ( ) const

inline

Definition at line 81 of file BlockHasher.cpp.

   {
      return std::all_of(
         mResults.begin(), mResults.end(),
         [](const auto& result)
         {
            return result.wait_for(std::chrono::seconds(0)) ==
                   std::future_status::ready;
         });
   }

References mResults.

NotifyReady()

void audacity::cloud::audiocom::sync::BlockHasher::Workers::NotifyReady ( )

inline

Definition at line 117 of file BlockHasher.cpp.

   {
      if (mOnComplete)
         mOnComplete();
   }

References mOnComplete.

Referenced by Workers().

Here is the caller graph for this function:

TakeResult()

std::vector< std::pair< int64_t, std::string > > audacity::cloud::audiocom::sync::BlockHasher::Workers::TakeResult ( )

inline

Definition at line 123 of file BlockHasher.cpp.

   {
      std::vector<std::pair<int64_t, std::string>> result;
 
      for (auto& fut : mResults)
      {
         const auto& threadResult = fut.get();
 
         for (const auto& [id, hash] : threadResult)
         {
            result.emplace_back(std::make_pair(id, hash.first));
 
            if (hash.second)
               mCache.UpdateHash(id, hash.first);
         }
      }
 
      mResults.clear();
 
      return result;
   }

References mCache, mResults, and audacity::cloud::audiocom::sync::BlockHashCache::UpdateHash().

Here is the call graph for this function:

Member Data Documentation

mCache

BlockHashCache& audacity::cloud::audiocom::sync::BlockHasher::Workers::mCache

private

Definition at line 148 of file BlockHasher.cpp.

Referenced by ComputeHash(), and TakeResult().

mOnComplete

std::function<void()> audacity::cloud::audiocom::sync::BlockHasher::Workers::mOnComplete

private

Definition at line 154 of file BlockHasher.cpp.

Referenced by NotifyReady().

mResults

std::vector<std::future<Result> > audacity::cloud::audiocom::sync::BlockHasher::Workers::mResults

private

Definition at line 151 of file BlockHasher.cpp.

Referenced by IsReady(), TakeResult(), and Workers().

mThreadsCount

const size_t audacity::cloud::audiocom::sync::BlockHasher::Workers::mThreadsCount

private

Definition at line 146 of file BlockHasher.cpp.

Referenced by Workers().

mWaiter

std::future<void> audacity::cloud::audiocom::sync::BlockHasher::Workers::mWaiter

private

Definition at line 152 of file BlockHasher.cpp.

Referenced by Workers().

---

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

• BlockHasher.cpp