database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

skip locked

Browse Source
This commit is contained in:
zhoubin
2022-09-08 12:01:28 +08:00
parent 148f04f8e4
commit b9a173661d
50 changed files with 506 additions and 297 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/gausskernel/runtime/executor/execReplication.cpp
View File

@ -369,7 +369,7 @@ static bool RelationFindReplTupleByIndex(EState *estate, Relation rel, Relation
PushActiveSnapshot(GetLatestSnapshot());
res = tableam_tuple_lock(targetRel,
locktup, &buf, GetCurrentCommandId(false), lockmode, false, &hufd,
locktup, &buf, GetCurrentCommandId(false), lockmode, LockWaitBlock, &hufd,
false, false, /* don't follow updates */
false, /* eval */
GetLatestSnapshot(), tid, /* ItemPointer */
@ -535,7 +535,7 @@ static bool RelationFindReplTupleSeq(Relation rel, LockTupleMode lockmode, Tuple
PushActiveSnapshot(GetLatestSnapshot());
res = tableam_tuple_lock(targetRel, locktup, &buf, GetCurrentCommandId(false),
lockmode, false, &hufd, false,
lockmode, LockWaitBlock, &hufd, false,
false, /* don't follow updates */
false, /* eval */
GetLatestSnapshot(), tid, /* ItemPointer */