| /system/core/fs_mgr/libsnapshot/libsnapshot_cow/ |
| D | cow_format.cpp | 61 std::ostream& operator<<(std::ostream& os, CowOperationV2 const& op) { in operator <<() argument
63 EmitCowTypeString(os, op.type) << ", "; in operator <<()
64 switch (op.compression) { in operator <<()
81 os << "data_length:" << op.data_length << ", "; in operator <<()
82 os << "new_block:" << op.new_block << ", "; in operator <<()
83 os << "source:" << op.source; in operator <<()
88 std::ostream& operator<<(std::ostream& os, CowOperationV3 const& op) { in operator <<() argument
90 EmitCowTypeString(os, op.type()); in operator <<()
91 if (op.type() == kCowReplaceOp || op.type() == kCowXorOp || op.type() == kCowSequenceOp) { in operator <<()
92 os << ", data_length:" << op.data_length; in operator <<()
[all …]
|
| D | writer_v2.cpp | 119 footer_.op.data_length = 64; in SetupHeaders()
120 footer_.op.type = kCowFooterOp; in SetupHeaders()
162 std::unique_ptr<CowOperationV2> op = std::make_unique<CowOperationV2>(); in InitBatchWrites() local
163 cowop_ptr[i].iov_base = op.get(); in InitBatchWrites()
165 opbuffer_vec_.push_back(std::move(op)); in InitBatchWrites()
293 footer_.op.num_ops = 0; in OpenForAppend()
296 for (const auto& op : *parser.get_v2ops()) { in OpenForAppend()
297 AddOperation(op); in OpenForAppend()
314 CowOperationV2 op = {}; in EmitCopy() local
315 op.type = kCowCopyOp; in EmitCopy()
[all …]
|
| D | inspect_cow.cpp | 59 static void ShowBad(CowReader& reader, const CowOperation* op) { in ShowBad() argument
61 auto buffer = std::make_unique<uint8_t[]>(op->data_length); in ShowBad()
63 if (!reader.GetRawBytes(op, buffer.get(), op->data_length, &count)) { in ShowBad()
67 for (int i = 0; i < op->data_length; i++) { in ShowBad()
71 if (op->data_length >= sizeof(CowOperation)) { in ShowBad()
83 for (const auto& op : *parser.get_v2ops()) { in ShowRawOpStreamV2()
84 std::cout << op << "\n"; in ShowRawOpStreamV2()
85 if (auto iter = parser.xor_data_loc()->find(op.new_block); in ShowRawOpStreamV2()
149 std::cout << "Footer: ops usage: " << footer.op.ops_size << " bytes\n"; in Inspect()
150 std::cout << "Footer: op count: " << footer.op.num_ops << "\n"; in Inspect()
[all …]
|
| D | test_v3.cpp | 51 static inline bool ReadData(CowReader& reader, const CowOperation* op, void* buffer, size_t size) { in ReadData() argument
52 return reader.ReadData(op, buffer, size) == size; in ReadData()
161 auto op = iter->Get(); in TEST_F() local
162 ASSERT_EQ(op->type(), kCowZeroOp); in TEST_F()
163 ASSERT_EQ(op->data_length, 0); in TEST_F()
164 ASSERT_EQ(op->new_block, 1); in TEST_F()
165 ASSERT_EQ(op->source(), 0); in TEST_F()
169 op = iter->Get(); in TEST_F()
171 ASSERT_EQ(op->type(), kCowZeroOp); in TEST_F()
172 ASSERT_EQ(op->data_length, 0); in TEST_F()
[all …]
|
| D | test_v2.cpp | 54 static inline bool ReadData(CowReader& reader, const CowOperation* op, void* buffer, size_t size) { in ReadData() argument
55 return reader.ReadData(op, buffer, size) == size; in ReadData()
80 ASSERT_EQ(footer.op.num_ops, 100); in TEST_F()
88 auto op = iter->Get(); in TEST_F() local
89 ASSERT_EQ(op->type(), kCowCopyOp); in TEST_F()
90 ASSERT_EQ(op->data_length, 0); in TEST_F()
91 ASSERT_EQ(op->new_block, 10 + i); in TEST_F()
92 ASSERT_EQ(op->source(), 1000 + i); in TEST_F()
128 ASSERT_EQ(footer.op.num_ops, 4); in TEST_F()
133 auto op = iter->Get(); in TEST_F() local
[all …]
|
| D | snapshot_reader.cpp | 40 const CowOperation* op = op_iter_->Get(); in CompressedSnapshotReader() local
41 if (IsMetadataOp(*op)) { in CompressedSnapshotReader()
47 if (op->type() == kCowReplaceOp) { in CompressedSnapshotReader()
48 num_blocks = (CowOpCompressionSize(op, block_size_) / block_size_); in CompressedSnapshotReader()
50 if (op->new_block >= ops_.size()) { in CompressedSnapshotReader()
51 ops_.resize(op->new_block + num_blocks, nullptr); in CompressedSnapshotReader()
54 size_t vec_index = op->new_block; in CompressedSnapshotReader()
56 ops_[vec_index] = op; in CompressedSnapshotReader()
156 const CowOperation* op = nullptr; in ReadBlock() local
158 op = ops_[chunk]; in ReadBlock()
[all …]
|
| /system/update_engine/payload_consumer/ |
| D | install_operation_executor_unittest.cc | 51 const chromeos_update_engine::InstallOperation& op) { in operator <<() argument
52 out << InstallOperationTypeName(op.type()) in operator <<()
53 << " SRC: " << ExtentsToString(op.src_extents()) in operator <<()
54 << " DST: " << ExtentsToString(op.dst_extents()); in operator <<()
101 void VerityUntouchedExtents(const InstallOperation& op) { in VerityUntouchedExtents() argument
104 extent_set.SubtractRepeatedExtents(op.dst_extents()); in VerityUntouchedExtents()
120 << "After performing op " << op << ", offset " << offset in VerityUntouchedExtents()
136 InstallOperation op; in TEST_F() local
137 op.set_type(InstallOperation::REPLACE); in TEST_F()
138 *op.mutable_dst_extents()->Add() = ExtentForRange(2, 2); in TEST_F()
[all …]
|
| D | partition_writer_unittest.cc | 71 *(aop.op.add_src_extents()) = ExtentForRange(0, num_blocks); in GenerateSourceCopyOp()
72 *(aop.op.add_dst_extents()) = ExtentForRange(0, num_blocks); in GenerateSourceCopyOp()
73 aop.op.set_type(InstallOperation::SOURCE_COPY); in GenerateSourceCopyOp()
77 aop.op.set_src_sha256_hash(src_hash.data(), src_hash.size()); in GenerateSourceCopyOp()
82 brillo::Blob PerformSourceCopyOp(const InstallOperation& op, in PerformSourceCopyOp() argument
91 EXPECT_TRUE(extent_writer.Init(op.src_extents(), kBlockSize)); in PerformSourceCopyOp()
109 EXPECT_TRUE(writer_.PerformSourceCopyOperation(op, &error)); in PerformSourceCopyOp()
152 auto output_data = PerformSourceCopyOp(source_copy_op.op, expected_data); in TEST_F()
180 auto output_data = PerformSourceCopyOp(source_copy_op.op, invalid_data); in TEST_F()
206 InstallOperation op; in TEST_F() local
[all …]
|
| /system/update_engine/payload_generator/ |
| D | merge_sequence_generator.cc | 118 [](CowMergeOperation& op) { in ProcessXorOps() argument
119 CHECK_EQ(op.type(), CowMergeOperation::COW_XOR); in ProcessXorOps()
124 if (op.src_offset() > 0) { in ProcessXorOps()
125 if (op.src_extent().num_blocks() == op.dst_extent().num_blocks()) { in ProcessXorOps()
126 op.mutable_src_extent()->set_num_blocks( in ProcessXorOps()
127 op.src_extent().num_blocks() + 1); in ProcessXorOps()
129 CHECK_EQ(op.src_extent().num_blocks(), in ProcessXorOps()
130 op.dst_extent().num_blocks() + 1); in ProcessXorOps()
132 CHECK_NE(op.src_extent().start_block(), in ProcessXorOps()
140 CHECK_EQ(GetCowOpType(aop.op.type()), CowMergeOperation::COW_COPY); in ProcessCopyOps()
[all …]
|
| D | annotated_operation.cc | 42 op.clear_data_offset(); in SetOperationBlob()
43 op.clear_data_length(); in SetOperationBlob()
48 op.set_data_offset(data_offset); in SetOperationBlob()
49 op.set_data_length(blob.size()); in SetOperationBlob()
58 os << InstallOperationTypeName(aop.op.type()) << " " << aop.op.data_length(); in operator <<()
59 if (aop.op.data_length() > 0) in operator <<()
60 os << " @" << aop.op.data_offset(); in operator <<()
64 if (aop.op.src_extents_size() != 0) { in operator <<()
66 OutputExtents(&os, aop.op.src_extents()); in operator <<()
68 if (aop.op.dst_extents_size() != 0) { in operator <<()
[all …]
|
| D | ab_generator.cc | 93 if (aop.op.dst_extents_size() > 1) { in FragmentOperations()
94 if (aop.op.type() == InstallOperation::SOURCE_COPY) { in FragmentOperations()
98 if (IsAReplaceOperation(aop.op.type())) { in FragmentOperations()
112 InstallOperation original_op = original_aop.op; in SplitSourceCopy()
149 new_aop.op = new_op; in SplitSourceCopy()
165 InstallOperation original_op = original_aop.op; in SplitAReplaceOp()
185 new_aop.op = new_op; in SplitAReplaceOp()
207 bool last_is_a_replace = IsAReplaceOperation(last_aop.op.type()); in MergeOperations()
209 if (last_aop.op.dst_extents_size() <= 0 || in MergeOperations()
210 curr_aop.op.dst_extents_size() <= 0) { in MergeOperations()
[all …]
|
| D | merge_sequence_generator_unittest.cc | 62 aops[0].op.set_type(InstallOperation::SOURCE_COPY); in TEST_F()
63 *aops[0].op.add_src_extents() = ExtentForRange(10, 10); in TEST_F()
64 *aops[0].op.add_dst_extents() = ExtentForRange(30, 10); in TEST_F()
66 aops[1].op.set_type(InstallOperation::SOURCE_COPY); in TEST_F()
67 *aops[1].op.add_src_extents() = ExtentForRange(20, 10); in TEST_F()
68 *aops[1].op.add_dst_extents() = ExtentForRange(40, 10); in TEST_F()
77 *aops[1].op.add_src_extents() = ExtentForRange(30, 5); in TEST_F()
78 *aops[1].op.add_dst_extents() = ExtentForRange(50, 5); in TEST_F()
84 InstallOperation op; in TEST_F() local
85 op.set_type(InstallOperation::SOURCE_COPY); in TEST_F()
[all …]
|
| D | payload_file_unittest.cc | 54 aop.op.set_data_offset(8); in TEST_F()
55 aop.op.set_data_length(3); in TEST_F()
58 aop.op.set_data_offset(7); in TEST_F()
59 aop.op.set_data_length(1); in TEST_F()
63 aop.op.set_data_offset(0); in TEST_F()
64 aop.op.set_data_length(6); in TEST_F()
77 EXPECT_EQ(0U, part0_aops[0].op.data_offset()); in TEST_F()
78 EXPECT_EQ(3U, part0_aops[0].op.data_length()); in TEST_F()
79 EXPECT_EQ(3U, part0_aops[1].op.data_offset()); in TEST_F()
80 EXPECT_EQ(1U, part0_aops[1].op.data_length()); in TEST_F()
[all …]
|
| D | delta_diff_utils_unittest.cc | 181 new_visited_blocks_.AddRepeatedExtents(aop.op.dst_extents()); in TEST_F()
215 InstallOperation& op = aop.op; in TEST_F() local
229 ASSERT_TRUE(op.has_type()); in TEST_F()
232 ASSERT_EQ(expected_type, op.type()); in TEST_F()
233 ASSERT_FALSE(op.has_data_offset()); in TEST_F()
234 ASSERT_FALSE(op.has_data_length()); in TEST_F()
235 ASSERT_EQ(0, op.src_extents_size()); in TEST_F()
236 ASSERT_FALSE(op.has_src_length()); in TEST_F()
237 ASSERT_EQ(1, op.dst_extents_size()); in TEST_F()
238 ASSERT_FALSE(op.has_dst_length()); in TEST_F()
[all …]
|
| D | ab_generator_unittest.cc | 81 InstallOperation op; in TestSplitReplaceOrReplaceXzOperation() local
82 op.set_type(orig_type); in TestSplitReplaceOrReplaceXzOperation()
83 *(op.add_dst_extents()) = in TestSplitReplaceOrReplaceXzOperation()
85 *(op.add_dst_extents()) = in TestSplitReplaceOrReplaceXzOperation()
101 op.set_data_offset(0); in TestSplitReplaceOrReplaceXzOperation()
102 op.set_data_length(op_blob.size()); in TestSplitReplaceOrReplaceXzOperation()
105 aop.op = op; in TestSplitReplaceOrReplaceXzOperation()
131 InstallOperation first_op = result_ops[0].op; in TestSplitReplaceOrReplaceXzOperation()
161 InstallOperation second_op = result_ops[1].op; in TestSplitReplaceOrReplaceXzOperation()
245 first_aop.op = first_op; in TestMergeReplaceOrReplaceXzOperations()
[all …]
|
| D | cow_size_estimator.cc | 77 for (const auto& op : operations) { in CowDryRun() local
78 switch (op.type()) { in CowDryRun()
88 op, source_fd, cow_writer, xor_map, old_partition_size); in CowDryRun()
89 TEST_AND_RETURN_FALSE(writer->Init(op.dst_extents(), block_size)); in CowDryRun()
90 for (const auto& ext : op.dst_extents()) { in CowDryRun()
117 TEST_AND_RETURN_FALSE(extent_writer.Init(op.dst_extents(), block_size)); in CowDryRun()
118 for (const auto& ext : op.dst_extents()) { in CowDryRun()
141 for (const auto& ext : op.dst_extents()) { in CowDryRun()
149 for (const auto& ext : op.dst_extents()) { in CowDryRun()
153 op, block_size, copy_blocks, source_fd, cow_writer, true)) { in CowDryRun()
[all …]
|
| /system/update_engine/aosp/ |
| D | update_attempter_android_integration_test.cc | 190 for (const auto& op : part.operations()) { in AddSignatureInfoToPayload() local
191 if (!op.has_data_offset()) in AddSignatureInfoToPayload()
193 ASSERT_EQ(total_blob_size, op.data_offset()) in AddSignatureInfoToPayload()
195 total_blob_size += op.data_length(); in AddSignatureInfoToPayload()
213 for (auto& op : *partition.mutable_operations()) { in HydratePayload()
214 if (op.type() == InstallOperation::REPLACE) { in HydratePayload()
215 ASSERT_GE(lseek64(blob_file_.fd(), op.data_offset(), SEEK_SET), 0); in HydratePayload()
217 new_part_.fd(), blob_file_.fd(), op.data_length())); in HydratePayload()
218 } else if (op.type() == InstallOperation::BROTLI_BSDIFF) { in HydratePayload()
221 old_part_.path(), op.src_extents(), &old_data, kBlockSize)) in HydratePayload()
[all …]
|
| D | ota_extractor.cc | 137 for (const auto& op : partition.operations()) { in ExtractImagesFromOTA() local
138 if (op.has_src_sha256_hash()) { in ExtractImagesFromOTA()
141 in_fd, op.src_extents(), manifest.block_size(), &actual_hash)); in ExtractImagesFromOTA()
143 HexEncode(op.src_sha256_hash())); in ExtractImagesFromOTA()
146 blob.resize(op.data_length()); in ExtractImagesFromOTA()
147 const auto op_data_offset = data_begin + op.data_offset(); in ExtractImagesFromOTA()
151 if (op.has_data_sha256_hash()) { in ExtractImagesFromOTA()
156 HexEncode(op.data_sha256_hash())); in ExtractImagesFromOTA()
159 if (op.type() == InstallOperation::ZERO) { in ExtractImagesFromOTA()
161 op, std::move(direct_writer))); in ExtractImagesFromOTA()
[all …]
|
| /system/keymint/ta/src/ |
| D | operation.rs | 85 CryptoOperation::HmacSign(op, _) in check_size()
86 | CryptoOperation::HmacVerify(op, _) in check_size()
87 | CryptoOperation::RsaDecrypt(op) in check_size()
88 | CryptoOperation::RsaSign(op) in check_size()
89 | CryptoOperation::EcAgree(op) in check_size()
90 | CryptoOperation::EcSign(op) => op.max_input_size(), in check_size()
239 let op = match key_material { in begin_operation() localVariable
422 self.operations[op_idx] = Some(op); in begin_operation()
437 self.with_authed_operation(op_handle, auth_token, timestamp_token, |op| { in op_update_aad()
438 if !op.aad_allowed { in op_update_aad()
[all …]
|
| /system/update_engine/common/ |
| D | cow_operation_convert_unittest.cc | 33 std::ostream& operator<<(std::ostream& out, CowOperation::Type op) { in operator <<() argument
34 switch (op) { in operator <<()
42 out << op; in operator <<()
49 out << "{" << c.op << ", " << c.src_block << ", " << c.dst_block << ", " in operator <<()
60 for (auto&& op : operations_) { in VerifyCowMergeOp()
61 src_extent_set.AddRepeatedExtents(op.src_extents()); in VerifyCowMergeOp()
62 dst_extent_set.AddRepeatedExtents(op.dst_extents()); in VerifyCowMergeOp()
66 if (cow_op.op == CowOperation::CowCopy) { in VerifyCowMergeOp()
97 auto&& op = operations->Add(); in AddOperation()
98 op->set_type(op_type); in AddOperation()
[all …]
|
| /system/media/audio_utils/ |
| D | fifo_index.cpp | 49 int audio_utils_fifo_index::wait(int op, uint32_t expected, const struct timespec *timeout) in wait() argument
51 return sys_futex(&mIndex, op, expected, timeout, NULL, 0); in wait()
54 int audio_utils_fifo_index::wake(int op, int waiters) in wake() argument
56 return sys_futex(&mIndex, op, waiters, NULL, NULL, 0); in wake()
94 void RefIndexDeferredStoreReleaseDeferredWake::wakeDeferred(int op, int waiters)
100 if (op == FUTEX_WAKE) {
119 void RefIndexDeferredStoreReleaseDeferredWake::wakeNow(int op, int waiters)
121 wakeDeferred(op, waiters);
165 int RefIndexCachedLoadAcquireDeferredWait::wait(int op, const struct timespec *timeout)
170 int err = mIndex.wait(op, mValue /*expected*/, timeout);
|
| /system/update_engine/lz4diff/ |
| D | lz4diff_main.cc | 49 Lz4DiffOp op) { in ExecuteLz4diff() argument
58 if (op == DIFF || op == TEST) { in ExecuteLz4diff()
69 if (op == PATCH || op == TEST) { in ExecuteLz4diff()
87 Lz4DiffOp op) { in ExecuteLz4diffOp() argument
97 if (patch_file == nullptr && op == TEST) { in ExecuteLz4diffOp()
107 src_image_path, dst_image_path, src_file, *dst_file, patch_file, op); in ExecuteLz4diffOp()
133 src_image_path, dst_image_path, *src_file, *dst_file, patch_file, op); in ExecuteLz4diffOp()
154 std::string_view op = argv[1]; in main() local
155 if (op == "diff") { in main()
168 } else if (op == "patch") { in main()
[all …]
|
| /system/update_engine/scripts/update_payload/ |
| D | checker_unittest.py | 588 op = mock.create_autospec(update_metadata_pb2.InstallOperation)
589 op.type = common.OpType.REPLACE
592 op.src_extents = []
595 op, data_length, (data_length + block_size - 1) // block_size,
599 op.src_extents = ['bar']
602 op, data_length, (data_length + block_size - 1) // block_size, 'foo')
605 op.src_extents = []
608 op, None, (data_length + block_size - 1) // block_size, 'foo')
611 op.src_extents = ['bar']
614 op, data_length, (data_length + block_size - 1) // block_size + 1,
[all …]
|
| D | checker.py | 755 def _CheckReplaceOperation(self, op, data_length, total_dst_blocks, op_name): argument
773 if op.src_extents:
780 if op.type == common.OpType.REPLACE:
792 def _CheckZeroOperation(self, op, op_name): argument
803 if op.src_extents:
805 if op.data_length:
807 if op.data_offset:
810 def _CheckAnyDiffOperation(self, op, data_length, total_dst_blocks, op_name): argument
836 if op.type == common.OpType.SOURCE_BSDIFF and self.minor_version <= 3:
837 if not op.HasField('src_length') or not op.HasField('dst_length'):
[all …]
|
| /system/nfc/src/nfa/rw/ |
| D | nfa_rw_api.cc | 73 p_msg->op = NFA_RW_OP_DETECT_NDEF; in NFA_RwDetectNDef()
118 p_msg->op = NFA_RW_OP_READ_NDEF; in NFA_RwReadNDef()
160 p_msg->op = NFA_RW_OP_WRITE_NDEF; in NFA_RwWriteNDef()
195 p_msg->op = NFA_RW_OP_PRESENCE_CHECK; in NFA_RwPresenceCheck()
228 p_msg->op = NFA_RW_OP_FORMAT_TAG; in NFA_RwFormatTag()
283 p_msg->op = NFA_RW_OP_SET_TAG_RO; in NFA_RwSetTagReadOnly()
342 p_msg->op = NFA_RW_OP_DETECT_LOCK_TLV; in NFA_RwLocateTlv()
344 p_msg->op = NFA_RW_OP_DETECT_MEM_TLV; in NFA_RwLocateTlv()
346 p_msg->op = NFA_RW_OP_DETECT_NDEF; in NFA_RwLocateTlv()
381 p_msg->op = NFA_RW_OP_T1T_RID; in NFA_RwT1tRid()
[all …]
|