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

[TABLELOCK] add is_for_replace_ for ObLockParam

Browse Source
This commit is contained in:
YangEfei
2024-03-27 06:45:31 +00:00
committed by ob-robot
parent 926c12a4d2
commit 9794cd443c
2 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
src/storage/tablelock/ob_table_lock_rpc_struct.cpp
View File

@ -30,7 +30,8 @@ OB_SERIALIZE_MEMBER(ObLockParam,
is_deadlock_avoid_enabled_,
is_try_lock_,
expired_time_,
schema_version_);
schema_version_,
is_for_replace_);
OB_SERIALIZE_MEMBER(ObLockRequest,
type_,

6
src/storage/tablelock/ob_table_lock_rpc_struct.h
View File

@ -72,7 +72,8 @@ public:
is_deadlock_avoid_enabled_(false),
is_try_lock_(true),
expired_time_(0),
schema_version_(-1)
schema_version_(-1),
is_for_replace_(false)
{}
virtual ~ObLockParam() { reset(); }
void reset();
@ -88,7 +89,7 @@ public:
bool is_valid() const;
TO_STRING_KV(K_(lock_id), K_(lock_mode), K_(owner_id), K_(op_type),
K_(is_deadlock_avoid_enabled),
K_(is_try_lock), K_(expired_time), K_(schema_version));
K_(is_try_lock), K_(expired_time), K_(schema_version), K_(is_for_replace));
ObLockID lock_id_;
ObTableLockMode lock_mode_;
@ -103,6 +104,7 @@ public:
int64_t expired_time_;
// current schema version
int64_t schema_version_;
bool is_for_replace_;
};
struct ObLockRequest