Searched refs:nti (Results 1 – 1 of 1) sorted by relevance
278 NewThreadInfo* nti = static_cast<NewThreadInfo*>(cookie); in receive_new_data() local282 pthread_mutex_lock(&nti->mu); in receive_new_data()283 while (nti->writer == nullptr) { in receive_new_data()284 pthread_cond_wait(&nti->cv, &nti->mu); in receive_new_data()286 pthread_mutex_unlock(&nti->mu); in receive_new_data()290 size_t write_now = std::min(size, nti->writer->AvailableSpace()); in receive_new_data()291 if (nti->writer->Write(data, write_now) != write_now) { in receive_new_data()299 if (nti->writer->Finished()) { in receive_new_data()302 pthread_mutex_lock(&nti->mu); in receive_new_data()303 nti->writer = nullptr; in receive_new_data()[all …]