Searched refs:nti (Results 1 – 1 of 1) sorted by relevance
256 NewThreadInfo* nti = (NewThreadInfo*) cookie; in receive_new_data() local261 pthread_mutex_lock(&nti->mu); in receive_new_data()262 while (nti->rss == NULL) { in receive_new_data()263 pthread_cond_wait(&nti->cv, &nti->mu); in receive_new_data()265 pthread_mutex_unlock(&nti->mu); in receive_new_data()269 ssize_t written = RangeSinkWrite(data, size, nti->rss); in receive_new_data()273 if (nti->rss->p_block == nti->rss->tgt->count) { in receive_new_data()276 pthread_mutex_lock(&nti->mu); in receive_new_data()277 nti->rss = NULL; in receive_new_data()278 pthread_cond_broadcast(&nti->cv); in receive_new_data()[all …]