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

Merge pull request #974 from citusdata/fix/use_access_share_lock 

Use AccessShareLock on the source table while creating a colocated table
pull/979/head
Metin Döşlü 2016-11-10 11:30:55 -08:00 committed by GitHub
parent 6810835e1a a0c92b38cb
commit ce3019d39e
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/backend/distributed/master/master_create_shards.c
View File

@ -41,6 +41,7 @@
#include "nodes/primnodes.h" #include "nodes/primnodes.h"
#include "postmaster/postmaster.h" #include "postmaster/postmaster.h"
#include "storage/fd.h" #include "storage/fd.h"
#include "storage/lmgr.h"
#include "storage/lock.h" #include "storage/lock.h"
#include "utils/builtins.h" #include "utils/builtins.h"
#include "utils/elog.h" #include "utils/elog.h"
@ -247,8 +248,8 @@ CreateColocatedShards(Oid targetRelationId, Oid sourceRelationId)
/* we plan to add shards: get an exclusive metadata lock on the target relation */ /* we plan to add shards: get an exclusive metadata lock on the target relation */
LockRelationDistributionMetadata(targetRelationId, ExclusiveLock); LockRelationDistributionMetadata(targetRelationId, ExclusiveLock);
/* a share metadata lock is enough on the source relation */ /* we don't want source table to get dropped before we colocate with it */
LockRelationDistributionMetadata(sourceRelationId, ShareLock); LockRelationOid(sourceRelationId, AccessShareLock);
/* prevent placement changes of the source relation until we colocate with them */ /* prevent placement changes of the source relation until we colocate with them */
sourceShardIntervalList = LoadShardIntervalList(sourceRelationId); sourceShardIntervalList = LoadShardIntervalList(sourceRelationId);