Lines Matching refs:writerThreadInfo
48 auto writerThreadInfo = params.GetTransferParams()->writerThreadInfo.get();
49 pthread_mutex_lock(&writerThreadInfo->mutex);
50 writerThreadInfo->writer = std::make_unique<BlockWriter>(params.GetFileDescriptor(), bs);
51 pthread_cond_broadcast(&writerThreadInfo->cond);
52 while (writerThreadInfo->writer != nullptr) {
54 if (!writerThreadInfo->readyToWrite) {
56 writerThreadInfo->writer->GetTotalWritten() << " bytes lost";
57 pthread_mutex_unlock(&writerThreadInfo->mutex);
58 writerThreadInfo->writer.reset();
59 writerThreadInfo->writer = nullptr;
62 LOG(DEBUG) << "Writer already written " << writerThreadInfo->writer->GetTotalWritten() << " byte(s)";
63 pthread_cond_wait(&writerThreadInfo->cond, &writerThreadInfo->mutex);
65 pthread_mutex_unlock(&writerThreadInfo->mutex);
67 writerThreadInfo->writer.reset();