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

fix indentations

users/saawasek/non_blocking_split_integrated
Sameer Awasekar 2022-06-01 19:36:00 +05:30
parent f1be4888b9
commit f03a0343bc
3 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/backend/distributed/operations/split_shard_replication_setup.c
View File

@ -351,7 +351,7 @@ CreateShardSplitInfo(uint64 sourceShardIdToSplit,
/* Oid of dummy table at the source */ /* Oid of dummy table at the source */
Oid destSplitChildShardOid = GetTableLocalShardOid(citusTableOid, Oid destSplitChildShardOid = GetTableLocalShardOid(citusTableOid,
desSplitChildShardId); desSplitChildShardId);
if (citusTableOid == InvalidOid || if (citusTableOid == InvalidOid ||
sourceShardToSplitOid == InvalidOid || sourceShardToSplitOid == InvalidOid ||

5
src/backend/distributed/shardsplit/shardsplit_shared_memory.c
View File

@ -51,7 +51,7 @@ GetShardSplitInfoSMHeaderFromDSMHandle(dsm_handle dsmHandle)
} }
/* /*
* Detatching segment associated with resource owner with 'dsm_pin_mapping' call before the * Detatching segment associated with resource owner with 'dsm_pin_mapping' call before the
* resource owner releases, to avoid warning being logged and potential leaks. * resource owner releases, to avoid warning being logged and potential leaks.
*/ */
dsm_pin_mapping(dsmSegment); dsm_pin_mapping(dsmSegment);
@ -62,6 +62,7 @@ GetShardSplitInfoSMHeaderFromDSMHandle(dsm_handle dsmHandle)
return header; return header;
} }
/* /*
* GetShardSplitInfoSMArrayForSlot returns pointer to the array of * GetShardSplitInfoSMArrayForSlot returns pointer to the array of
* 'ShardSplitInfo' struct stored in the shared memory segment. * 'ShardSplitInfo' struct stored in the shared memory segment.
@ -95,7 +96,7 @@ GetShardSplitInfoSMArrayForSlot(char *slotName, int *shardSplitInfoCount)
/* /*
* AllocateSharedMemoryForShardSplitInfo is used to allocate and store * AllocateSharedMemoryForShardSplitInfo is used to allocate and store
* information about the shard undergoing a split. The function allocates dynamic * information about the shard undergoing a split. The function allocates dynamic
* shared memory segment consisting of a header and an array of ShardSplitInfo structure. * shared memory segment consisting of a header and an array of ShardSplitInfo structure.
* The contents of this shared memory segment are consumed by WAL sender process * The contents of this shared memory segment are consumed by WAL sender process
* during catch up phase of replication through logical decoding plugin. * during catch up phase of replication through logical decoding plugin.
* *

2
src/test/regress/sql/split_shard_replication_colocated_setup.sql
View File

@ -125,4 +125,4 @@ select pg_sleep(5);
SET search_path TO split_shard_replication_setup_schema; SET search_path TO split_shard_replication_setup_schema;
SELECT * from table_second_7; SELECT * from table_second_7;
SELECT * from table_second_8; SELECT * from table_second_8;
SELECT * from table_second_9; SELECT * from table_second_9;