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

Add ensure no modification back

ref_on_buraks
Burak Velioglu 2022-01-27 13:16:43 +03:00
parent 64ab7111ba
commit ee69a5a0b5
No known key found for this signature in database
GPG Key ID: F6827E620F6549C6
3 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/backend/distributed/metadata/metadata_sync.c
View File

@ -83,7 +83,6 @@
char *EnableManualMetadataChangesForUser = ""; char *EnableManualMetadataChangesForUser = "";
static void EnsureSequentialModeMetadataOperations(void);
static List * CitusTableMetadataCreateCommandList(Oid relationId); static List * CitusTableMetadataCreateCommandList(Oid relationId);
static void EnsureObjectMetadataIsSane(int distributionArgumentIndex, static void EnsureObjectMetadataIsSane(int distributionArgumentIndex,
int colocationId); int colocationId);
@ -276,7 +275,7 @@ SyncCitusTableMetadata(Oid relationId)
* visible on all connections used by the transaction, meaning we can only use 1 * visible on all connections used by the transaction, meaning we can only use 1
* connection per node. * connection per node.
*/ */
static void void
EnsureSequentialModeMetadataOperations(void) EnsureSequentialModeMetadataOperations(void)
{ {
if (!IsTransactionBlock()) if (!IsTransactionBlock())

1
src/backend/distributed/metadata/node_metadata.c
View File

@ -798,6 +798,7 @@ SyncObjectDependenciesToNode(WorkerNode *workerNode)
return; return;
} }
EnsureSequentialModeMetadataOperations();
Assert(ShouldPropagate()); Assert(ShouldPropagate());
List *commandList = SyncObjectDependenciesCommandList(workerNode); List *commandList = SyncObjectDependenciesCommandList(workerNode);

1
src/include/distributed/metadata_sync.h
View File

@ -31,6 +31,7 @@ typedef enum
/* Functions declarations for metadata syncing */ /* Functions declarations for metadata syncing */
extern void SyncNodeMetadataToNode(const char *nodeNameString, int32 nodePort); extern void SyncNodeMetadataToNode(const char *nodeNameString, int32 nodePort);
extern void SyncCitusTableMetadata(Oid relationId); extern void SyncCitusTableMetadata(Oid relationId);
extern void EnsureSequentialModeMetadataOperations(void);
extern bool ClusterHasKnownMetadataWorkers(void); extern bool ClusterHasKnownMetadataWorkers(void);
extern char * LocalGroupIdUpdateCommand(int32 groupId); extern char * LocalGroupIdUpdateCommand(int32 groupId);
extern bool ShouldSyncTableMetadata(Oid relationId); extern bool ShouldSyncTableMetadata(Oid relationId);