354   std::unique_ptr<RangeSinkWriter> writer;  member
368     while (nti->writer == nullptr) {  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()
393       nti->writer = nullptr;  in receive_new_data()
408     while (nti->writer == nullptr) {  in receive_brotli_new_data()
421     size_t buffer_size = std::min<size_t>(32768, nti->writer->AvailableSpace());  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()
457       nti->writer = nullptr;  in receive_brotli_new_data()
475   if (nti->writer != nullptr) {  in unzip_new_data()
1333     params.nti.writer = std::make_unique<RangeSinkWriter>(params.fd, tgt);  in PerformCommandNew()
1336     while (params.nti.writer != nullptr) {  in PerformCommandNew()
1338         LOG(ERROR) << "missing " << (tgt.blocks() * BLOCKSIZE - params.nti.writer->BytesWritten())  in PerformCommandNew()
1398       RangeSinkWriter writer(params.fd, tgt);  in PerformCommandDiff()  local
1401                             std::bind(&RangeSinkWriter::Write, &writer, std::placeholders::_1,  in PerformCommandDiff()
1410                              std::bind(&RangeSinkWriter::Write, &writer, std::placeholders::_1,  in PerformCommandDiff()
1419       if (!writer.Finished()) {  in PerformCommandDiff()
1421                    << writer.AvailableSpace() << " bytes";  in PerformCommandDiff()