363   NewThreadInfo* nti = static_cast<NewThreadInfo*>(cookie);  in receive_new_data()  local
367     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()
392       pthread_mutex_lock(&nti->mu);  in receive_new_data()
393       nti->writer = nullptr;  in receive_new_data()
394       pthread_cond_broadcast(&nti->cv);  in receive_new_data()
395       pthread_mutex_unlock(&nti->mu);  in receive_new_data()
403   NewThreadInfo* nti = static_cast<NewThreadInfo*>(cookie);  in receive_brotli_new_data()  local
405   while (size > 0 || BrotliDecoderHasMoreOutput(nti->brotli_decoder_state)) {  in receive_brotli_new_data()
407     pthread_mutex_lock(&nti->mu);  in receive_brotli_new_data()
408     while (nti->writer == nullptr) {  in receive_brotli_new_data()
410       if (!nti->receiver_available) {  in receive_brotli_new_data()
411         pthread_mutex_unlock(&nti->mu);  in receive_brotli_new_data()
414       pthread_cond_wait(&nti->cv, &nti->mu);  in receive_brotli_new_data()
416     pthread_mutex_unlock(&nti->mu);  in receive_brotli_new_data()
421     size_t buffer_size = std::min<size_t>(32768, nti->writer->AvailableSpace());  in receive_brotli_new_data()
433         nti->brotli_decoder_state, &available_in, &data, &available_out, &next_out, nullptr);  in receive_brotli_new_data()
437                  << BrotliDecoderErrorString(BrotliDecoderGetErrorCode(nti->brotli_decoder_state));  in receive_brotli_new_data()
445     if (nti->writer->Write(buffer, write_now) != write_now) {  in receive_brotli_new_data()
453     if (nti->writer->Finished()) {  in receive_brotli_new_data()
456       pthread_mutex_lock(&nti->mu);  in receive_brotli_new_data()
457       nti->writer = nullptr;  in receive_brotli_new_data()
458       pthread_cond_broadcast(&nti->cv);  in receive_brotli_new_data()
459       pthread_mutex_unlock(&nti->mu);  in receive_brotli_new_data()
467   NewThreadInfo* nti = static_cast<NewThreadInfo*>(cookie);  in unzip_new_data()  local
468   if (nti->brotli_compressed) {  in unzip_new_data()
469     ProcessZipEntryContents(nti->za, &nti->entry, receive_brotli_new_data, nti);  in unzip_new_data()
471     ProcessZipEntryContents(nti->za, &nti->entry, receive_new_data, nti);  in unzip_new_data()
473   pthread_mutex_lock(&nti->mu);  in unzip_new_data()
474   nti->receiver_available = false;  in unzip_new_data()
475   if (nti->writer != nullptr) {  in unzip_new_data()
476     pthread_cond_broadcast(&nti->cv);  in unzip_new_data()
478   pthread_mutex_unlock(&nti->mu);  in unzip_new_data()
543     NewThreadInfo nti;  member
1332     pthread_mutex_lock(&params.nti.mu);  in PerformCommandNew()
1333     params.nti.writer = std::make_unique<RangeSinkWriter>(params.fd, tgt);  in PerformCommandNew()
1334     pthread_cond_broadcast(&params.nti.cv);  in PerformCommandNew()
1336     while (params.nti.writer != nullptr) {  in PerformCommandNew()
1337       if (!params.nti.receiver_available) {  in PerformCommandNew()
1338         LOG(ERROR) << "missing " << (tgt.blocks() * BLOCKSIZE - params.nti.writer->BytesWritten())  in PerformCommandNew()
1340         pthread_mutex_unlock(&params.nti.mu);  in PerformCommandNew()
1343       pthread_cond_wait(&params.nti.cv, &params.nti.mu);  in PerformCommandNew()
1346     pthread_mutex_unlock(&params.nti.mu);  in PerformCommandNew()
1783     params.nti.za = za;  in PerformBlockImageUpdate()
1784     params.nti.entry = new_entry;  in PerformBlockImageUpdate()
1785     params.nti.brotli_compressed = android::base::EndsWith(new_data_fn->data, ".br");  in PerformBlockImageUpdate()
1786     if (params.nti.brotli_compressed) {  in PerformBlockImageUpdate()
1788       params.nti.brotli_decoder_state = BrotliDecoderCreateInstance(nullptr, nullptr, nullptr);  in PerformBlockImageUpdate()
1790     params.nti.receiver_available = true;  in PerformBlockImageUpdate()
1792     pthread_mutex_init(&params.nti.mu, nullptr);  in PerformBlockImageUpdate()
1793     pthread_cond_init(&params.nti.cv, nullptr);  in PerformBlockImageUpdate()
1798     int error = pthread_create(&params.thread, &attr, unzip_new_data, &params.nti);  in PerformBlockImageUpdate()
1906     pthread_mutex_lock(&params.nti.mu);  in PerformBlockImageUpdate()
1907     if (params.nti.receiver_available) {  in PerformBlockImageUpdate()
1910     params.nti.receiver_available = false;  in PerformBlockImageUpdate()
1911     pthread_cond_broadcast(&params.nti.cv);  in PerformBlockImageUpdate()
1912     pthread_mutex_unlock(&params.nti.mu);  in PerformBlockImageUpdate()
1946     pthread_mutex_destroy(&params.nti.mu);  in PerformBlockImageUpdate()
1947     pthread_cond_destroy(&params.nti.cv);  in PerformBlockImageUpdate()
1958   if (params.nti.brotli_decoder_state != nullptr) {  in PerformBlockImageUpdate()
1959     BrotliDecoderDestroyInstance(params.nti.brotli_decoder_state);  in PerformBlockImageUpdate()