349   std::unique_ptr<RangeSinkWriter> writer;  member
363     while (nti->writer == nullptr) {  in receive_new_data()
375     size_t write_now = std::min(size, nti->writer->AvailableSpace());  in receive_new_data()
376     if (nti->writer->Write(data, write_now) != write_now) {  in receive_new_data()
384     if (nti->writer->Finished()) {  in receive_new_data()
388       nti->writer = nullptr;  in receive_new_data()
403     while (nti->writer == nullptr) {  in receive_brotli_new_data()
416     size_t buffer_size = std::min<size_t>(32768, nti->writer->AvailableSpace());  in receive_brotli_new_data()
440     if (nti->writer->Write(buffer, write_now) != write_now) {  in receive_brotli_new_data()
448     if (nti->writer->Finished()) {  in receive_brotli_new_data()
452       nti->writer = nullptr;  in receive_brotli_new_data()
470   if (nti->writer != nullptr) {  in unzip_new_data()
1328     params.nti.writer = std::make_unique<RangeSinkWriter>(params.fd, tgt);  in PerformCommandNew()
1331     while (params.nti.writer != nullptr) {  in PerformCommandNew()
1333         LOG(ERROR) << "missing " << (tgt.blocks() * BLOCKSIZE - params.nti.writer->BytesWritten())  in PerformCommandNew()
1393       RangeSinkWriter writer(params.fd, tgt);  in PerformCommandDiff()  local
1396                             std::bind(&RangeSinkWriter::Write, &writer, std::placeholders::_1,  in PerformCommandDiff()
1405                              std::bind(&RangeSinkWriter::Write, &writer, std::placeholders::_1,  in PerformCommandDiff()
1414       if (!writer.Finished()) {  in PerformCommandDiff()
1416                    << writer.AvailableSpace() << " bytes";  in PerformCommandDiff()