| /system/security/keystore2/src/database/ |
| D | versioning.rs | 18 pub fn create_or_get_version(tx: &Transaction, current_version: u32) -> Result<u32> { in create_or_get_version()
19 tx.execute( in create_or_get_version()
27 let version = tx in create_or_get_version()
41 let version = if tx in create_or_get_version()
57 tx.execute("INSERT INTO persistent.version (id, version) VALUES(0, ?);", params![version]) in create_or_get_version()
64 pub fn update_version(tx: &Transaction, new_version: u32) -> Result<()> { in update_version()
65 let updated = tx in update_version()
75 pub fn upgrade_database<F>(tx: &Transaction, current_version: u32, upgraders: &[F]) -> Result<()> in upgrade_database()
82 let mut db_version = create_or_get_version(tx, current_version) in upgrade_database()
85 db_version = upgraders[db_version as usize](tx).with_context(|| { in upgrade_database()
[all …]
|
| /system/core/trusty/storage/lib/ |
| D | storage.c | 148 struct iovec tx[3] = {{&msg, sizeof(msg)}, {&req, sizeof(req)}, {(void *)name, strlen(name)}}; in storage_open_file() local
152 ssize_t rc = send_reqv(session, tx, 3, rx, 2); in storage_open_file()
170 struct iovec tx[2] = {{&msg, sizeof(msg)}, {&req, sizeof(req)}}; in storage_close_file() local
173 ssize_t rc = send_reqv(_to_session(fh), tx, 2, rx, 1); in storage_close_file()
184 struct iovec tx[3] = {{&msg, sizeof(msg)}, {&req, sizeof(req)}, {(void *)name, strlen(name)}}; in storage_delete_file() local
187 ssize_t rc = send_reqv(session, tx, 3, rx, 1); in storage_delete_file()
195 struct iovec tx[2] = {{&msg, sizeof(msg)}, {&req, sizeof(req)}}; in _read_chunk() local
198 ssize_t rc = send_reqv(_to_session(fh), tx, 2, rx, 2); in _read_chunk()
230 struct iovec tx[3] = {{&msg, sizeof(msg)}, {&req, sizeof(req)}, {(void *)buf, size}}; in _write_req() local
233 ssize_t rc = send_reqv(_to_session(fh), tx, 3, rx, 1); in _write_req()
[all …]
|
| /system/security/keystore2/src/ |
| D | database.rs | 170 fn load_from_db(key_id: i64, tx: &Transaction) -> Result<Self> { in load_from_db()
171 let mut stmt = tx in load_from_db()
197 fn store_in_db(&self, key_id: i64, tx: &Transaction) -> Result<()> { in store_in_db()
198 let mut stmt = tx in store_in_db()
246 fn load_from_db(blob_id: i64, tx: &Transaction) -> Result<Self> { in load_from_db()
247 let mut stmt = tx in load_from_db()
271 fn store_in_db(&self, blob_id: i64, tx: &Transaction) -> Result<()> { in store_in_db()
272 let mut stmt = tx in store_in_db()
894 db.with_transaction(Immediate("TX_new"), |tx| { in new()
895 versioning::upgrade_database(tx, Self::CURRENT_DB_VERSION, Self::UPGRADERS) in new()
[all …]
|
| /system/security/keystore2/rkpd_client/src/ |
| D | lib.rs | 149 let (tx, rx) = oneshot::channel(); in get_rkpd_registration()
150 let cb = GetRegistrationCallback::new_native_binder(tx); in get_rkpd_registration()
207 let (tx, rx) = oneshot::channel(); in get_rkpd_attestation_key_from_registration_async()
208 let cb = GetKeyCallback::new_native_binder(tx); in get_rkpd_attestation_key_from_registration_async()
273 let (tx, rx) = oneshot::channel(); in store_rkpd_attestation_key_with_registration_async()
274 let cb = StoreUpgradedKeyCallback::new_native_binder(tx); in store_rkpd_attestation_key_with_registration_async()
410 let (tx, rx) = oneshot::channel(); in get_mock_registration()
411 let cb = GetRegistrationCallback::new_native_binder(tx); in get_mock_registration()
434 let (tx, rx) = oneshot::channel(); in test_get_registration_cb_cancel()
435 let cb = GetRegistrationCallback::new_native_binder(tx); in test_get_registration_cb_cancel()
[all …]
|
| /system/libfmq/tests/ |
| D | fmq_unit_tests.cpp | 817 typename TypeParam::MQType::MemTransaction tx; in TYPED_TEST() local
818 ASSERT_TRUE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
820 ASSERT_TRUE(tx.copyTo(data, 0 /* startIdx */, dataLen)); in TYPED_TEST()
826 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
828 ASSERT_TRUE(tx.copyFrom(readData, 0 /* startIdx */, dataLen)); in TYPED_TEST()
845 typename TypeParam::MQType::MemTransaction tx; in TYPED_TEST() local
846 ASSERT_TRUE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
848 auto first = tx.getFirstRegion(); in TYPED_TEST()
849 auto second = tx.getSecondRegion(); in TYPED_TEST()
853 uint8_t* ptr = tx.getSlot(i); in TYPED_TEST()
[all …]
|
| D | msgq_test_client.cpp | 680 typename TypeParam::MQType::MemTransaction tx; in TYPED_TEST() local
681 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
683 const auto& region = tx.getFirstRegion(); in TYPED_TEST()
715 typename TypeParam::MQType::MemTransaction tx; in TYPED_TEST() local
716 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
718 auto first = tx.getFirstRegion(); in TYPED_TEST()
719 auto second = tx.getSecondRegion(); in TYPED_TEST()
761 typename TypeParam::MQType::MemTransaction tx; in TYPED_TEST() local
762 ASSERT_TRUE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
764 auto first = tx.getFirstRegion(); in TYPED_TEST()
[all …]
|
| /system/security/keystore2/legacykeystore/ |
| D | lib.rs | 62 .and_then(|tx| f(&tx).map(|result| (result, tx))) in with_transaction()
63 .and_then(|(result, tx)| { in with_transaction()
64 tx.commit().context("In with_transaction: Failed to commit transaction.")?; in with_transaction()
90 self.with_transaction(TransactionBehavior::Immediate, |tx| { in init_tables()
91 tx.execute( in init_tables()
105 self.with_transaction(TransactionBehavior::Deferred, |tx| { in list()
106 let mut stmt = tx in list()
126 self.with_transaction(TransactionBehavior::Immediate, |tx| { in put()
127 tx.execute( in put()
137 self.with_transaction(TransactionBehavior::Deferred, |tx| { in get()
[all …]
|
| /system/tools/aidl/tests/ |
| D | aidl_test_client_loggable_interface.cpp | 56 BpLoggableInterface::logFunc = [&](const BpLoggableInterface::TransactionLog& tx) { log = tx; }; in TEST_F() argument
|
| D | aidl_test_client_ndk_loggable_interface.cpp | 65 BpLoggableInterface::logFunc = [&](const BpLoggableInterface::TransactionLog& tx) { log = tx; }; in TEST_F() argument
|
| /system/libfmq/fuzzer/ |
| D | fmq_fuzzer.cpp | 129 typename Queue::MemTransaction tx; in reader() local
131 if (!readMq.beginRead(numElements, &tx)) { in reader()
134 const auto& region = tx.getFirstRegion(); in reader()
187 typename Queue::MemTransaction tx; in writer() local
189 if (!writeMq.beginWrite(numElements, &tx)) { in writer()
195 const auto& region = tx.getFirstRegion(); in writer()
|
| /system/core/trusty/apploader/ |
| D | apploader.cpp | 179 struct iovec tx[2] = {{&hdr, sizeof(hdr)}, {&req, sizeof(req)}}; in send_load_message() local
184 return tipc_send(tipc_fd, tx, 2, &shm, 1); in send_load_message()
|
| /system/nfc/src/rust/nci/ |
| D | nci.rs | 101 let (tx, rx) = oneshot::channel::<Response>(); in send()
104 pending: PendingCommand { cmd, response: tx }, in send()
113 let (tx, rx) = oneshot::channel::<Response>(); in send_and_notify()
117 pending: PendingCommand { cmd, response: tx }, in send_and_notify()
|
| D | api.rs | 106 let (tx, rx) = oneshot::channel::<HalEventStatus>(); in nfc_disable()
108 event.register(HalEvent::CloseComplete, tx).await; in nfc_disable()
|
| /system/libziparchive/cli-tests/ |
| D | zipinfo.test | 52 -rw-r----- 3.0 unx 1024 tx defN 2017-06-04 08:45 d1/d2/x.txt
|
| /system/libfmq/include/fmq/ |
| D | MessageQueueBase.h | 892 MemTransaction tx; in write() local
893 return beginWrite(nMessages, &tx) && in write()
894 tx.copyToSized(data, 0 /* startIdx */, nMessages, quantum()) && commitWrite(nMessages); in write()
1276 MemTransaction tx; in read() local
1277 return beginRead(nMessages, &tx) && in read()
1278 tx.copyFromSized(data, 0 /* startIdx */, nMessages, quantum()) && commitRead(nMessages); in read()
|
| /system/logging/liblog/tests/ |
| D | liblog_benchmark.cpp | 688 log_time* tx = reinterpret_cast<log_time*>(eventData + 4 + 1); in BM_log_latency() local
689 if (ts != *tx) { in BM_log_latency()
761 log_time* tx = reinterpret_cast<log_time*>(eventData + 4 + 1); in BM_log_delay() local
762 if (ts != *tx) { in BM_log_delay()
|
| D | liblog_test.cpp | 276 log_time* tx = reinterpret_cast<log_time*>(&eventData->payload.data); in TEST() local
277 if (ts == *tx) { in TEST()
279 } else if (ts1 == *tx) { in TEST()
1550 log_time tx(reinterpret_cast<char*>(&eventData->payload.data)); in count_matching_ts()
1551 if (ts != tx) continue; in count_matching_ts()
1804 log_time tx(reinterpret_cast<char*>(&eventData->payload.data)); in TEST()
1805 if (ts == tx) { in TEST()
|
| /system/logging/logcat/tests/ |
| D | logcat_test.cpp | 478 log_time* tx = reinterpret_cast<log_time*>(&t); in TEST() local
479 if (ts == *tx) { in TEST()
523 log_time* tx = reinterpret_cast<log_time*>(&t); in TEST() local
524 if (ts == *tx) { in TEST()
|
| /system/logging/logcat/ |
| D | event.logtags | 107 52001 http_stats (useragent|3),(response|2|3),(processing|2|3),(tx|1|2),(rx|1|2)
|