Searched refs:txn (Results 1 – 3 of 3) sorted by relevance
| /system/libfmq/ |
| D | libfmq.rs | 146 let txn = std::mem::take(&mut self.inner); in drop() localVariable
147 self.queue.commit_write(txn); in drop()
273 let txn = self.begin_write(n)?; in write_many() localVariable
274 Some(WriteCompletion { inner: txn, queue: self, n_elems: n, n_written: 0 }) in write_many()
277 fn commit_write(&mut self, txn: MemTransaction) -> bool { in commit_write()
280 unsafe { self.inner.commitWrite(txn.first.length + txn.second.length) } in commit_write()
284 let mut txn: MemTransaction = Default::default(); in begin_write() localVariable
289 unsafe { self.inner.beginWrite(n, addr_of_mut!(txn)) }.then_some(txn) in begin_write()
294 fn ptr<T: Share>(txn: &MemTransaction, idx: usize) -> *mut T { in ptr()
295 let (base, region_idx) = if idx < txn.first.length { in ptr()
[all …]
|
| /system/chre/java/test/utils/src/com/google/android/utils/chre/ |
| D | ChreTestUtil.java | 102 ContextHubTransaction<Void> txn = manager.loadNanoApp(info, nanoAppBinary); in loadNanoApp() local
105 resp = txn.waitForResponse(TIMEOUT_LOAD_NANOAPP_SECONDS, TimeUnit.SECONDS); in loadNanoApp()
133 ContextHubTransaction<Void> txn = manager.unloadNanoApp(info, nanoAppId); in unloadNanoApp() local
136 resp = txn.waitForResponse(TIMEOUT_UNLOAD_NANOAPP_SECONDS, TimeUnit.SECONDS); in unloadNanoApp()
|
| /system/libfmq/tests/ |
| D | fmq_unit_tests.cpp | 1290 auto txn = AidlMessageQueueSync::MemRegion(); in TEST() local
1291 txn.getLengthInBytes(); in TEST()
|