external
/
citus
mirror of https://github.com/citusdata/citus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix tests

pull/5899/head
gledis69 2022-04-25 19:01:31 +03:00
parent 5d6ac5d0a1
commit d50c015934
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/utils/resource_lock.c
View File

@ -1129,7 +1129,7 @@ AcquireDistributedLockOnRelations_Internal(List *relationIdList, LOCKMODE lockMo
LOCK_RELATION_IF_EXISTS;
appendStringInfo(lockRelationCommand, lockCommand,
quote_literal_cstr(qualifiedRelationName),
lockModeCString);
quote_literal_cstr(lockModeCString));
/* preemptive permission check so a worker connection is not */
/* established if the user is not allowed to acquire the lock */

4
src/include/distributed/resource_lock.h
View File

@ -117,9 +117,9 @@ typedef enum CitusOperations
#define DIST_LOCK_NOWAIT 1 << 2
#define LOCK_RELATION_IF_EXISTS \
"SELECT pg_catalog.lock_relation_if_exists(%s, quote_literal_cstr(%s));"
"SELECT pg_catalog.lock_relation_if_exists(%s, %s);"
#define LOCK_RELATION_IF_EXISTS_NOWAIT \
"SELECT pg_catalog.lock_relation_if_exists(%s, quote_literal_cstr(%s), nowait => true);"
"SELECT pg_catalog.lock_relation_if_exists(%s, %s, nowait => true);"
/* Lock shard/relation metadata for safe modifications */
extern void LockShardDistributionMetadata(int64 shardId, LOCKMODE lockMode);