lock0lock.ic
上传用户:romrleung
上传日期:2022-05-23
资源大小:18897k
文件大小:2k
源码类别:

MySQL数据库

开发平台:

Visual C++

  1. /******************************************************
  2. The transaction lock system
  3. (c) 1996 Innobase Oy
  4. Created 5/7/1996 Heikki Tuuri
  5. *******************************************************/
  6. #include "sync0sync.h"
  7. #include "srv0srv.h"
  8. #include "dict0dict.h"
  9. #include "row0row.h"
  10. #include "trx0sys.h"
  11. #include "trx0trx.h"
  12. #include "buf0buf.h"
  13. #include "page0page.h"
  14. #include "page0cur.h"
  15. #include "row0vers.h"
  16. #include "que0que.h"
  17. #include "btr0cur.h"
  18. #include "read0read.h"
  19. #include "log0recv.h"
  20. /*************************************************************************
  21. Calculates the fold value of a page file address: used in inserting or
  22. searching for a lock in the hash table. */
  23. UNIV_INLINE
  24. ulint
  25. lock_rec_fold(
  26. /*==========*/
  27. /* out: folded value */
  28. ulint space, /* in: space */
  29. ulint page_no)/* in: page number */
  30. {
  31. return(ut_fold_ulint_pair(space, page_no));
  32. }
  33. /*************************************************************************
  34. Calculates the hash value of a page file address: used in inserting or
  35. searching for a lock in the hash table. */
  36. UNIV_INLINE
  37. ulint
  38. lock_rec_hash(
  39. /*==========*/
  40. /* out: hashed value */
  41. ulint space, /* in: space */
  42. ulint page_no)/* in: page number */
  43. {
  44. return(hash_calc_hash(lock_rec_fold(space, page_no),
  45. lock_sys->rec_hash));
  46. }
  47. /*************************************************************************
  48. Checks if some transaction has an implicit x-lock on a record in a clustered
  49. index. */
  50. UNIV_INLINE
  51. trx_t*
  52. lock_clust_rec_some_has_impl(
  53. /*=========================*/
  54. /* out: transaction which has the x-lock, or
  55. NULL */
  56. rec_t* rec, /* in: user record */
  57. dict_index_t* index) /* in: clustered index */
  58. {
  59. dulint trx_id;
  60. #ifdef UNIV_SYNC_DEBUG
  61. ut_ad(mutex_own(&kernel_mutex));
  62. #endif /* UNIV_SYNC_DEBUG */
  63. ut_ad(index->type & DICT_CLUSTERED);
  64. ut_ad(page_rec_is_user_rec(rec));
  65. trx_id = row_get_rec_trx_id(rec, index);
  66. if (trx_is_active(trx_id)) {
  67. /* The modifying or inserting transaction is active */
  68. return(trx_get_on_id(trx_id));
  69. }
  70. return(NULL);
  71. }