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

Rename AppropriateReplicationModel -> DecideReplicationModel (#3842)

pull/3846/head
SaitTalhaNisanci 2020-05-17 10:24:14 +03:00 committed by GitHub
parent 8f9ef63e8a
commit 80e34382cf
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/backend/distributed/commands/create_distributed_table.c
View File

@ -85,7 +85,7 @@ int ReplicationModel = REPLICATION_MODEL_COORDINATOR;
/* local function forward declarations */ /* local function forward declarations */
static char AppropriateReplicationModel(char distributionMethod, bool viaDeprecatedAPI); static char DecideReplicationModel(char distributionMethod, bool viaDeprecatedAPI);
static void CreateHashDistributedTableShards(Oid relationId, Oid colocatedTableId, static void CreateHashDistributedTableShards(Oid relationId, Oid colocatedTableId,
bool localTableEmpty); bool localTableEmpty);
static uint32 ColocationIdForNewTable(Oid relationId, Var *distributionColumn, static uint32 ColocationIdForNewTable(Oid relationId, Var *distributionColumn,
@ -341,8 +341,8 @@ void
CreateDistributedTable(Oid relationId, Var *distributionColumn, char distributionMethod, CreateDistributedTable(Oid relationId, Var *distributionColumn, char distributionMethod,
char *colocateWithTableName, bool viaDeprecatedAPI) char *colocateWithTableName, bool viaDeprecatedAPI)
{ {
char replicationModel = AppropriateReplicationModel(distributionMethod, char replicationModel = DecideReplicationModel(distributionMethod,
viaDeprecatedAPI); viaDeprecatedAPI);
/* /*
* ColocationIdForNewTable assumes caller acquires lock on relationId. In our case, * ColocationIdForNewTable assumes caller acquires lock on relationId. In our case,
@ -437,13 +437,13 @@ CreateDistributedTable(Oid relationId, Var *distributionColumn, char distributio
/* /*
* AppropriateReplicationModel function decides which replication model should be * DecideReplicationModel function decides which replication model should be
* used depending on given distribution configuration and global ReplicationModel * used depending on given distribution configuration and global ReplicationModel
* variable. If ReplicationModel conflicts with distribution configuration, this * variable. If ReplicationModel conflicts with distribution configuration, this
* function errors out. * function errors out.
*/ */
static char static char
AppropriateReplicationModel(char distributionMethod, bool viaDeprecatedAPI) DecideReplicationModel(char distributionMethod, bool viaDeprecatedAPI)
{ {
if (viaDeprecatedAPI) if (viaDeprecatedAPI)
{ {