Searched refs:nti (Results 1 – 1 of 1) sorted by relevance
358 NewThreadInfo* nti = static_cast<NewThreadInfo*>(cookie); in receive_new_data() local362 pthread_mutex_lock(&nti->mu); in receive_new_data()363 while (nti->writer == nullptr) { in receive_new_data()365 if (!nti->receiver_available) { in receive_new_data()366 pthread_mutex_unlock(&nti->mu); in receive_new_data()369 pthread_cond_wait(&nti->cv, &nti->mu); in receive_new_data()371 pthread_mutex_unlock(&nti->mu); in receive_new_data()375 size_t write_now = std::min(size, nti->writer->AvailableSpace()); in receive_new_data()376 if (nti->writer->Write(data, write_now) != write_now) { in receive_new_data()384 if (nti->writer->Finished()) { in receive_new_data()[all …]