Lines Matching refs:writerThreadInfo
98 WriterThreadInfo *info = tm->GetTransferParams()->writerThreadInfo.get();
192 auto writerThreadInfo = transferParams->writerThreadInfo.get();
208 pthread_mutex_lock(&writerThreadInfo->mutex);
209 if (writerThreadInfo->readyToWrite) {
213 writerThreadInfo->readyToWrite = false;
214 pthread_cond_broadcast(&writerThreadInfo->cond);
215 pthread_mutex_unlock(&writerThreadInfo->mutex);
231 auto writerThreadInfo = transferParams->writerThreadInfo.get();
232 writerThreadInfo->readyToWrite = true;
233 pthread_mutex_init(&writerThreadInfo->mutex, nullptr);
234 pthread_cond_init(&writerThreadInfo->cond, nullptr);
238 writerThreadInfo->newPatch = infos.newDataName;