| /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()
43 let version = if tx in create_or_get_version()
59 tx.execute("INSERT INTO persistent.version (id, version) VALUES(0, ?);", params![version]) in create_or_get_version()
66 pub fn update_version(tx: &Transaction, new_version: u32) -> Result<()> { in update_version()
67 let updated = tx in update_version()
77 pub fn upgrade_database<F>(tx: &Transaction, current_version: u32, upgraders: &[F]) -> Result<()> in upgrade_database()
84 let mut db_version = create_or_get_version(tx, current_version) in upgrade_database()
87 db_version = upgraders[db_version as usize](tx).with_context(|| { in upgrade_database()
[all …]
|
| /system/security/keystore2/src/ |
| D | database.rs | 127 fn load_from_db(key_id: i64, tx: &Transaction) -> Result<Self> { in load_from_db()
128 let mut stmt = tx in load_from_db()
154 fn store_in_db(&self, key_id: i64, tx: &Transaction) -> Result<()> { in store_in_db()
155 let mut stmt = tx in store_in_db()
203 fn load_from_db(blob_id: i64, tx: &Transaction) -> Result<Self> { in load_from_db()
204 let mut stmt = tx in load_from_db()
228 fn store_in_db(&self, blob_id: i64, tx: &Transaction) -> Result<()> { in store_in_db()
229 let mut stmt = tx in store_in_db()
879 db.with_transaction(TransactionBehavior::Immediate, |tx| { in new()
880 versioning::upgrade_database(tx, Self::CURRENT_DB_VERSION, Self::UPGRADERS) in new()
[all …]
|
| D | rkpd_client.rs | 122 let (tx, rx) = oneshot::channel(); in get_rkpd_registration()
123 let cb = GetRegistrationCallback::new_native_binder(tx); in get_rkpd_registration()
200 let (tx, rx) = oneshot::channel(); in get_rkpd_attestation_key_from_registration_async()
201 let cb = GetKeyCallback::new_native_binder(tx); in get_rkpd_attestation_key_from_registration_async()
268 let (tx, rx) = oneshot::channel(); in store_rkpd_attestation_key_with_registration_async()
269 let cb = StoreUpgradedKeyCallback::new_native_binder(tx); in store_rkpd_attestation_key_with_registration_async()
416 let (tx, rx) = oneshot::channel(); in get_mock_registration()
417 let cb = GetRegistrationCallback::new_native_binder(tx); in get_mock_registration()
440 let (tx, rx) = oneshot::channel(); in test_get_registration_cb_cancel()
441 let cb = GetRegistrationCallback::new_native_binder(tx); in test_get_registration_cb_cancel()
[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/libfmq/tests/ |
| D | fmq_unit_tests.cpp | 737 typename TypeParam::MQType::MemTransaction tx; in TYPED_TEST() local
738 ASSERT_TRUE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
740 ASSERT_TRUE(tx.copyTo(data, 0 /* startIdx */, dataLen)); in TYPED_TEST()
746 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
748 ASSERT_TRUE(tx.copyFrom(readData, 0 /* startIdx */, dataLen)); in TYPED_TEST()
765 typename TypeParam::MQType::MemTransaction tx; in TYPED_TEST() local
766 ASSERT_TRUE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
768 auto first = tx.getFirstRegion(); in TYPED_TEST()
769 auto second = tx.getSecondRegion(); in TYPED_TEST()
773 uint8_t* ptr = tx.getSlot(i); in TYPED_TEST()
[all …]
|
| D | msgq_test_client.cpp | 664 typename TypeParam::MQType::MemTransaction tx; in TYPED_TEST() local
665 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
667 const auto& region = tx.getFirstRegion(); in TYPED_TEST()
699 typename TypeParam::MQType::MemTransaction tx; in TYPED_TEST() local
700 ASSERT_TRUE(this->mQueue->beginRead(dataLen, &tx)); in TYPED_TEST()
702 auto first = tx.getFirstRegion(); in TYPED_TEST()
703 auto second = tx.getSecondRegion(); in TYPED_TEST()
745 typename TypeParam::MQType::MemTransaction tx; in TYPED_TEST() local
746 ASSERT_TRUE(this->mQueue->beginWrite(dataLen, &tx)); in TYPED_TEST()
748 auto first = tx.getFirstRegion(); in TYPED_TEST()
[all …]
|
| /system/security/keystore2/legacykeystore/ |
| D | lib.rs | 64 .and_then(|tx| f(&tx).map(|result| (result, tx))) in with_transaction()
65 .and_then(|(result, tx)| { in with_transaction()
66 tx.commit().context("In with_transaction: Failed to commit transaction.")?; in with_transaction()
91 self.with_transaction(TransactionBehavior::Immediate, |tx| { in init_tables()
92 tx.execute( in init_tables()
106 self.with_transaction(TransactionBehavior::Deferred, |tx| { in list()
107 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/nfc/src/rust/nci/ |
| D | nci.rs | 101 let (tx, rx) = oneshot::channel::<ResponsePacket>(); in send()
104 pending: PendingCommand { cmd, response: tx }, in send()
116 let (tx, rx) = oneshot::channel::<ResponsePacket>(); in send_and_notify()
120 pending: PendingCommand { cmd, response: tx }, in send_and_notify()
|
| D | api.rs | 93 let (tx, rx) = oneshot::channel::<HalEventStatus>(); in nfc_disable()
95 hr.register(HalEvent::CloseComplete, tx).await; in nfc_disable()
|
| /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 | 128 typename Queue::MemTransaction tx; in reader() local
130 if (!readMq.beginRead(numElements, &tx)) { in reader()
133 const auto& region = tx.getFirstRegion(); in reader()
186 typename Queue::MemTransaction tx; in writer() local
188 if (!writeMq.beginWrite(numElements, &tx)) { in writer()
194 const auto& region = tx.getFirstRegion(); in writer()
|
| /system/core/trusty/apploader/ |
| D | apploader.cpp | 173 struct iovec tx[2] = {{&hdr, sizeof(hdr)}, {&req, sizeof(req)}}; in send_load_message() local
178 return tipc_send(tipc_fd, tx, 2, &shm, 1); in send_load_message()
|
| /system/libfmq/include/fmq/ |
| D | MessageQueueBase.h | 809 MemTransaction tx; in write() local
810 return beginWrite(nMessages, &tx) && tx.copyTo(data, 0 /* startIdx */, nMessages) && in write()
1141 MemTransaction tx; in read() local
1142 return beginRead(nMessages, &tx) && tx.copyFrom(data, 0 /* startIdx */, nMessages) && in read()
|
| /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/logging/liblog/tests/ |
| D | liblog_benchmark.cpp | 683 log_time* tx = reinterpret_cast<log_time*>(eventData + 4 + 1); in BM_log_latency() local
684 if (ts != *tx) { in BM_log_latency()
756 log_time* tx = reinterpret_cast<log_time*>(eventData + 4 + 1); in BM_log_delay() local
757 if (ts != *tx) { in BM_log_delay()
|
| D | liblog_test.cpp | 273 log_time* tx = reinterpret_cast<log_time*>(&eventData->payload.data); in TEST() local
274 if (ts == *tx) { in TEST()
276 } else if (ts1 == *tx) { in TEST()
1547 log_time tx(reinterpret_cast<char*>(&eventData->payload.data)); in count_matching_ts()
1548 if (ts != tx) continue; in count_matching_ts()
1852 log_time tx(reinterpret_cast<char*>(&eventData->payload.data)); in TEST()
1853 if (ts == tx) { in TEST()
|
| /system/logging/logcat/tests/ |
| D | logcat_test.cpp | 481 log_time* tx = reinterpret_cast<log_time*>(&t); in TEST() local
482 if (ts == *tx) { in TEST()
526 log_time* tx = reinterpret_cast<log_time*>(&t); in TEST() local
527 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)
|