Lines Matching refs:current_transaction

259     current_transaction: Option<DArc<Transaction>>,  field
288 current_transaction: None, in new()
343 let transaction = self.current_transaction.take().ok_or(EINVAL)?; in pop_transaction_to_reply()
345 self.current_transaction = Some(transaction); in pop_transaction_to_reply()
349 self.current_transaction = transaction.find_from(thread).cloned(); in pop_transaction_to_reply()
354 match self.current_transaction.take() { in pop_transaction_replied()
358 self.current_transaction = Some(old); in pop_transaction_replied()
361 self.current_transaction = old.clone_next(); in pop_transaction_replied()
395 self.current_transaction.is_none() && !self.process_work_list && self.is_looper() in should_use_process_work_queue()
460 if print_all || inner.current_transaction.is_some() || !inner.work_list.is_empty() { in debug_print()
470 let mut t_opt = inner.current_transaction.as_ref(); in debug_print()
498 self.inner.lock().current_transaction = Some(transaction); in set_current_transaction()
502 self.inner.lock().current_transaction.is_some() in has_current_transaction()
1149 match &inner.current_transaction { in is_current_transaction()
1160 if let Some(cur) = &inner.current_transaction { in top_of_transaction_stack()
1207 if !transaction.is_stacked_on(&inner.current_transaction) { in transaction_inner()
1211 inner.current_transaction = Some(transaction.clone_arc()); in transaction_inner()
1222 transaction = inner.current_transaction.take().unwrap(); in transaction_inner()
1223 inner.current_transaction = transaction.clone_next(); in transaction_inner()