Minor refactors

velioglu/wo_seq_test_1
Burak Velioglu 2022-01-13 01:01:47 +03:00
parent 33efade04c
commit 02526f1bee
No known key found for this signature in database
GPG Key ID: F6827E620F6549C6
5 changed files with 4 additions and 7 deletions

View File

@ -82,7 +82,7 @@
/* managed via a GUC */ /* managed via a GUC */
char *EnableManualMetadataChangesForUser = ""; char *EnableManualMetadataChangesForUser = "";
static void EnsureSequentialModeMetadataOperations(void);
static List * GetDistributedTableMetadataEvents(Oid relationId); static List * GetDistributedTableMetadataEvents(Oid relationId);
static void EnsureObjectMetadataIsSane(int distributionArgumentIndex, static void EnsureObjectMetadataIsSane(int distributionArgumentIndex,
int colocationId); int colocationId);
@ -101,6 +101,7 @@ static GrantStmt * GenerateGrantOnSchemaStmtForRights(Oid roleOid,
char *permission, char *permission,
bool withGrantOption); bool withGrantOption);
static void SetLocalEnableDependencyCreation(bool state);
static char * GenerateSetRoleQuery(Oid roleOid); static char * GenerateSetRoleQuery(Oid roleOid);
static void MetadataSyncSigTermHandler(SIGNAL_ARGS); static void MetadataSyncSigTermHandler(SIGNAL_ARGS);
static void MetadataSyncSigAlrmHandler(SIGNAL_ARGS); static void MetadataSyncSigAlrmHandler(SIGNAL_ARGS);

View File

@ -29,7 +29,6 @@ typedef enum
/* Functions declarations for metadata syncing */ /* Functions declarations for metadata syncing */
extern void StartMetadataSyncToNode(const char *nodeNameString, int32 nodePort); extern void StartMetadataSyncToNode(const char *nodeNameString, int32 nodePort);
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);
@ -60,7 +59,6 @@ extern BackgroundWorkerHandle * SpawnSyncMetadataToNodes(Oid database, Oid owner
extern void SyncMetadataToNodesMain(Datum main_arg); extern void SyncMetadataToNodesMain(Datum main_arg);
extern void SignalMetadataSyncDaemon(Oid database, int sig); extern void SignalMetadataSyncDaemon(Oid database, int sig);
extern bool ShouldInitiateMetadataSync(bool *lockFailure); extern bool ShouldInitiateMetadataSync(bool *lockFailure);
extern void SetLocalEnableDependencyCreation(bool state);
extern List * SequenceDependencyCommandList(Oid relationId); extern List * SequenceDependencyCommandList(Oid relationId);
extern List * DDLCommandsForSequence(Oid sequenceOid, char *ownerName); extern List * DDLCommandsForSequence(Oid sequenceOid, char *ownerName);

View File

@ -187,7 +187,7 @@ test: multi_repartition_udt multi_repartitioned_subquery_udf multi_subtransactio
test: multi_modifying_xacts test: multi_modifying_xacts
test: check_mx test: check_mx
test: turn_mx_off test: turn_mx_off
# test: multi_generate_ddl_commands multi_repair_shards test: multi_generate_ddl_commands multi_repair_shards
test: multi_create_shards test: multi_create_shards
test: turn_mx_on test: turn_mx_on
test: multi_transaction_recovery test: multi_transaction_recovery

View File

@ -15,7 +15,7 @@
# --- # ---
test: multi_extension test: multi_extension
test: multi_test_helpers multi_test_helpers_superuser test: multi_test_helpers multi_test_helpers_superuser
#test: multi_mx_node_metadata test: multi_mx_node_metadata
test: multi_cluster_management test: multi_cluster_management
test: multi_mx_function_table_reference test: multi_mx_function_table_reference
test: multi_test_catalog_views test: multi_test_catalog_views

View File

@ -6,8 +6,6 @@
-- metadata changes to MX tables. -- metadata changes to MX tables.
-- Turn metadata sync off at first -- Turn metadata sync off at first
\c - - - :master_port
SELECT stop_metadata_sync_to_node('localhost', :worker_1_port); SELECT stop_metadata_sync_to_node('localhost', :worker_1_port);
SELECT stop_metadata_sync_to_node('localhost', :worker_2_port); SELECT stop_metadata_sync_to_node('localhost', :worker_2_port);