Lines Matching refs:nti
212 NewThreadInfo* nti = (NewThreadInfo*) cookie;
215 // Wait for nti->rss to be non-NULL, indicating some of this
217 pthread_mutex_lock(&nti->mu);
218 while (nti->rss == NULL) {
219 pthread_cond_wait(&nti->cv, &nti->mu);
221 pthread_mutex_unlock(&nti->mu);
223 // At this point nti->rss is set, and we own it. The main
224 // thread is waiting for it to disappear from nti.
225 ssize_t written = RangeSinkWrite(data, size, nti->rss);
229 if (nti->rss->p_block == nti->rss->tgt->count) {
232 pthread_mutex_lock(&nti->mu);
233 nti->rss = NULL;
234 pthread_cond_broadcast(&nti->cv);
235 pthread_mutex_unlock(&nti->mu);
243 NewThreadInfo* nti = (NewThreadInfo*) cookie;
244 mzProcessZipEntryContents(nti->za, nti->entry, receive_new_data, nti);
342 NewThreadInfo nti;
343 nti.za = za;
344 nti.entry = new_entry;
345 nti.rss = NULL;
346 pthread_mutex_init(&nti.mu, NULL);
347 pthread_cond_init(&nti.cv, NULL);
352 pthread_create(&new_data_thread, &attr, unzip_new_data, &nti);
475 pthread_mutex_lock(&nti.mu);
476 nti.rss = &rss;
477 pthread_cond_broadcast(&nti.cv);
478 while (nti.rss) {
479 pthread_cond_wait(&nti.cv, &nti.mu);
481 pthread_mutex_unlock(&nti.mu);
