| /system/update_engine/payload_consumer/ |
| D | partition_writer_unittest.cc | 49 EXPECT_FALSE(writer_.source_ecc_fd_) << "source_ecc_fd_ already open."; in SetFakeECCFile()
55 writer_.source_ecc_fd_ = fake_ecc_fd_; in SetFakeECCFile()
60 return writer_.source_ecc_recovered_failures_; in GetSourceEccRecoveredFailures()
99 EXPECT_TRUE(writer_.Init(&install_plan_, true, 0)); in PerformSourceCopyOp()
100 EXPECT_TRUE(writer_.PerformSourceCopyOperation(op, &error)); in PerformSourceCopyOp()
101 writer_.CheckpointUpdateProgress(1); in PerformSourceCopyOp()
116 PartitionWriter writer_{ member in chromeos_update_engine::PartitionWriterTest
182 writer_.source_fd_ = std::make_shared<EintrSafeFileDescriptor>(); in TEST_F()
183 writer_.source_fd_->Open(source.path().c_str(), O_RDONLY); in TEST_F()
197 EXPECT_EQ(writer_.source_ecc_fd_, writer_.ChooseSourceFD(op, &error)); in TEST_F()
|
| D | snapshot_extent_writer_unittest.cc | 96 SnapshotExtentWriter writer_{&cow_writer_}; member in chromeos_update_engine::SnapshotExtentWriterTest
110 writer_.Init(extents, kBlockSize); in TEST_F()
117 writer_.Write(buf.data(), kBlockSize - 1); in TEST_F()
121 writer_.Write(buf.data() + kBlockSize - 1, 1); in TEST_F()
133 writer_.Init(extents, kBlockSize); in TEST_F()
140 writer_.Write(buf.data(), buf.size()); in TEST_F()
156 writer_.Init(extents, kBlockSize); in TEST_F()
165 writer_.Write(buf.data(), kBlockSize - 1); in TEST_F()
169 writer_.Write(buf.data() + kBlockSize - 1, 1 + kBlockSize * 2); in TEST_F()
|
| D | file_writer.h | 86 explicit ScopedFileWriterCloser(FileWriter* writer) : writer_(writer) {} in ScopedFileWriterCloser()
88 int err = writer_->Close(); in ~ScopedFileWriterCloser()
95 FileWriter* writer_;
|
| D | partition_writer.cc | 128 TEST_AND_RETURN_FALSE(writer_->Write(buf, count)); in Write()
158 writer_(std::move(writer)), in BsdiffExtentFile()
163 std::unique_ptr<ExtentWriter> writer_; member in chromeos_update_engine::BsdiffExtentFile
214 TEST_AND_RETURN_FALSE(writer_->Write(buffer, count)); in Write()
226 writer_(std::move(writer)), in PuffinExtentStream()
232 std::unique_ptr<ExtentWriter> writer_; member in chromeos_update_engine::PuffinExtentStream
|
| /system/update_engine/cros/ |
| D | download_action_chromeos.cc | 54 writer_(nullptr), in DownloadActionChromeos()
238 if (writer_ && writer_ != delta_performer_.get()) { in StartDownloading()
248 writer_ = delta_performer_.get(); in StartDownloading()
270 writer_ = delta_performer_.get(); in StartDownloading()
349 if (writer_) { in TerminateProcessing()
350 writer_->Close(); in TerminateProcessing()
351 writer_ = nullptr; in TerminateProcessing()
378 if (writer_ && !writer_->Write(bytes, length, &code_)) { in ReceivedBytes()
407 if (writer_) { in TransferComplete()
408 LOG_IF(WARNING, writer_->Close() != 0) << "Error closing the writer."; in TransferComplete()
[all …]
|
| D | download_action_chromeos.h | 67 void SetTestFileWriter(FileWriter* writer) { writer_ = writer; } in SetTestFileWriter()
133 FileWriter* writer_; variable
|
| /system/extras/simpleperf/ |
| D | cmd_merge.cpp | 137 writer_ = RecordFileWriter::CreateInstance(output_file_); in Run()
138 if (!writer_) { in Run()
144 return writer_->Close(); in Run()
277 bool MergeAttrSection() { return writer_->WriteAttrSection(readers_[0]->AttrSection()); } in MergeAttrSection()
296 bool ProcessRecord(Record* record) { return writer_->WriteRecord(*record); } in ProcessRecord()
327 if (!writer_->BeginWriteFeatures(features.size())) { in MergeFeatureSection()
336 !writer_->WriteFeature(feature, data.data(), data.size())) { in MergeFeatureSection()
347 return writer_->EndWriteFeatures(); in MergeFeatureSection()
374 return writer_->WriteBuildIdFeature(records); in WriteBuildIdFeature()
406 if (!writer_->WriteFileFeature(file_feature)) { in WriteFileFeature()
[all …]
|
| D | cmd_debug_unwind.cpp | 355 writer_.reset(new RecordFileWriter(output_filename_, out_fp_, false)); in Process()
356 if (!writer_ || !writer_->WriteAttrSection(reader_->AttrSection())) { in Process()
381 return writer_->WriteRecord(*r); in ProcessRecord()
400 if (!writer_->WriteRecord(map_record)) { in WriteMapsForSample()
410 if (!writer_->BeginWriteFeatures(reader_->FeatureSectionDescriptors().size())) { in WriteFeatureSections()
432 if (!writer_->WriteDebugUnwindFeature(feature)) { in WriteFeatureSections()
439 if (kept_binaries_.count(file_feature.path) && !writer_->WriteFileFeature(file_feature)) { in WriteFeatureSections()
451 if (!writer_->WriteBuildIdFeature(write_build_ids)) { in WriteFeatureSections()
456 !writer_->WriteFeature(feat_type, buffer.data(), buffer.size())) { in WriteFeatureSections()
461 return writer_->EndWriteFeatures() && writer_->Close(); in WriteFeatureSections()
[all …]
|
| /system/logging/logd/ |
| D | LogReaderThread.cpp | 36 writer_(std::move(writer)), in LogReaderThread()
70 log_buffer_->FlushTo(writer_.get(), *first_pass_state, in ThreadFunction()
77 writer_.get(), *flush_to_state_, in ThreadFunction()
105 writer_->Release(); in ThreadFunction()
|
| D | LogReaderThread.h | 51 writer_->Shutdown(); in Release()
63 std::string name() const REQUIRES(logd_lock) { return writer_->name(); } in name()
79 std::unique_ptr<LogWriter> writer_ GUARDED_BY(logd_lock);
|
| /system/core/fs_mgr/libsnapshot/ |
| D | make_cow_from_ab_ota.cpp | 109 std::unique_ptr<CowWriter> writer_; member in android::snapshot::PayloadConverter
140 writer_ = nullptr; in Run()
195 writer_ = std::make_unique<CowWriter>(options); in ProcessPartition()
196 if (!writer_->Initialize(std::move(fd))) { in ProcessPartition()
209 if (!writer_->Finalize()) { in ProcessPartition()
238 if (!writer_->AddZeroBlocks(extent.start_block(), extent.num_blocks())) { in ProcessZero()
404 if (!writer_->AddRawBlocks(extent.start_block(), &dest[dest_pos], size)) { in ProcessDiff()
513 if (!writer_->AddCopy(dst_block, src_block)) { in ProcessCopy()
603 if (!writer_->AddRawBlocks(extent.start_block(), buffer.get() + buffer_pos, extent_size)) { in ProcessReplace()
|