Searched refs:writerThreadInfo (Results 1 – 8 of 8) sorted by relevance
48 auto writerThreadInfo = params.GetTransferParams()->writerThreadInfo.get(); in Execute() local49 pthread_mutex_lock(&writerThreadInfo->mutex); in Execute()51 pthread_cond_broadcast(&writerThreadInfo->cond); in Execute()52 while (writerThreadInfo->writer != nullptr) { in Execute()54 if (!writerThreadInfo->readyToWrite) { in Execute()57 pthread_mutex_unlock(&writerThreadInfo->mutex); in Execute()58 writerThreadInfo->writer.reset(); in Execute()59 writerThreadInfo->writer = nullptr; in Execute()63 pthread_cond_wait(&writerThreadInfo->cond, &writerThreadInfo->mutex); in Execute()65 pthread_mutex_unlock(&writerThreadInfo->mutex); in Execute()[all …]
33 transferParams_->writerThreadInfo = std::make_unique<WriterThreadInfo>(); in TransferManager()
132 auto writerThreadInfo = transferParams->writerThreadInfo.get(); in ExecuteTransferCommand() local146 pthread_mutex_lock(&writerThreadInfo->mutex); in ExecuteTransferCommand()147 if (writerThreadInfo->readyToWrite) { in ExecuteTransferCommand()151 writerThreadInfo->readyToWrite = false; in ExecuteTransferCommand()152 pthread_cond_broadcast(&writerThreadInfo->cond); in ExecuteTransferCommand()153 pthread_mutex_unlock(&writerThreadInfo->mutex); in ExecuteTransferCommand()277 auto writerThreadInfo = transferParams->writerThreadInfo.get(); in InitThread() local278 writerThreadInfo->readyToWrite = true; in InitThread()279 pthread_mutex_init(&writerThreadInfo->mutex, nullptr); in InitThread()280 pthread_cond_init(&writerThreadInfo->cond, nullptr); in InitThread()[all …]
192 auto writerThreadInfo = transferParams->writerThreadInfo.get(); in ExecuteTransferCommand() local208 pthread_mutex_lock(&writerThreadInfo->mutex); in ExecuteTransferCommand()209 if (writerThreadInfo->readyToWrite) { in ExecuteTransferCommand()213 writerThreadInfo->readyToWrite = false; in ExecuteTransferCommand()214 pthread_cond_broadcast(&writerThreadInfo->cond); in ExecuteTransferCommand()215 pthread_mutex_unlock(&writerThreadInfo->mutex); in ExecuteTransferCommand()231 auto writerThreadInfo = transferParams->writerThreadInfo.get(); in InitThread() local232 writerThreadInfo->readyToWrite = true; in InitThread()233 pthread_mutex_init(&writerThreadInfo->mutex, nullptr); in InitThread()234 pthread_cond_init(&writerThreadInfo->cond, nullptr); in InitThread()[all …]
58 transferParams->writerThreadInfo = std::make_unique<WriterThreadInfo>();76 transferParams->writerThreadInfo = std::make_unique<WriterThreadInfo>();
65 transferParams->writerThreadInfo = std::make_unique<WriterThreadInfo>();
124 transferParams->writerThreadInfo = std::make_unique<WriterThreadInfo>();
49 std::unique_ptr<WriterThreadInfo> writerThreadInfo; member