copyRequest::base::hashCalculator Class Reference

Collaboration diagram for copyRequest::base::hashCalculator:

Public Member Functions
	hashCalculator (blockQueue &blocksToHash, blockQueue &hashedBlocks, base *request, bool mayParallelize, exceptionList &exceptions)
	~hashCalculator () noexcept(false)
bool	joinable () const
bool	parallelized () const

Private Attributes
std::vector< std::thread >	workers
checksum::parallel *	parallelSum
blockQueue &	outputQueue

Detailed Description

Definition at line 186 of file copyRequest.h.

Constructor & Destructor Documentation

hashCalculator()

copyRequest::base::hashCalculator::hashCalculator	(	blockQueue &	blocksToHash,
		blockQueue &	hashedBlocks,
		base *	request,
		bool	mayParallelize,
		exceptionList &	exceptions
	)

Definition at line 669 of file copyRequest.cpp.

                                  :
    outputQueue(hashedBlocks) {
    if (request->checkSums.empty() || (request->state & stateBitType::append)) {
        return;
    }
    unsigned nBlocks = request->readInitialStat->size / request->memoryBlockSize;
    if (request->checkSums.size() == 1
            && request->checkSums.front()->parallelizable()
            && nSumThreads > 1
            && mayParallelize
            && nBlocks >= nSumThreads ) {
        workers.resize(std::min(nSumThreads.fGetValue(), nBlocks));
        parallelSum = dynamic_cast<checksum::parallel*>(request->checkSums.front());
        for (auto& worker : workers) {
            worker = std::thread(&copyRequest::base::hash_worker, request,
                                 parallelSum,
                                 std::ref(blocksToHash),
                                 std::ref(outputQueue),
                                 std::ref(exceptions));
        }
    } else { // use one thread to calculate all checksums
        workers.emplace_back(std::thread(&copyRequest::base::hasher, request,
                                         std::ref(blocksToHash),
                                         std::ref(outputQueue),
                                         std::ref(exceptions)));
    }
}

References copyRequest::append, copyRequest::base::checkSums, options::single< T >::fGetValue(), copyRequest::base::hash_worker(), copyRequest::base::hasher(), copyRequest::base::memoryBlockSize, copyRequest::base::nSumThreads, outputQueue, parallelSum, copyRequest::base::readInitialStat, copyRequest::base::state, and workers.

Here is the call graph for this function:

~hashCalculator()

copyRequest::base::hashCalculator::~hashCalculator ( )

noexcept

Definition at line 701 of file copyRequest.cpp.

                                                                {
    if (workers.empty()) {
        return;
    }
    for (auto& worker : workers) {
        worker.join();
    }
    if (workers.size() > 1) {
        parallelSum->parallelFinish();
    }
    outputQueue.signalDone();
}

Member Function Documentation

joinable()

bool copyRequest::base::hashCalculator::joinable

(

)

const

Definition at line 713 of file copyRequest.cpp.

                                                   {
    return ! workers.empty();
}

Referenced by copyRequest::base::doThreadedCopy().

Here is the caller graph for this function:

parallelized()

bool copyRequest::base::hashCalculator::parallelized

(

)

const

Definition at line 716 of file copyRequest.cpp.

                                                       {
    return workers.size() != 1; // we also do nothing in parallel
}

Referenced by copyRequest::base::doThreadedCopy().

Here is the caller graph for this function:

Member Data Documentation

outputQueue

blockQueue& copyRequest::base::hashCalculator::outputQueue

private

Definition at line 189 of file copyRequest.h.

Referenced by hashCalculator().

parallelSum

checksum::parallel* copyRequest::base::hashCalculator::parallelSum

private

Definition at line 188 of file copyRequest.h.

Referenced by hashCalculator().

workers

std::vector<std::thread> copyRequest::base::hashCalculator::workers

private

Definition at line 187 of file copyRequest.h.

Referenced by hashCalculator().

---

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

• src/copyRequest.h (v0.19-24-g0617ca1 with changes)
• src/copyRequest.cpp (v0.19-24-g0617ca1 with changes)