Lines Matching refs:Some

153             Some(sg_entry) => sg_entry,  in validate_parent_fixup()
345 self.current_transaction = Some(transaction); in pop_transaction_to_reply()
356 Some(old) => { in pop_transaction_replied()
358 self.current_transaction = Some(old); in pop_transaction_replied()
471 while let Some(t) = t_opt { in debug_print()
498 self.inner.lock().current_transaction = Some(transaction); in set_current_transaction()
518 return self.inner.lock().pop_work().ok_or(EAGAIN).map(Some); in get_work_local()
524 if let Some(work) = inner.pop_work() { in get_work_local()
525 return Ok(Some(work)); in get_work_local()
550 if let Some(work) = inner.pop_work() { in get_work()
551 return Ok(Some(work)); in get_work()
564 return self.process.get_work().ok_or(EAGAIN).map(Some); in get_work()
569 GetWorkOrRegister::Work(work) => return Ok(Some(work)), in get_work()
575 if let Some(work) = inner.pop_work() { in get_work()
576 return Ok(Some(work)); in get_work()
592 Some(work) => Ok(Some(work)), in get_work()
754 Some(parent_entry) => parent_entry, in translate_object()
797 Some(parent_entry) => parent_entry, in translate_object()
936 let mut secctx = if let Some(offset) = txn_security_ctx_offset { in copy_transaction_data()
945 Some((offset, ctx)) in copy_transaction_data()
957 Some((_offset, ctx)) => ptr_align(ctx.len()).ok_or(EINVAL)?, in copy_transaction_data()
1067 if let Some(sg_state) = sg_state.as_mut() { in copy_transaction_data()
1074 if let Some((off_out, secctx)) = secctx.as_mut() { in copy_transaction_data()
1151 Some(current) => Arc::ptr_eq(current, transaction), in is_current_transaction()
1160 if let Some(cur) = &inner.current_transaction { in top_of_transaction_stack()
1165 Ok(Some(cur.clone())) in top_of_transaction_stack()
1211 inner.current_transaction = Some(transaction.clone_arc()); in transaction_inner()
1326 if let Some(buffer) = buffer { in write()
1412 Ok(Some(work)) => match work.into_arc().do_work(self, &mut writer) { in read()
1532 while let Ok(Some(work)) = self.get_work_local(false) { in release()