Collaboration diagram for copyRequest::base::writeActor:

[legend]

Public Member Functions
	writeActor (std::unique_ptr< outputHandler::base::writer > &writeHandle, blockQueue &blocksToWrite, blockQueue &writtenBlocks, bool mayParallelize, base *request, exceptionList &exceptions)

	~writeActor () noexcept(false)

bool	joinable () const

Private Attributes
std::vector< std::thread >	workers

blockQueue &	outputQueue

Detailed Description

Definition at line 244 of file copyRequest.h.

Constructor & Destructor Documentation

◆ writeActor()

copyRequest::base::writeActor::writeActor	(	std::unique_ptr< outputHandler::base::writer > &	writeHandle,
		blockQueue &	blocksToWrite,
		blockQueue &	writtenBlocks,
		bool	mayParallelize,
		base *	request,
		exceptionList &	exceptions
	)

Definition at line 625 of file copyRequest.cpp.

                                   :
     outputQueue(writtenBlocks) {
     if (noCopy) { // do nothing
         return;
     }
     unsigned nBlocks = request->readInitialStat->size / request->memoryBlockSize;
     if (mayParallelize
             && request->nConcurrentProcesses < nThreads / nWriteThreads + 1
             && writeHandle->parallelizable()
             && nWriteThreads > 1
             && nBlocks >= nWriteThreads) {
         workers.resize(nWriteThreads);
         for (auto& worker : workers) {
             worker = std::thread(&copyRequest::base::writeWorker, request,
                                  std::ref(writeHandle),
                                  std::ref(blocksToWrite),
                                  std::ref(writtenBlocks),
                                  std::ref(exceptions));
         }
     } else {
         workers.push_back(std::thread(&copyRequest::base::writer, request,
                                       std::ref(writeHandle),
                                       std::ref(blocksToWrite),
                                       std::ref(writtenBlocks),
                                       std::ref(exceptions)));
     }
 }

References copyRequest::base::memoryBlockSize, copyRequest::base::nConcurrentProcesses, noCopy, nThreads, copyRequest::base::nWriteThreads, ioHandle::parallelizable(), copyRequest::base::readInitialStat, workers, copyRequest::base::writer(), and copyRequest::base::writeWorker().

Here is the call graph for this function:

◆ ~writeActor()

copyRequest::base::writeActor::~writeActor ( )

noexcept

Definition at line 657 of file copyRequest.cpp.

                                                         {
     if (workers.empty()) {
         return;
     }
     for (auto& worker : workers) {
         worker.join();
     }
     outputQueue.signalDone();
 }

Member Function Documentation

◆ joinable()

bool copyRequest::base::writeActor::joinable ( ) const

Definition at line 666 of file copyRequest.cpp.

                                                {
     return !workers.empty();
 }

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

Here is the caller graph for this function:

Member Data Documentation

◆ outputQueue

blockQueue& copyRequest::base::writeActor::outputQueue

private

Definition at line 246 of file copyRequest.h.

◆ workers

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

private

Definition at line 245 of file copyRequest.h.

Referenced by writeActor().

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

Public Member Functions

Private Attributes