hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

lock wait mgr feature placeholder

Browse Source
This commit is contained in:
felix-w15
2024-07-29 15:17:47 +00:00
committed by ob-robot
parent c86ca4687b
commit 8cb9272c66
1 changed files with 24 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
src/storage/memtable/ob_row_conflict_info.h
View File

@ -36,7 +36,15 @@ public:
conflict_sess_id_pair_(),
conflict_tx_scheduler_(),
conflict_tx_id_(),
conflict_tx_hold_seq_() {}
conflict_tx_hold_seq_(),
conflict_hash_(0),
lock_seq_(0),
abs_timeout_(0),
lock_mode_(0),
last_compact_cnt_(0),
total_update_cnt_(0),
assoc_sess_id_(0),
holder_sess_id_(0) {}
~ObRowConflictInfo() = default;
ObRowConflictInfo(const ObRowConflictInfo &) = delete;// disallow default copy
ObRowConflictInfo &operator=(const ObRowConflictInfo &) = delete;// disallow default assign operator
@ -79,7 +87,9 @@ public:
}
TO_STRING_KV(K_(conflict_happened_addr), K_(conflict_ls), K_(conflict_tablet),
K_(conflict_row_key_str), K_(conflict_sess_id_pair), K_(conflict_tx_scheduler),
K_(conflict_tx_id), K_(conflict_tx_hold_seq));
K_(conflict_tx_id), K_(conflict_tx_hold_seq), K_(conflict_hash), K_(lock_seq),
K_(abs_timeout), K_(self_tx_id), K_(lock_mode), K_(last_compact_cnt), K_(total_update_cnt),
K_(assoc_sess_id), K_(holder_sess_id));
common::ObAddr conflict_happened_addr_;// distributed info
share::ObLSID conflict_ls_;// resource related
common::ObTabletID conflict_tablet_;// resource related
@ -88,10 +98,21 @@ public:
common::ObAddr conflict_tx_scheduler_;// holder related
transaction::ObTransID conflict_tx_id_;// holder related
transaction::ObTxSEQ conflict_tx_hold_seq_;// holder use sql identified by this seq to add row lock
uint64_t conflict_hash_; // conflict hash value
int64_t lock_seq_; // lock wait slot sequence num, used for lock wait manager
int64_t abs_timeout_; // query timeout ts
transaction::ObTransID self_tx_id_; // tx id who acquires lock
uint8_t lock_mode_; // used for table lock conflict
int64_t last_compact_cnt_; // row compact cnt
int64_t total_update_cnt_; // row update cnt
uint32_t assoc_sess_id_; // trx's associate session id who acquires lock
uint32_t holder_sess_id_; // lock holder session id
};
OB_SERIALIZE_MEMBER_TEMP(inline, ObRowConflictInfo, conflict_happened_addr_, conflict_ls_,
conflict_tablet_, conflict_row_key_str_, conflict_sess_id_pair_,
conflict_tx_scheduler_, conflict_tx_id_, conflict_tx_hold_seq_);
conflict_tx_scheduler_, conflict_tx_id_, conflict_tx_hold_seq_, conflict_hash_,
lock_seq_, abs_timeout_, self_tx_id_, lock_mode_, last_compact_cnt_,
total_update_cnt_, assoc_sess_id_, holder_sess_id_);
}
}
#endif