Lines Matching refs:current_transaction

267     current_transaction: Option<DArc<Transaction>>,  field
296 current_transaction: None, in new()
351 let transaction = self.current_transaction.take().ok_or(EINVAL)?; in pop_transaction_to_reply()
353 self.current_transaction = Some(transaction); in pop_transaction_to_reply()
357 self.current_transaction = transaction.find_from(thread).cloned(); in pop_transaction_to_reply()
362 match self.current_transaction.take() { in pop_transaction_replied()
366 self.current_transaction = Some(old); in pop_transaction_replied()
369 self.current_transaction = old.clone_next(); in pop_transaction_replied()
403 self.current_transaction.is_none() && !self.process_work_list && self.is_looper() in should_use_process_work_queue()
468 if print_all || inner.current_transaction.is_some() || !inner.work_list.is_empty() { in debug_print()
478 let mut t_opt = inner.current_transaction.as_ref(); in debug_print()
506 self.inner.lock().current_transaction = Some(transaction); in set_current_transaction()
510 self.inner.lock().current_transaction.is_some() in has_current_transaction()
1173 match &inner.current_transaction { in is_current_transaction()
1184 if let Some(cur) = &inner.current_transaction { in top_of_transaction_stack()
1231 if !transaction.is_stacked_on(&inner.current_transaction) { in transaction_inner()
1235 inner.current_transaction = Some(transaction.clone_arc()); in transaction_inner()
1246 transaction = inner.current_transaction.take().unwrap(); in transaction_inner()
1247 inner.current_transaction = transaction.clone_next(); in transaction_inner()