| /system/update_engine/payload_generator/ |
| D | delta_diff_utils_unittest.cc | 187 new_visited_blocks_.AddRepeatedExtents(aop.op.dst_extents()); in TEST_F()
209 InstallOperation op; in TEST_F() local
219 &op)); in TEST_F()
222 EXPECT_TRUE(op.has_type()); in TEST_F()
223 EXPECT_EQ(InstallOperation::MOVE, op.type()); in TEST_F()
224 EXPECT_FALSE(op.has_data_offset()); in TEST_F()
225 EXPECT_FALSE(op.has_data_length()); in TEST_F()
226 EXPECT_EQ(1, op.src_extents_size()); in TEST_F()
227 EXPECT_EQ(kBlockSize, op.src_length()); in TEST_F()
228 EXPECT_EQ(1, op.dst_extents_size()); in TEST_F()
[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 | inplace_generator_unittest.cc | 59 out->aop.op.set_type(type); in GenVertex()
61 StoreExtents(src_extents, out->aop.op.mutable_src_extents()); in GenVertex()
62 StoreExtents(dst_extents, out->aop.op.mutable_dst_extents()); in GenVertex()
98 void OpAppendExtent(InstallOperation* op, uint64_t start, uint64_t length) { in OpAppendExtent() argument
99 Extent* extent = op->add_src_extents(); in OpAppendExtent()
160 InstallOperation& op = vertex.aop.op; in TEST_F() local
161 OpAppendExtent(&op, 4, 3); in TEST_F()
162 OpAppendExtent(&op, kSparseHole, 4); // Sparse hole in file in TEST_F()
163 OpAppendExtent(&op, 3, 1); in TEST_F()
164 OpAppendExtent(&op, 7, 3); in TEST_F()
[all …]
|
| D | ab_generator.cc | 94 if (aop.op.dst_extents_size() > 1) { in FragmentOperations()
95 if (aop.op.type() == InstallOperation::SOURCE_COPY) { in FragmentOperations()
99 if (IsAReplaceOperation(aop.op.type())) { in FragmentOperations()
113 InstallOperation original_op = original_aop.op; in SplitSourceCopy()
150 new_aop.op = new_op; in SplitSourceCopy()
166 InstallOperation original_op = original_aop.op; in SplitAReplaceOp()
186 new_aop.op = new_op; in SplitAReplaceOp()
208 bool last_is_a_replace = IsAReplaceOperation(last_aop.op.type()); in MergeOperations()
210 if (last_aop.op.dst_extents_size() <= 0 || in MergeOperations()
211 curr_aop.op.dst_extents_size() <= 0) { in MergeOperations()
[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 | ab_generator_unittest.cc | 82 InstallOperation op; in TestSplitReplaceOrReplaceBzOperation() local
83 op.set_type(orig_type); in TestSplitReplaceOrReplaceBzOperation()
84 *(op.add_dst_extents()) = in TestSplitReplaceOrReplaceBzOperation()
86 *(op.add_dst_extents()) = in TestSplitReplaceOrReplaceBzOperation()
102 op.set_data_offset(0); in TestSplitReplaceOrReplaceBzOperation()
103 op.set_data_length(op_blob.size()); in TestSplitReplaceOrReplaceBzOperation()
106 aop.op = op; in TestSplitReplaceOrReplaceBzOperation()
133 InstallOperation first_op = result_ops[0].op; in TestSplitReplaceOrReplaceBzOperation()
163 InstallOperation second_op = result_ops[1].op; in TestSplitReplaceOrReplaceBzOperation()
248 first_aop.op = first_op; in TestMergeReplaceOrReplaceBzOperations()
[all …]
|
| D | full_update_generator_unittest.cc | 85 EXPECT_EQ(1, aops[i].op.dst_extents_size()); in TEST_F()
88 aops[i].op.dst_extents(0).start_block()) in TEST_F()
91 aops[i].op.dst_extents(0).num_blocks()); in TEST_F()
92 if (aops[i].op.type() != InstallOperation::REPLACE) { in TEST_F()
93 EXPECT_EQ(InstallOperation::REPLACE_BZ, aops[i].op.type()); in TEST_F()
116 utils::BlocksInExtents(aops[0].op.dst_extents())); in TEST_F()
118 utils::BlocksInExtents(aops[1].op.dst_extents())); in TEST_F()
138 utils::BlocksInExtents(aops[0].op.dst_extents())); in TEST_F()
|
| D | payload_file.cc | 126 if (!aop.op.has_data_offset()) in WritePayload()
128 if (aop.op.data_offset() != next_blob_offset) { in WritePayload()
129 LOG(FATAL) << "bad blob offset! " << aop.op.data_offset() in WritePayload()
132 next_blob_offset += aop.op.data_length(); in WritePayload()
169 *partition->add_operations() = aop.op; in WritePayload()
179 *manifest_.add_kernel_install_operations() = aop.op; in WritePayload()
186 *manifest_.add_install_operations() = aop.op; in WritePayload()
318 if (!aop.op.has_data_offset()) in ReorderDataBlobs()
320 CHECK(aop.op.has_data_length()); in ReorderDataBlobs()
321 brillo::Blob buf(aop.op.data_length()); in ReorderDataBlobs()
[all …]
|
| D | inplace_generator.cc | 105 CHECK(v.aop.op.has_type()); in CheckGraph()
113 vector<uint64_t> read_blocks = ExpandExtents(vertex->aop.op.src_extents()); in SubstituteBlocks()
134 vertex->aop.op.clear_src_extents(); in SubstituteBlocks()
136 StoreExtents(new_extents, vertex->aop.op.mutable_src_extents()); in SubstituteBlocks()
175 graph->back().aop.op.set_type(InstallOperation::MOVE); in CutEdges()
177 graph->back().aop.op.mutable_src_extents()); in CutEdges()
179 graph->back().aop.op.mutable_dst_extents()); in CutEdges()
180 graph->back().aop.op.set_src_length(graph_utils::EdgeWeight(*graph, edge) * in CutEdges()
182 graph->back().aop.op.set_dst_length(graph->back().aop.op.src_length()); in CutEdges()
276 InstallOperation::Type type = (*graph)[op_index].aop.op.type(); in MoveAndSortFullOpsToBack()
[all …]
|
| /system/update_engine/scripts/update_payload/ |
| D | applier.py | 244 def _ApplyReplaceOperation(self, op, op_name, out_data, part_file, part_size): argument
261 if op.type == common.OpType.REPLACE_BZ:
264 elif op.type == common.OpType.REPLACE_XZ:
271 for ex, ex_name in common.ExtentIter(op.dst_extents,
309 def _ApplyMoveOperation(self, op, op_name, part_file): argument
327 in_data = _ReadExtents(part_file, op.src_extents, block_size)
330 _WriteExtents(part_file, in_data, op.dst_extents, block_size,
333 def _ApplyZeroOperation(self, op, op_name, part_file): argument
349 for ex, ex_name in common.ExtentIter(op.dst_extents, base_name):
355 def _ApplySourceCopyOperation(self, op, op_name, old_part_file, argument
[all …]
|
| D | checker_unittest.py | 573 op = self.mox.CreateMock(
575 op.type = common.OpType.REPLACE
578 op.src_extents = []
581 op, data_length, (data_length + block_size - 1) / block_size,
585 op.src_extents = ['bar']
588 op, data_length, (data_length + block_size - 1) / block_size, 'foo')
591 op.src_extents = []
594 op, None, (data_length + block_size - 1) / block_size, 'foo')
597 op.src_extents = ['bar']
600 op, data_length, (data_length + block_size - 1) / block_size + 1, 'foo')
[all …]
|
| D | checker.py | 777 def _CheckReplaceOperation(self, op, data_length, total_dst_blocks, op_name): argument
790 if op.src_extents:
797 if op.type == common.OpType.REPLACE:
809 def _CheckMoveOperation(self, op, data_offset, total_src_blocks, argument
835 src_extent_iter = iter(op.src_extents)
836 dst_extent_iter = iter(op.dst_extents)
892 def _CheckZeroOperation(self, op, op_name): argument
903 if op.src_extents:
905 if op.data_length:
907 if op.data_offset:
[all …]
|
| D | test_utils.py | 201 op = operations.add()
202 op.type = op_type
204 _SetMsgField(op, 'data_offset', data_offset)
205 _SetMsgField(op, 'data_length', data_length)
207 self._AddExtents(op.src_extents, src_extents)
208 _SetMsgField(op, 'src_length', src_length)
210 self._AddExtents(op.dst_extents, dst_extents)
211 _SetMsgField(op, 'dst_length', dst_length)
213 _SetMsgField(op, 'data_sha256_hash', data_sha256_hash)
|
| /system/bt/bta/gatt/ |
| D | bta_gattc_queue.cc | 106 gatt_operation& op = gatt_ops.front(); in gatt_execute_next_op() local
108 if (op.type == GATT_READ_CHAR) { in gatt_execute_next_op()
111 data->cb = op.read_cb; in gatt_execute_next_op()
112 data->cb_data = op.read_cb_data; in gatt_execute_next_op()
113 BTA_GATTC_ReadCharacteristic(conn_id, op.handle, GATT_AUTH_REQ_NONE, in gatt_execute_next_op()
116 } else if (op.type == GATT_READ_DESC) { in gatt_execute_next_op()
119 data->cb = op.read_cb; in gatt_execute_next_op()
120 data->cb_data = op.read_cb_data; in gatt_execute_next_op()
121 BTA_GATTC_ReadCharDescr(conn_id, op.handle, GATT_AUTH_REQ_NONE, in gatt_execute_next_op()
124 } else if (op.type == GATT_WRITE_CHAR) { in gatt_execute_next_op()
[all …]
|
| /system/media/audio_utils/ |
| D | fifo_index.cpp | 36 int audio_utils_fifo_index::wait(int op, uint32_t expected, const struct timespec *timeout) in wait() argument
38 return sys_futex(&mIndex, op, expected, timeout, NULL, 0); in wait()
41 int audio_utils_fifo_index::wake(int op, int waiters) in wake() argument
43 return sys_futex(&mIndex, op, waiters, NULL, NULL, 0); in wake()
84 void RefIndexDeferredStoreReleaseDeferredWake::wakeDeferred(int op, int waiters) in wakeDeferred() argument
90 if (op == FUTEX_WAKE) { in wakeDeferred()
109 void RefIndexDeferredStoreReleaseDeferredWake::wakeNow(int op, int waiters) in wakeNow() argument
111 wakeDeferred(op, waiters); in wakeNow()
155 int RefIndexCachedLoadAcquireDeferredWait::wait(int op, const struct timespec *timeout) in wait() argument
160 int err = mIndex.wait(op, mValue /*expected*/, timeout); in wait()
|
| /system/nfc/src/nfa/rw/ |
| D | nfa_rw_api.cc | 76 p_msg->op = NFA_RW_OP_DETECT_NDEF; in NFA_RwDetectNDef()
121 p_msg->op = NFA_RW_OP_READ_NDEF; in NFA_RwReadNDef()
163 p_msg->op = NFA_RW_OP_WRITE_NDEF; in NFA_RwWriteNDef()
198 p_msg->op = NFA_RW_OP_PRESENCE_CHECK; in NFA_RwPresenceCheck()
231 p_msg->op = NFA_RW_OP_FORMAT_TAG; in NFA_RwFormatTag()
287 p_msg->op = NFA_RW_OP_SET_TAG_RO; in NFA_RwSetTagReadOnly()
346 p_msg->op = NFA_RW_OP_DETECT_LOCK_TLV; in NFA_RwLocateTlv()
348 p_msg->op = NFA_RW_OP_DETECT_MEM_TLV; in NFA_RwLocateTlv()
350 p_msg->op = NFA_RW_OP_DETECT_NDEF; in NFA_RwLocateTlv()
385 p_msg->op = NFA_RW_OP_T1T_RID; in NFA_RwT1tRid()
[all …]
|
| /system/media/audio_utils/include/audio_utils/ |
| D | fifo_index.h | 66 int wait(int op, uint32_t expected, const struct timespec *timeout);
77 int wake(int op, int waiters = 1);
127 void wakeDeferred(int op, int waiters = 1);
130 void wakeNow(int op, int waiters = 1);
184 int wait(int op, const struct timespec *timeout);
|
| D | futex.h | 35 int sys_futex(void *addr1, int op, int val1, const struct timespec *timeout, void *addr2, in sys_futex() argument
39 return syscall(SYS_futex, addr1, op, val1, timeout, addr2, val3); in sys_futex()
43 (void) op; in sys_futex()
|
| /system/update_engine/payload_consumer/ |
| D | delta_performer_unittest.cc | 256 *(aop.op.add_src_extents()) = ExtentForRange(0, num_blocks); in GenerateSourceCopyPayload()
257 *(aop.op.add_dst_extents()) = ExtentForRange(0, num_blocks); in GenerateSourceCopyPayload()
258 aop.op.set_type(InstallOperation::SOURCE_COPY); in GenerateSourceCopyPayload()
262 aop.op.set_src_sha256_hash(src_hash.data(), src_hash.size()); in GenerateSourceCopyPayload()
449 *(aop.op.add_dst_extents()) = ExtentForRange(0, 1); in TEST_F()
450 aop.op.set_data_offset(0); in TEST_F()
451 aop.op.set_data_length(expected_data.size()); in TEST_F()
452 aop.op.set_type(InstallOperation::REPLACE); in TEST_F()
471 *(aop.op.add_dst_extents()) = ExtentForRange(0, 1); in TEST_F()
472 aop.op.set_data_offset(0); in TEST_F()
[all …]
|
| /system/security/keystore/ |
| D | keymaster_worker.cpp | 341 auto op = operationMap_.removeOperation(token, false /* wasOpSuccessful */, in abort() local
343 if (op) { in abort()
344 keyStore_->getAuthTokenTable().MarkCompleted(op->handle); in abort()
345 return KS_HANDLE_HIDL_ERROR(keymasterDevice_, keymasterDevice_->abort(op->handle)); in abort()
554 KeymasterWorker::getOperationAuthTokenIfNeeded(std::shared_ptr<Operation> op) { in getOperationAuthTokenIfNeeded() argument
555 if (!op) return ErrorCode::INVALID_OPERATION_HANDLE; in getOperationAuthTokenIfNeeded()
557 if (op->authTokenFuture.valid()) { in getOperationAuthTokenIfNeeded()
559 op->authTokenFuture.wait(); in getOperationAuthTokenIfNeeded()
560 auto rc = op->authTokenFuture.get(); in getOperationAuthTokenIfNeeded()
564 op->authTokenFuture = {}; in getOperationAuthTokenIfNeeded()
[all …]
|
| D | operation.cpp | 47 auto op = entry->second; in getOperation() local
50 return op; in getOperation()
66 auto op = entry->second; in removeOperation() local
67 logKeystoreKeyOperationEvent(*op, wasSuccessful, responseCode); in removeOperation()
72 removeOperationTracking(token, op->appToken); in removeOperation()
73 return op; in removeOperation()
|
| D | key_operation_log_handler.cpp | 114 void logKeystoreKeyOperationEvent(const Operation& op, bool wasOperationSuccessful, in logKeystoreKeyOperationEvent() argument
116 AuthorizationSet authorization_set(op.characteristics.softwareEnforced); in logKeystoreKeyOperationEvent()
117 authorization_set.Union(op.characteristics.hardwareEnforced); in logKeystoreKeyOperationEvent()
118 AuthorizationSet operation_params(op.params); in logKeystoreKeyOperationEvent()
129 generateBitMapForBlockModeValue(operation_params), static_cast<int32_t>(op.purpose), in logKeystoreKeyOperationEvent()
|
| /system/update_engine/scripts/ |
| D | payload_info.py | 152 for op, op_count in itertools.izip(operations, itertools.count()):
153 print(' %d: %s' % (op_count, op_dict[op.type]))
154 if op.HasField('data_offset'):
155 print(' Data offset: %s' % op.data_offset)
156 if op.HasField('data_length'):
157 print(' Data length: %s' % op.data_length)
158 if op.src_extents:
159 _DisplayExtents(op.src_extents, 'Source')
160 if op.dst_extents:
161 _DisplayExtents(op.dst_extents, 'Destination')
|
| /system/netd/server/ |
| D | IdletimerControllerTest.cpp | 44 const char *op = add ? "-A" : "-D"; in makeAddRemoveCommands() local
48 " --timeout 12345 --label hello --send_nl_msg 1", op), in makeAddRemoveCommands()
52 " --timeout 12345 --label hello --send_nl_msg 1", op), in makeAddRemoveCommands()
|
| /system/core/libappfuse/ |
| D | EpollController.cc | 54 bool EpollController::InvokeControl(int op, int fd, int events, void* data) const { in InvokeControl() argument
59 if (epoll_ctl(poll_fd_, op, fd, &event) == -1) { in InvokeControl()
60 PLOG(ERROR) << "epoll_ctl() error op=" << op; in InvokeControl()
|