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

Test

naisila/rebalancer_pt
naisila 2022-11-17 10:51:09 +03:00
parent 8e5ba45b74
commit 60c45914c5
1 changed files with 19 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
src/backend/distributed/replication/multi_logical_replication.c
View File

@ -115,7 +115,7 @@ bool PlacementMovedUsingLogicalReplicationInTX = false;
static int logicalReplicationProgressReportTimeout = 10 * 1000; static int logicalReplicationProgressReportTimeout = 10 * 1000;
static List * PrepareReplicationSubscriptionList(List *shardList); // static List * PrepareReplicationSubscriptionList(List *shardList);
static List * GetReplicaIdentityCommandListForShard(Oid relationId, uint64 shardId); static List * GetReplicaIdentityCommandListForShard(Oid relationId, uint64 shardId);
static List * GetIndexCommandListForShardBackingReplicaIdentity(Oid relationId, static List * GetIndexCommandListForShardBackingReplicaIdentity(Oid relationId,
uint64 shardId); uint64 shardId);
@ -176,7 +176,7 @@ LogicallyReplicateShards(List *shardList, char *sourceNodeName, int sourceNodePo
char *superUser = CitusExtensionOwnerName(); char *superUser = CitusExtensionOwnerName();
char *databaseName = get_database_name(MyDatabaseId); char *databaseName = get_database_name(MyDatabaseId);
int connectionFlags = FORCE_NEW_CONNECTION; int connectionFlags = FORCE_NEW_CONNECTION;
List *replicationSubscriptionList = PrepareReplicationSubscriptionList(shardList); List *replicationSubscriptionList = shardList;
/* no shards to move */ /* no shards to move */
if (list_length(replicationSubscriptionList) == 0) if (list_length(replicationSubscriptionList) == 0)
@ -648,25 +648,25 @@ DropAllLogicalReplicationLeftovers(LogicalRepType type)
* to a partitioned tables should be exluded from logical replication * to a partitioned tables should be exluded from logical replication
* subscription list. * subscription list.
*/ */
static List * // static List *
PrepareReplicationSubscriptionList(List *shardList) // PrepareReplicationSubscriptionList(List *shardList)
{ // {
List *replicationSubscriptionList = NIL; // List *replicationSubscriptionList = NIL;
ListCell *shardCell = NULL; // ListCell *shardCell = NULL;
foreach(shardCell, shardList) // foreach(shardCell, shardList)
{ // {
ShardInterval *shardInterval = (ShardInterval *) lfirst(shardCell); // ShardInterval *shardInterval = (ShardInterval *) lfirst(shardCell);
if (!PartitionedTable(shardInterval->relationId)) // if (!PartitionedTable(shardInterval->relationId))
{ // {
/* only add regular and child tables to subscription */ // /* only add regular and child tables to subscription */
replicationSubscriptionList = lappend(replicationSubscriptionList, // replicationSubscriptionList = lappend(replicationSubscriptionList,
shardInterval); // shardInterval);
} // }
} // }
return replicationSubscriptionList; // return replicationSubscriptionList;
} // }
/* /*