From 205ab01a53e818cc4513d6a62fa4bb36756a4639 Mon Sep 17 00:00:00 2001 From: Sameer Awasekar Date: Wed, 3 Aug 2022 16:15:10 +0530 Subject: [PATCH] Add bit map singleton call --- .../shardsplit/shardsplit_logical_replication.c | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/src/backend/distributed/shardsplit/shardsplit_logical_replication.c b/src/backend/distributed/shardsplit/shardsplit_logical_replication.c index 1f131df3f..47ad269e3 100644 --- a/src/backend/distributed/shardsplit/shardsplit_logical_replication.c +++ b/src/backend/distributed/shardsplit/shardsplit_logical_replication.c @@ -393,9 +393,7 @@ WaitForShardSplitRelationSubscriptionsBecomeReady(List *shardSplitPubSubMetadata ShardSplitSubscriberMetadata *shardSplitPubSubMetadata = NULL; foreach_ptr(shardSplitPubSubMetadata, shardSplitPubSubMetadataList) { - Bitmapset *tableOwnerIds = NULL; - tableOwnerIds = bms_add_member(tableOwnerIds, - shardSplitPubSubMetadata->tableOwnerId); + Bitmapset *tableOwnerIds = bms_make_singleton(shardSplitPubSubMetadata->tableOwnerId); WaitForRelationSubscriptionsBecomeReady( shardSplitPubSubMetadata->targetNodeConnection, tableOwnerIds, SHARD_SPLIT_SUBSCRIPTION_PREFIX); @@ -414,10 +412,7 @@ WaitForShardSplitRelationSubscriptionsToBeCaughtUp(XLogRecPtr sourcePosition, ShardSplitSubscriberMetadata *shardSplitPubSubMetadata = NULL; foreach_ptr(shardSplitPubSubMetadata, shardSplitPubSubMetadataList) { - Bitmapset *tableOwnerIds = NULL; - tableOwnerIds = bms_add_member(tableOwnerIds, - shardSplitPubSubMetadata->tableOwnerId); - + Bitmapset *tableOwnerIds = bms_make_singleton(shardSplitPubSubMetadata->tableOwnerId); WaitForShardSubscriptionToCatchUp(shardSplitPubSubMetadata->targetNodeConnection, sourcePosition, tableOwnerIds,