Searched refs:nti (Results 1 – 1 of 1) sorted by relevance
363 NewThreadInfo* nti = static_cast<NewThreadInfo*>(cookie); in receive_new_data() local367 pthread_mutex_lock(&nti->mu); in receive_new_data()368 while (nti->writer == nullptr) { in receive_new_data()370 if (!nti->receiver_available) { in receive_new_data()371 pthread_mutex_unlock(&nti->mu); in receive_new_data()374 pthread_cond_wait(&nti->cv, &nti->mu); in receive_new_data()376 pthread_mutex_unlock(&nti->mu); in receive_new_data()380 size_t write_now = std::min(size, nti->writer->AvailableSpace()); in receive_new_data()381 if (nti->writer->Write(data, write_now) != write_now) { in receive_new_data()389 if (nti->writer->Finished()) { in receive_new_data()[all …]