Lines Matching refs:writerThreadInfo

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